HttpClient 4.0.1 - 如何释放连接？ [复制]

Question

我对一堆 URL 进行了循环，对于每个 URL，我都在执行以下操作：

private String doQuery(String url) {

  HttpGet httpGet = new HttpGet(url);
  setDefaultHeaders(httpGet); // static method
  HttpResponse response = httpClient.execute(httpGet);   // httpClient instantiated in constructor

  int rc = response.getStatusLine().getStatusCode();

  if (rc != 200) {
    // some stuff...
    return;
  }

  HttpEntity entity = response.getEntity();

  if (entity == null) {
    // some stuff...
    return;
  }

  // process the entity, get input stream etc

}

第一个查询没问题，第二个抛出这个异常：

线程“main”中的异常 java.lang.IllegalStateException： 无效使用 SingleClientConnManager：连接 仍然分配。确保释放 分配前的连接 另一个。在 org.apache.http.impl.conn.SingleClientConnManager.getConnection(SingleClientConnManager.java:199) 在 org.apache.http.impl.conn.SingleClientConnManager$1.getConnection(SingleClientConnManager.java:173)......

这只是一个简单的单线程应用程序。如何释放此连接？

Answer 1

Httpcomponents 4.1 推荐的方法是关闭连接并释放任何底层资源：

EntityUtils.consume(HttpEntity)

其中传递的HttpEntity 是一个响应实体。

Answer 2

这似乎很好用：

      if( response.getEntity() != null ) {
         response.getEntity().consumeContent();
      }//if

即使您没有打开它的内容，也不要忘记消费该实体。例如，您期望响应中的 HTTP_OK 状态并且没有得到它，您仍然必须使用实体！

Answer 3

要回答我自己的问题：要释放连接（以及与请求关联的任何其他资源），您必须关闭 HttpEntity 返回的 InputStream：

InputStream is = entity.getContent();

.... process the input stream ....

is.close();       // releases all resources

来自docs

Answer 4

从 4.2 版本开始，他们引入了一种更方便的方法来简化连接释放：HttpRequestBase.releaseConnection()

Answer 5

我正在附上一个专门针对 Apache HttpClient 4.0.1 的详细答案。我正在使用这个 HttpClient 版本，因为它是由 WAS v8.0 提供的，我需要在同样由 WAS v8.0 提供的 Apache Wink v1.1.1 中使用提供的 HttpClient 来对 Sharepoint 进行一些经过 NTLM 身份验证的 REST 调用.

引用 Apache HttpClient 邮件列表中的 Oleg Kalnichevski 的话：

几乎所有这些代码都是不必要的。 (1) HttpClient 将 只要实体自动释放底层连接 内容被消耗到流的末尾； (2) HttpClient 将 在任何 I/O 异常时自动释放底层连接 读取响应内容时抛出。无特殊处理 在这种情况下需要。

事实上，这完全足以确保资源的正确释放：

HttpResponse rsp = httpclient.execute(target, req); 
HttpEntity entity = rsp.getEntity(); 
if (entity != null) {
     InputStream instream = entity.getContent();
     try {
         // process content
     } finally {
         instream.close();
         // entity.consumeContent() would also do
     } 
}

就是这样。

Source

Answer 6

如果不使用响应，则可以使用以下代码中止请求：

// Low level resources should be released before initiating a new request
HttpEntity entity = response.getEntity();

if (entity != null) {
    // Do not need the rest
    httpPost.abort();
}

参考：http://hc.apache.org/httpcomponents-client-ga/tutorial/html/fundamentals.html#d5e143

Apache HttpClient 版本：4.1.3

Answer 7

我在多线程环境（Servlet）中使用 HttpClient 时遇到了这个问题。 一个 servlet 仍然保持连接，而另一个想要获得连接。

解决方案：

4.0 版使用ThreadSafeClientConnManager

4.2 版使用PoolingClientConnectionManager

并设置这两个设置器：

setDefaultMaxPerRoute
setMaxTotal

Answer 8

我正在使用 HttpClient 4.5.3，使用 CloseableHttpResponse#close 为我工作。

    CloseableHttpResponse response = client.execute(request);

    try {
        HttpEntity entity = response.getEntity();
        String body = EntityUtils.toString(entity);
        checkResult(body);
        EntityUtils.consume(entity);
    } finally {
        response.close();
    }

使用 Java7 及更高版本：

try (CloseableHttpResponse response = client.execute(request)) {
   ...
}

Answer 9

HTTP HEAD 请求的处理方式必须稍有不同，因为 response.getEntity() 为空。 相反，您必须捕获传递给 HttpClient.execute() 的 HttpContext 并检索连接参数以关闭它（无论如何在 HttpComponents 4.1.X 中）。

HttpRequest httpRqst = new HttpHead( uri );
HttpContext httpContext = httpFactory.createContext();
HttpResponse httpResp = httpClient.execute( httpRqst, httpContext );

...

// Close when finished
HttpEntity entity = httpResp.getEntity();
if( null != entity )
  // Handles standard 'GET' case
  EntityUtils.consume( entity );
else {
  ConnectionReleaseTrigger  conn =
      (ConnectionReleaseTrigger) httpContext.getAttribute( ExecutionContext.HTTP_CONNECTION );
  // Handles 'HEAD' where entity is not returned
  if( null != conn )
    conn.releaseConnection();
}

HttpComponents 4.2.X 向 HttpRequestBase 添加了一个 releaseConnection() 来简化此操作。

Answer 10

如果你想重新使用连接，那么你必须在每次使用后完全消费内容流，如下所示：

EntityUtils.consume(response.getEntity())

注意：即使状态码不是 200，您也需要消费内容流。不这样做会在下次使用时引发以下问题：

线程“main”java.lang.IllegalStateException 中的异常：SingleClientConnManager 的使用无效：连接仍然分配。确保在分配另一个连接之前释放连接。

如果是一次性使用，那么只需关闭连接就会释放与其关联的所有资源。

Answer 11

强烈建议使用处理程序来处理响应。

client.execute(yourRequest,defaultHanler);

它会通过consume(HTTPENTITY)方法自动释放连接。

处理程序示例：

private ResponseHandler<String> defaultHandler = new ResponseHandler<String>() {
    @Override
    public String handleResponse(HttpResponse response)
        throws IOException {
        int status = response.getStatusLine().getStatusCode();

        if (status >= 200 && status < 300) {
            HttpEntity entity = response.getEntity();
            return entity != null ? EntityUtils.toString(entity) : null;
        } else {
            throw new ClientProtocolException("Unexpected response status: " + status);
        }
    }
};

Answer 12

我遇到了同样的问题，并通过在方法结束时关闭响应来解决它：

try {
    // make the request and get the entity 
} catch(final Exception e) {
    // handle the exception
} finally {
    if(response != null) {
        response.close();
    }
}