Java SocketListener类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.mortbay.http.SocketListener类的典型用法代码示例。如果您正苦于以下问题：Java SocketListener类的具体用法？Java SocketListener怎么用？Java SocketListener使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SocketListener类属于org.mortbay.http包，在下文中一共展示了SocketListener类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setupServer

import org.mortbay.http.SocketListener; //导入依赖的package包/类
private void setupServer() throws Exception
{
    this.server = new HttpServer();
    SocketListener listener = new SocketListener();
    listener.setPort(PORT);
    this.server.addListener(listener);
    HttpContext context = new HttpContext();
    context.setContextPath("/");

    ServletHandler servletHandler = new ServletHandler();
    context.addHandler(servletHandler);

    // Map a servlet onto the container
    ServletHolder holder =
            servletHandler.addServlet("JrpipServlet", "/JrpipServlet", "com.gs.jrpip.server.JrpipServlet");
    holder.put("serviceInterface.Echo", "com.gs.jrpip.Echo");
    holder.put("vmBoundServiceClass.Echo", "com.gs.jrpip.EchoImpl");
    holder.setInitOrder(10);

    this.server.addContext(context);

    this.server.start();
    this.servlet = (JrpipServlet) holder.getServlet();
}

开发者ID:goldmansachs，项目名称:jrpip，代码行数:25，代码来源:VmBoundServiceTest.java

示例2: setUpHttpServer

import org.mortbay.http.SocketListener; //导入依赖的package包/类
private void setUpHttpServer() throws Exception {
    server = new HttpServer();
    SocketListener listener = new SocketListener();
    listener.setPort(configuration.getPort());
    server.addListener(listener);

    ServletHttpContext servletContext = new ServletHttpContext();
    servletContext.setContextPath("jsunit");
    servletContext.setResourceBase(configuration.getResourceBase().toString());

    servletContext.addServlet("JSP", "*.jsp", JspServlet.class.getName());
    servletContext.addHandler(new ResourceHandler());

    ConfigurationManager.clearConfigurationProviders();
    ConfigurationManager.addConfigurationProvider(new XmlConfigurationProvider(xworkXmlName()));
    com.opensymphony.webwork.config.Configuration.set("webwork.action.extension", "");

    for (String servletName : servletNames())
        addWebworkServlet(servletContext, servletName);
    server.addContext(servletContext);

    if (Monitor.activeCount() == 0)
        Monitor.monitor();
}

开发者ID:BradNeuberg，项目名称:purple-include，代码行数:25，代码来源:AbstractJsUnitServer.java

示例3: setupServerWithHandler

import org.mortbay.http.SocketListener; //导入依赖的package包/类
protected void setupServerWithHandler(
        HttpHandler handler,
        SecurityConstraint constraint,
        UserRealm realm) throws Exception
{
    this.port = (int) (Math.random() * 10000.0 + 10000.0);
    this.jrpipUrl = "http://localhost:" + this.port + "/JrpipServlet";
    this.server = new HttpServer();
    SocketListener listener = new SocketListener();
    listener.setPort(this.port);
    this.server.addListener(listener);
    HttpContext context = new HttpContext();
    context.setContextPath("/");

    if (realm != null)
    {
        context.setRealm(realm);
    }

    if (constraint != null)
    {
        context.addSecurityConstraint("/", constraint);
    }

    if (handler != null)
    {
        context.addHandler(handler);
    }

    ServletHandler servletHandler = new ServletHandler();
    context.addHandler(servletHandler);

    ServletHolder holder = servletHandler.addServlet("JrpipServlet", "/JrpipServlet", "com.gs.jrpip.server.JrpipServlet");
    holder.put("serviceInterface.Echo", "com.gs.jrpip.Echo");
    holder.put("serviceClass.Echo", "com.gs.jrpip.EchoImpl");

    this.addCustomConfiguration(holder);

    holder.setInitOrder(10);

    this.server.addContext(context);
    this.server.start();
    this.servlet = (JrpipServlet) holder.getServlet();
}

开发者ID:goldmansachs，项目名称:jrpip，代码行数:45，代码来源:JrpipTestCase.java

示例4: setUp

import org.mortbay.http.SocketListener; //导入依赖的package包/类
@Setup @SuppressWarnings("unused")
private void setUp(HttpTestEnvironment env) throws Exception {
    server = new Server();
    SocketListener listener = new SocketListener();
    listener.setPort(env.getServerPort());
    server.addListener(listener);
    context = new HttpContext(server, Channel.CONTEXT_PATH + "/*");
    server.start();
}

开发者ID:wso2，项目名称:wso2-axis2-transports，代码行数:10，代码来源:JettyServer.java

示例5: testGet

import org.mortbay.http.SocketListener; //导入依赖的package包/类
@Validated @Test
public void testGet() throws Exception {
    Server server = new Server();
    SocketListener listener = new SocketListener();
    server.addListener(listener);
    HttpContext context = new HttpContext(server, "/*");
    HttpHandler handler = new AbstractHttpHandler() {
        public void handle(String pathInContext, String pathParams,
                HttpRequest request, HttpResponse response) throws HttpException, IOException {

            try {
                SOAPMessage message = MessageFactory.newInstance().createMessage();
                SOAPBody body = message.getSOAPBody();
                body.addChildElement("root");
                response.setContentType(SOAPConstants.SOAP_1_1_CONTENT_TYPE);
                message.writeTo(response.getOutputStream());
                request.setHandled(true);
            } catch (SOAPException ex) {
                throw new RuntimeException("Failed to generate SOAP message", ex);
            }
        }
    };
    context.addHandler(handler);
    server.start();
    try {
        SOAPConnectionFactory sf = new SOAPConnectionFactoryImpl();
        SOAPConnection con = sf.createConnection();
        URL urlEndpoint = new URL("http", "localhost", listener.getPort(), "/test");
        SOAPMessage reply = con.get(urlEndpoint);
        SOAPElement bodyElement = (SOAPElement)reply.getSOAPBody().getChildElements().next();
        assertEquals("root", bodyElement.getLocalName());
    } finally {
        server.stop();
    }
}

开发者ID:wso2，项目名称:wso2-axis2，代码行数:36，代码来源:SOAPConnectionTest.java

示例6: _main

import org.mortbay.http.SocketListener; //导入依赖的package包/类
public static void _main(String[] args)
        throws Exception {
    // Create the server
    HttpServer server = new HttpServer();
    int port = DEFAULT_PORT; 
    String strWebContext = "./web";
    String strServerContext="./server";
    if (args.length > 0) {
        port = Integer.parseInt(args[0]);
    }
    if (args.length > 1) {
    	strWebContext = args[1];
    }
    if (args.length > 2) {
    	strServerContext = args[2];
    }
    

    // Create a port listener
    SocketListener listener = new SocketListener();
    
    listener.setPort(port);
    server.addListener(listener);

 String host = null;

    // Create a context
    File webxml = new File(strServerContext + "/web.xml");
    if (webxml.exists()) {
    	System.err.println("not supported atm");
        //addWebXmlContext(server, "/", host, "/", strWebContext, strServerContext);
    } else {
    	addContext(server, "/", host, "/", strWebContext, strServerContext);
    }

    //addContext(server,"/susi/","localhost","/jm/",null,null);
    
    server.start();

 if ( host != null && !host.isEmpty() )
  DesktopUtil.launchBrowser( host, port, false );
}

开发者ID:lucee，项目名称:Lucee4，代码行数:43，代码来源:RunAsJavaApplication.java

注：本文中的org.mortbay.http.SocketListener类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。