java中使用HttpClient的连接池

Question

Closed. This question needs to be more focused. It is not currently accepting answers.

---

想要改进这个问题吗？通过编辑这篇文章来更新问题，使其仅关注一个问题。

2 年前已关闭。

Answer 1

我最近几天一直在研究这个问题，所以只想与您分享一些“众所周知”的知识。

首先，由于您正在处理同一台服务器，因此建议使用单个 HTTP 客户端来执行您的请求。在 PoolingHttpClientConnectionManager 的帮助下，您的客户端可用于同时执行多个请求。官方多线程请求执行的例子可以参见

其次，HTTP/1.1（以及 HTTP/1.0 的增强版本）允许 HTTP 客户端在事务完成后保持连接打开，以便可以在将来的请求中重用。这通常称为持久连接。

另外，为了重复使用客户端进行多个请求，来自服务器的响应标头通常包含一个属性调用 Keep-Alive，其中包含当前连接保持活动状态的时间。除此之外，Apache Http Client 还为您提供了一个接口ConnectionKeepAliveStrategy来自定义您自己的重用连接策略。

Answer 2

PoolingClientConnectionManager 现已弃用。从（4.3 版本）开始使用PoolingHttpClientConnectionManager。

Answer 3

[假设 Java 和 Apache 的 HttpClient]

使用 ThreadSafeClientConnManager。将单个全局实例传递给每个 HttpClient 实例的构造函数。我认为汇集 HttpClient 本身没有任何意义。

Answer 4

ThreadSafeClientConnManager 现已弃用，请使用 PoolingClientConnectionManager 相反。

Answer 5

对于 HttpClient 4x：

ThreadSafeClientConnManager ...管理客户端池
连接并且能够为来自多个执行线程的连接请求提供服务。

连接按路线汇集。对经理已经指定的路线的请求
池中有可用的持久连接将通过租用连接来提供服务
池而不是创建一个全新的连接。

http://hc.apache.org/httpcomponents-client-ga /tutorial/html/connmgmt.html

Answer 6

这是不需要身份验证的 Apache HttpClient 4.3 连接池的示例：

public class PoolOfHttpConnections{
   static String[] urisToGet = {"http://www.site1.com", "http://www.site2.com"};

    public static void main(String[] args) throws Exception {
           CloseableHttpClient httpclient = HttpClients.createDefault();
           // create a thread for each link
           GetThread[] threads = new GetThread[urisToGet.length];
           for (int i = 0; i < threads.length; i++) {
               HttpGet httpget = new HttpGet(urisToGet[i]);
               threads[i] = new GetThread(httpClient, httpget);
           }

           // start the threads
           for (int j = 0; j < threads.length; j++) {
               threads[j].start();
           }
           // join the threads
           for (int j = 0; j < threads.length; j++) {
               threads[j].join();
           }
    } //end main

    private static class GetThread extends Thread {

            private final CloseableHttpClient httpClient;
            private final HttpContext context;
            private final HttpGet httpget;

            public GetThread(CloseableHttpClient httpClient, HttpGet httpget) {
                   this.httpClient = httpClient;
                   this.context = HttpClientContext.create();
                   this.httpget = httpget;
            }

            @Override
            public void run() {
                   try {
                       CloseableHttpResponse response = httpClient.execute(httpget, context);
                       try {
                           HttpEntity entity = response.getEntity();
                           System.out.println("----------------------------------------");
                           Date date = new Date();
                           System.out.println("Beginning*******************");
                           System.out.println(date.toString());
                           System.out.println("There are "+urisToGet.length+" threads running in parallel!");
                           System.out.println(response.getStatusLine());
                           if (entity != null) {
                              System.out.println("Response content length: " + entity.getContentLength());
                           }
                           System.out.println(EntityUtils.toString(entity));
                           EntityUtils.consume(entity);
                       } finally {
                         response.close();
                         System.out.println("End*******************");
                       }
                   } catch (ClientProtocolException ex) {
                          // Handle protocol errors
                   } catch (IOException ex) {
                          // Handle I/O errors
                   }
            }
    } /*end private class*/  }//end public class PoolOfHttpConnections

Answer 7

HttpClient已经有一个连接池。所以你不需要创建它。只需使用它即可。