Httpclient 4.0.3 随机挂起的多个帖子

Question

让我解释一下情况。

我有一个 servlet 将传出 GET/POST 重定向到另一个域（某种代理）上的另一个项目，其工作是处理它并返回一些内容（参数和 gif）。我使用 HttpClient 4.0.3 来执行此操作。

我的应用程序在启动时发送了多个 GET/POST，因此我设置了一次 ThreadSafeClientConnManager 来以这种方式处理多个线程。

cm_params = new BasicHttpParams();
ConnManagerParams.setMaxTotalConnections(cm_params, 200);

ConnPerRouteBean connPerRoute = new ConnPerRouteBean();
HttpHost localhost = new HttpHost("localhost");
connPerRoute.setMaxForRoute(new HttpRoute(localhost), 50);

ConnManagerParams.setMaxConnectionsPerRoute(cm_params, connPerRoute);

SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(
        new Scheme("http", PlainSocketFactory.getSocketFactory(), 80));

cm = new ThreadSafeClientConnManager(cm_params, schemeRegistry);

然后我使用这些参数创建一个新的 HttpClient，这应该足以同时处理一堆请求。当然，我对每个 GET/POST 都在 public void service() 上执行此操作，但在创建它后我使用相同的 Httpclient 对象。

httpclient = new DefaultHttpClient(cm, cm_params);

之后，我构建我的 POST 并通过执行发送它，并包含所有必需的参数和这样的三重验证。

    HttpPost httpPost = new HttpPost(target+tmpString); 

    httpPost.setHeader("Host", request.getHeader("host"));
    httpPost.setHeader("User-Agent", request.getHeader("user-agent"));
    httpPost.setHeader("Accept-Encoding", request.getHeader("accept-encoding"));
    httpPost.setHeader("Accept", request.getHeader("accept"));
    ..etc..

    UrlEncodedFormEntity urlEncodedFormEntity = new UrlEncodedFormEntity(params);
    urlEncodedFormEntity.setContentEncoding(HTTP.UTF_8);
    httpPost.setEntity(urlEncodedFormEntity);

    HttpResponse response = httpclient.execute(httpPost);

最后，我读取流并处理实体...

    OutputStream os = res.getOutputStream();
    InputStream is = response.getEntity().getContent();
    byte[] buf = new byte[1024];
    for(int n;(n=is.read(buf))!=-1;)
    {
        os.write(buf, 0, n);
    }
    // Make sure to close
    is.close();
    os.close();

    // Flush entities just in case
    EntityUtils.consume(urlEncodedFormEntity);
    EntityUtils.consume(response.getEntity());
    urlEncodedFormEntity.getContent().close();
    response.getEntity().getContent().close();

所以我的问题是，当我加载页面时，代码运行得很好。已正确处理 4 个发送的请求（1 个 GET、3 个 POST）。基本上返回一些参数和 1 个我在页面上打印的小 gif。

但是，一旦我开始对我的应用程序进行压力测试，IE 在 4-5 个选项卡中加载同一页面，每当我同时执行多个 POST 时，我的应用程序似乎都会随机挂起。我认为即使我使用相同的 Httpclient 对象，我也不会有任何问题，因为我正确声明了 ThreadSafeClientConnManager （我认为？），所以它应该处理多个线程。

有人知道我做错了什么吗？如果我一一加载我的选项卡，它不会挂起。就在我同时刷新多个选项卡时。

有人知道吗？ :S（抱歉英语不是我的母语^^;）

Answer 1

我陷入了同样的错误。我们注意到 HttpClient 不会自行关闭。

我所做的是，我在未清除的 HttpClient 和 HttpResponse 上尝试了 HttpClientUtils.closeQuietly() 方法。它帮助了我的事业，并且它不再挂起。您也可以尝试和试验它。

Answer 2

@Apache Fan，设置这个：

ConnManagerParams.setMaxTotalConnections(cm_params, 200);
connPerRoute.setDefaultMaxPerRoute(50);

怀疑我可能会耗尽连接，我打开 3-4 个选项卡，它就耗尽了...每个选项卡可能有 4 个 POST，所以不会加起来：S

Answer 3

您可能想从 HttpClient API -

ThreadSafeClientConnManager 维护每个路由和总连接的最大限制。默认情况下，此实现将为每个给定路由创建不超过 2 个并发连接，并且总共不超过 20 个连接。对于许多现实世界的应用程序来说，这些限制可能过于严格，特别是当它们使用 HTTP 作为其服务的传输协议时。但是，可以使用 HTTP 参数调整连接限制。

也许您的应用程序耗尽了池连接，您需要增加池大小。

Answer 4

最近我试图实现这一点，但我遇到了一些新问题，例如当我第一次发送请求时，它在没有cookie的情况下发送，但在第二次httpContext自动添加cookie
但这是标准的发送方式，但有时您请求的服务器会在没有cookie的情况下接受，因此我使用了INTERCEPTOR。第二次它会删除自动添加的 cookie，之后它工作正常，请使用此 httpClient 拦截器，使用下面的代码：

httpClient.addRequestInterceptor(new HttpRequestInterceptor() {

        @Override
        public void process(HttpRequest request, HttpContext context)
                throws HttpException, IOException {
            LOG.info("***************** Entered My Interceptor ****************************");
            Header[] headers = request.getAllHeaders();
            for (Header eachHeader : headers) {
                LOG.info("Headers -- Name: {}, Value: {} ",
                        eachHeader.getName(), eachHeader.getValue());
            }
            request.removeHeaders("Cookie");
        }
    });