org.apache.http.conn.ConnectionPoolTimeoutException:等待连接池超时

Question

我使用多线程在java中同时扫描不同的URL。有一个bug，如果请求时间总和超过100,000。我已经结束了，该结束了。下面是servlet

的代码

private String proyGetHttp(String url) throws ParseException, IOException,
            InterruptedException {
        String content = "";
        getMethod = new HttpGet(url);
        HttpResponse response = null;
        HttpEntity httpEntity = null;
        boolean success = false;
        while (!success) {
            System.out.println("url：" + url + "，connect...");
            try {
                response = client.execute(getMethod);
                httpEntity = response.getEntity();
                StringBuffer sb = new StringBuffer();
                if (httpEntity != null) {
                    BufferedReader in = null;
                    InputStream instream = httpEntity.getContent();
                    try {
                        in = new BufferedReader(new InputStreamReader(instream));
                        String lineContent = "";
                        while(lineContent != null){
                            sb.append(lineContent);
                            lineContent = in.readLine();
                        }
                    } catch (Exception ex)
                        getMethod.abort();
                        throw ex;
                    } finally {
                        // Closing the input stream will trigger connection release
                        try { instream.close(); in.close();} catch (Exception ignore) {}
                    }
                }
                content = sb.toString();
                success = true;
                System.out.println("connect successfully...");
            } catch (Exception e) {
                e.printStackTrace();
                getMethod.abort();
                System.out.println("connect fail, please waitting...");
                Thread.sleep(sleepTime);
            }finally{
                getMethod.releaseConnection();
            }
        }
        return content;
    }

下面的代码创建默认客户端

        PoolingClientConnectionManager cm = new PoolingClientConnectionManager();
        cm.setMaxTotal(100);
        DefaultHttpClient client = null;
        client = new DefaultHttpClient(cm);
        client.getParams().setParameter("http.protocol.cookie-policy", CookiePolicy.BROWSER_COMPATIBILITY);
        client.getParams().setParameter(HttpConnectionParams.CONNECTION_TIMEOUT, 5000);

Answer 1

我有同样的问题，我找到了修复。此超时是由于连接泄漏造成的。在我的例子中，我使用httpDelete方法而不使用响应。相反，我正在检查响应的状态。

解决方法是，需要使用响应实体。为了确保适当地释放系统资源，必须关闭与实体相关联的内容流。

所以我使用EntityUtils.consumeQuietly(response.getEntity());来确保实体内容被完全使用，并且内容流(如果存在)是关闭的。