并发编程网 - ifeve.com

2.3. HTTP 连接管理

2.3.1. 管理连接和连接管理器

HTTP 连接是复杂的、 有状态的、 非线程安全的对象，因此需要恰当的管理才能正常工作。HTTP连接一次只能由一个线程使用。HttpClient使用实现了HttpClientConnectionManager接口，被称为HTTP连接管理器的特殊实体去访问HTTP连接。

HTTP连接管理器的作用是作为一个工厂类来为新的HTTP连接使用,管理持久连接的生命周期和同步访问，确保一次只能由一个线程使用连接。 HTTP连接管理器内部与ManagedHttpClientConnection接口的实例一起工作，作为真实连接的代理来管理连接状态和控制I/O操作的执行。 如果一个受管的连接被它的使用者释放或显式关闭， 基础连接将从它的代理服务器上分离，并返回给管理器。即使服务使用者仍然持有对代理实例的引用，它不再是能够执行任何I/O操作或有意或无意地更改实际连接的状态。

这是一个从连接管理器获取连接的示例

HttpClientContext context = HttpClientContext.create();
HttpClientConnectionManager connMrg = new BasicHttpClientConnectionManager();
HttpRoute route = new HttpRoute(new HttpHost("localhost", 80));
// Request new connection. This can be a long process
ConnectionRequest connRequest = connMrg.requestConnection(route, null);
// Wait for connection up to 10 sec
HttpClientConnection conn = connRequest.get(10, TimeUnit.SECONDS);
try {
    // If not open
    if (!conn.isOpen()) {
        // establish connection based on its route info
        connMrg.connect(conn, route, 1000, context);
        // and mark it as route complete
        connMrg.routeComplete(conn, route, context);
    }
    // Do useful things with the connection.
} finally {
    connMrg.releaseConnection(conn, null, 1, TimeUnit.MINUTES);
}

如果有必要的话，连接请求可以通过调用ConnectionRequest#cancel()方法来提前终止。当线程阻塞在 ConnectionRequest#get()方法时，它将被解除阻塞。

PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
// Increase max total connection to 200
cm.setMaxTotal(200);
// Increase default max connection per route to 20
cm.setDefaultMaxPerRoute(20);
// Increase max connections for localhost:80 to 50
HttpHost localhost = new HttpHost("locahost", 80);
cm.setMaxPerRoute(new HttpRoute(localhost), 50);

CloseableHttpClient httpClient = HttpClients.custom()
        .setConnectionManager(cm)
        .build();

CloseableHttpClient httpClient = <...>
httpClient.close();