下面列出了org.apache.http.HttpRequestFactory#org.apache.http.impl.DefaultHttpServerConnection 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
@Override
public void run() {
s_logger.info("ApiServer listening on port " + _serverSocket.getLocalPort());
while (!Thread.interrupted()) {
try {
// Set up HTTP connection
final Socket socket = _serverSocket.accept();
final DefaultHttpServerConnection conn = new DefaultHttpServerConnection();
conn.bind(socket, _params);
// Execute a new worker task to handle the request
s_executor.execute(new WorkerTask(_httpService, conn, s_workerCount++));
} catch (final InterruptedIOException ex) {
break;
} catch (final IOException e) {
s_logger.error("I/O error initializing connection thread", e);
break;
}
}
}
@Override
public void run() {
s_logger.info("ApiServer listening on port " + _serverSocket.getLocalPort());
while (!Thread.interrupted()) {
try {
// Set up HTTP connection
final Socket socket = _serverSocket.accept();
final DefaultHttpServerConnection conn = new DefaultHttpServerConnection();
conn.bind(socket, _params);
// Execute a new worker task to handle the request
s_executor.execute(new WorkerTask(_httpService, conn, s_workerCount++));
} catch (final InterruptedIOException ex) {
break;
} catch (final IOException e) {
s_logger.error("I/O error initializing connection thread", e);
break;
}
}
}
public ApacheServerConnection(Socket socket, DefaultHttpServerConnection connection) {
this.socket = socket;
this.connection = connection;
}
public ApacheServerConnection(Socket socket, DefaultHttpServerConnection connection) {
this.socket = socket;
this.connection = connection;
}