如何使用Apache HttpClient获得持久的HttpConnection？

Question

在我的测试应用程序中，我使用Apache HttpClient向同一主机执行连续的HttpGet请求，但在每个下一个请求时，都会发现之前的HttpConnection被关闭并创建新的HttpConnection。

我使用同一个HttpClient实例，不关闭响应。我从每个实体获取InputStream，用扫描仪读取，然后关闭扫描仪。我测试了KeepAlivestStrategy，结果是真的。请求之间的时间间隔不超过keepAlive或ConnectionTimeOlive持续时间。

谁能告诉我这种行为的原因是什么？

已更新

我找到了解决方案。为了保持HttpConnecton的活力，在构建HttpClient时需要设置HttpClientConnectionManager。我使用了BasicHttpClientConnectionManager。

ConnectionKeepAliveStrategy keepAliveStrat = new DefaultConnectionKeepAliveStrategy() {
   @Override
   public long getKeepAliveDuration(HttpResponse response, HttpContext context)
   {
      long keepAlive = super.getKeepAliveDuration(response, context);
      if (keepAlive == -1)
         keepAlive = 120000;
      return keepAlive;
   }
};
HttpClientConnectionManager connectionManager = new BasicHttpClientConnectionManager();
try (CloseableHttpClient httpClient = HttpClients.custom()
            .setConnectionManager(connectionManager) // without this setting connection is not kept alive 
            .setDefaultCookieStore(store)
            .setKeepAliveStrategy(keepAliveStrat)
            .setConnectionTimeToLive(120, TimeUnit.SECONDS)
            .setUserAgent(USER_AGENT)
            .build())
{   
   HttpClientContext context = new HttpClientContext();
   RequestConfig config = RequestConfig.custom()
           .setCookieSpec(CookieSpecs.DEFAULT)
           .setSocketTimeout(10000)
           .setConnectTimeout(10000)
           .build();
   context.setRequestConfig(config);
   HttpGet httpGet = new HttpGet(uri);
   CloseableHttpResponse response = httpClient.execute(httpGet, context);
   HttpConnection conn = context.getConnection();
   HttpEntity entity = response.getEntity();
   try (Scanner in = new Scanner(entity.getContent(), ENC))
   {
      // do something
   }
   System.out.println("open=" + conn.isOpen()); // now open=true 

   HttpGet httpGet2 = new HttpGet(uri2); // on the same host with other path

   // and so on
} 

更新2

通常，使用conn.isOpen（）检查连接不是检查连接状态的正确方法，因为：“内部HTTP连接管理器使用ManagedHttpClientConnection的实例作为真实连接的代理，该连接管理连接状态并控制I/O操作的执行。如果托管连接被其使用者释放或显式关闭，则基础连接将与其代理分离并返回给管理器。即使服务消耗er仍然持有对代理实例的引用，它不再能够执行任何I/O操作，或者有意或无意地更改实际连接的状态。“（HttpClent教程）

正如@oleg所指出的，跟踪连接的正确方法是使用记录器。

Answer 1

从HttpClient网站上的示例：

// In order to ensure correct deallocation of system resources
// the user MUST call CloseableHttpResponse#close() from a finally clause.
// Please note that if response content is not fully consumed the underlying
// connection cannot be safely re-used and will be shut down and discarded
// by the connection manager. 

因此，正如@oleg所说，您需要在检查连接状态之前关闭HttpACK。

Answer 2

您的应用程序必须关闭响应对象，以确保基础连接的适当资源分配。响应关闭后，HttpClient将有效连接保持活动状态，并将其返回到连接管理器（连接池）。

我怀疑您的代码只是泄漏了连接，并且每个请求都会产生一个新创建的连接，而所有以前的连接都会继续在内存中堆积。

Answer 3

首先，您需要确保正在使用的远程服务器支持保持活动连接。只需检查远程服务器是否在每个响应中返回头Connection:Keep Alive或Connection:Closed。对于关闭案例，您对此无能为力。您可以使用此在线工具执行此类检查。

接下来，您需要实施本手册第#2.6段中定义的连接KeepAlivestStrategy。请注意，自HttpClient 4.0版以来，您可以使用现有的DefaultConnectionKeepAliveStrategy，这样您的HttpClient将按照以下方式构造：

HttpClient client = HttpClients.custom()
    .setKeepAliveStrategy(DefaultConnectionKeepAliveStrategy.INSTANCE)
    .build();

如果服务器支持，这将确保您的HttpClient实例将通过保持活动机制重用相同的连接。