本文整理汇总了Java中org.apache.http.impl.DefaultBHttpServerConnectionFactory类的典型用法代码示例。如果您正苦于以下问题:Java DefaultBHttpServerConnectionFactory类的具体用法?Java DefaultBHttpServerConnectionFactory怎么用?Java DefaultBHttpServerConnectionFactory使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DefaultBHttpServerConnectionFactory类属于org.apache.http.impl包,在下文中一共展示了DefaultBHttpServerConnectionFactory类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: RequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public RequestListenerThread(
int port,
HttpService httpService,
SSLServerSocketFactory sf) throws IOException {
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
while (!createServerSocket(sf, port))
{
port++;
if (port >= 65535) {
System.out.println("Now the port is already in use,port number add 1");
ConsoleFactory.printToConsole("Now the port is already in use,port number add 1",true);
break;
}
}
monitorPort = port;
this.httpService = httpService;
}
开发者ID:HuaweiSNC,项目名称:OpsDev,代码行数:18,代码来源:ElementalHttpServer.java
示例2: RequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
/**
* Default constructor which specifies the <code>port</code> to listen to
* for requests and the <code>handlers</code>, which specify how to handle
* the request.
*
* @param port
* the port to listen to
* @param handlers
* the handlers, which specify how to handle the different
* requests
*
* @throws IOException
* if some IO operation fails
*/
public RequestListenerThread(final int port,
final Map<String, IHandler> handlers) throws IOException {
super(port);
// Set up the HTTP protocol processor
final HttpProcessor httpproc = new ImmutableHttpProcessor(
new HttpResponseInterceptor[] { new ResponseDate(),
new ResponseServer(), new ResponseContent(),
new ResponseConnControl() });
// Set up request handlers
UriHttpRequestHandlerMapper registry = new UriHttpRequestHandlerMapper();
for (final Entry<String, IHandler> entry : handlers.entrySet()) {
registry.register(entry.getKey(), entry.getValue());
}
// Set up the HTTP service
httpService = new HttpService(httpproc, registry);
connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
}
开发者ID:pmeisen,项目名称:gen-server-http-listener,代码行数:35,代码来源:RequestListenerThread.java
示例3: RequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public RequestListenerThread(
final int port,
final HttpService httpService,
final SSLServerSocketFactory sf) throws IOException {
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
this.serversocket = sf != null ? sf.createServerSocket(port) : new ServerSocket(port);
this.httpService = httpService;
}
开发者ID:whyDK37,项目名称:pinenut,代码行数:9,代码来源:HttpEndpoint.java
示例4: RequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public RequestListenerThread(
final int port,
final HttpService httpService,
final SSLServerSocketFactory sf) throws IOException {
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
this.serversocket = sf != null ? sf.createServerSocket(port) : new ServerSocket(port);
this.httpService = httpService;
// only 4 connections can run concurrently
connectionHandlerExecutor = Executors.newFixedThreadPool(100);
System.out.println("Request Listener Thread created");
}
开发者ID:anantoni,项目名称:SparrowWorker,代码行数:12,代码来源:RequestListenerThread.java
示例5: GenericRequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public GenericRequestListenerThread(
final int port,
final HttpService httpService,
final SSLServerSocketFactory sf) throws IOException {
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
this.serversocket = sf != null ? sf.createServerSocket(port) : new ServerSocket(port);
this.httpService = httpService;
// only 4 connections can run concurrently
connectionHandlerExecutor = Executors.newFixedThreadPool(1000);
//System.out.println("Request Listener Thread created");
}
开发者ID:anantoni,项目名称:SparrowScheduler,代码行数:13,代码来源:GenericRequestListenerThread.java
示例6: LateBindingRequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public LateBindingRequestListenerThread(
final int port,
final HttpService httpService,
final SSLServerSocketFactory sf) throws IOException {
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
this.serversocket = sf != null ? sf.createServerSocket(port) : new ServerSocket(port);
this.httpService = httpService;
// only 4 connections can run concurrently
connectionHandlerExecutor = Executors.newFixedThreadPool(22);
System.out.println("Request Listener Thread created");
}
开发者ID:anantoni,项目名称:SparrowScheduler,代码行数:13,代码来源:LateBindingRequestListenerThread.java
示例7: RequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public RequestListenerThread(final int port,
final HttpService httpService, final SSLServerSocketFactory sf)
throws IOException {
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
this.serversocket = sf != null ? sf.createServerSocket(port)
: new ServerSocket(port);
this.httpService = httpService;
LimitedQueue<Runnable> blockingQueue = new LimitedQueue<Runnable>(
10);
executor = new java.util.concurrent.ThreadPoolExecutor(1, 10, 0L,
TimeUnit.MILLISECONDS, blockingQueue);
}
开发者ID:ranoble,项目名称:Megapode,代码行数:13,代码来源:HttpServer.java
示例8: getHttpConnectionFactory
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public HttpConnectionFactory<DefaultBHttpServerConnection> getHttpConnectionFactory() {
if (null == _connectionFactory) _connectionFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
return _connectionFactory;
}
开发者ID:Sabadios,项目名称:Cherry,代码行数:6,代码来源:WebEngine.java
示例9: RequestListenerThread
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public RequestListenerThread(final int port, final HttpService httpService,
final SSLServerSocketFactory sf) throws IOException {
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
this.serversocket = sf != null ? sf.createServerSocket(port) : new ServerSocket(port);
this.httpService = httpService;
}
开发者ID:haogrgr,项目名称:haogrgr-test,代码行数:7,代码来源:HttpSrvMain.java
示例10: SimpleHttpServer
import org.apache.http.impl.DefaultBHttpServerConnectionFactory; //导入依赖的package包/类
public SimpleHttpServer(int port, ConnectedAddressesProvider connectedAddressesProvider){
this.connFactory = DefaultBHttpServerConnectionFactory.INSTANCE;
// Set up the HTTP protocol processor
HttpProcessor httpproc = HttpProcessorBuilder.create()
.add(new ResponseDate())
.add(new ResponseServer("Test/1.1"))
.add(new ResponseContent())
.add(new ResponseConnControl()).build();
// Set up request handlers
UriHttpRequestHandlerMapper reqistry = new UriHttpRequestHandlerMapper();
reqistry.register("*", new HttpRequestHandlerNew(connectedAddressesProvider));
// Set up the HTTP service
httpService = new HttpService(httpproc, reqistry);
try {
serversocket = new ServerSocket(port, 1, InetAddress.getByName("127.0.0.1"));
System.out.println("Listening on port " + serversocket.getLocalPort());
while (!Thread.interrupted()) {
try {
// Set up HTTP connection
Socket socket = serversocket.accept();
System.out.println("Incoming connection from " + socket.getInetAddress());
HttpServerConnection conn = connFactory.createConnection(socket);
// Start worker thread
Thread t = new WorkerThread(httpService, conn);
t.setDaemon(true);
t.start();
} catch (InterruptedIOException ex) {
break;
} catch (IOException e) {
System.err.println("I/O error initialising connection thread: "
+ e.getMessage());
break;
}
}
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
开发者ID:martinexner,项目名称:dcl,代码行数:46,代码来源:SimpleHttpServer.java
注:本文中的org.apache.http.impl.DefaultBHttpServerConnectionFactory类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论