blocks|key|2493431|text|假设Java和Apache的HttpClient|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2493432|使用ThreadSafeClientConnManager。将单个全局实例传递给每个HttpClient实例的构造函数。我不认为集中HttpClients本身是没有意义的。|offset|length|2493433|entityMap|0|LINK|mutability|MUTABLE|url|https://hc.apache.org/httpcomponents-client-ga/httpclient/apidocs/org/apache/http/impl/conn/tsccm/ThreadSafeClientConnManager.html^0|0|2|R|0|0^^$0|@$1|2|3|4|5|6|7|N|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|O|8|@]|9|@$D|P|E|Q|1|R]]|A|$]]|$1|F|3|-4|5|6|7|S|8|@]|9|@]|A|$]]]|G|$H|$5|I|J|K|A|$L|M]]]]

[assuming Java, and Apache's HttpClient]

Use a <a href="https://hc.apache.org/httpcomponents-client-ga/httpclient/apidocs/org/apache/http/impl/conn/tsccm/ThreadSafeClientConnManager.html" rel="nofollow noreferrer">ThreadSafeClientConnManager</a>. Pass a single global instance to the constructor of every HttpClient instance. I don't think there's any point in pooling the HttpClients themselves.

blocks|key|937206|text|对于HttpClient+4x：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|937207|ThreadSafeClientConnManager+...管理客户端连接的池()，并能够服务来自多个执行线程的连接请求。
连接在每个路由的基础上池()。对于管理器已经在池中具有持久连接的路由的请求，将通过从池租赁一个连接来服务，而不是创建一个全新的连接。|blockquote|offset|length|style|BOLD|937208|http://hc.apache.org/httpcomponents-client-ga/tutorial/html/connmgmt.html|937209|entityMap|0|LINK|mutability|MUTABLE|url^0|0|13|2|1R|D|0|0|21|0|0^^$0|@$1|2|3|4|5|6|7|R|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|S|8|@$E|T|F|U|G|H]|$E|V|F|W|G|H]]|9|@]|A|$]]|$1|I|3|J|5|6|7|X|8|@]|9|@$E|Y|F|Z|1|10]]|A|$]]|$1|K|3|-4|5|6|7|11|8|@]|9|@]|A|$]]]|L|$M|$5|N|O|P|A|$Q|J]]]]

For HttpClient 4x:
<blockquote>
ThreadSafeClientConnManager ... manages a pool of client
connections and is able to service connection requests from multiple execution threads.
Connections are pooled on a per route basis. A request for a route for which the manager already
has a persistent connection available in the pool will be serviced by leasing a connection from
the pool rather than creating a brand new connection.
</blockquote>
<a href="http://hc.apache.org/httpcomponents-client-ga/tutorial/html/connmgmt.html" rel="noreferrer">http://hc.apache.org/httpcomponents-client-ga/tutorial/html/connmgmt.html</a>

blocks|key|937214|text|现在不推荐PoolingClientConnectionManager了。从(4.3版本)使用PoolingHttpClientConnectionManager。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|937215|entityMap^0|5|U|1B|Y|0^^$0|@$1|2|3|4|5|6|7|H|8|@$9|I|A|J|B|C]|$9|K|A|L|B|C]]|D|@]|E|$]]|$1|F|3|-4|5|6|7|M|8|@]|D|@]|E|$]]]|G|$]]

<code>PoolingClientConnectionManager</code> is Deprecated now . from (4.3 version) use <code>PoolingHttpClientConnectionManager</code>.

blocks|key|2493547|text|这是一个不需要身份验证的ApacheApache4.3连接池的示例：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2493548|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%2B%2B)+{
+++++++++++++++HttpGet+httpget+=+new+HttpGet(urisToGet[i]);
+++++++++++++++threads[i]+=+new+GetThread(httpClient,+httpget);
+++++++++++}

+++++++++++//+start+the+threads
+++++++++++for+(int+j+=+0;+j+<+threads.length;+j%2B%2B)+{
+++++++++++++++threads[j].start();
+++++++++++}
+++++++++++//+join+the+threads
+++++++++++for+(int+j+=+0;+j+<+threads.length;+j%2B%2B)+{
+++++++++++++++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+"%2BurisToGet.length%2B"+threads+running+in+parallel!");
+++++++++++++++++++++++++++System.out.println(response.getStatusLine());
+++++++++++++++++++++++++++if+(entity+!=+null)+{
++++++++++++++++++++++++++++++System.out.println("Response+content+length:+"+%2B+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|code-block|syntax|javascript|2493549|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

This is an example of an Apache HttpClient 4.3 pool of connections which do not require authentication:

<pre><code>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 &lt; threads.length; i++) {
 HttpGet httpget = new HttpGet(urisToGet[i]);
 threads[i] = new GetThread(httpClient, httpget);
 }

 // start the threads
 for (int j = 0; j &lt; threads.length; j++) {
 threads[j].start();
 }
 // join the threads
 for (int j = 0; j &lt; 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
</code></pre>

blocks|key|2134418|text|HttpClient已经有了一个不需要创建的连接pool.So。就用它吧。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2134419|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|D|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|E|8|@]|9|@]|A|$]]]|C|$]]

HttpClient has already have a connection pool.So you do not need to create it. Just use it.

blocks|key|937290|text|最近几天我一直在研究这个问题，所以我只想和你分享一些“每个人都知道”的知识。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|937291|首先，在处理同一服务器时，建议使用单个HTTP客户端来执行请求。在PoolingHttpClientConnectionManager的帮助下，您的客户端可以同时执行多个请求。多线程请求执行的正式示例可以找到这里。|offset|length|style|CODE|937292|其次，HTTP/1.1+(以及HTTP+/1.0的增强版本)允许HTTP客户端在事务完成后保持连接打开，以便可以在以后的请求中重用它。这通常被称为持久连接。|BOLD|937293|另外，为了重用客户端进行多个请求，来自服务器的响应头通常包括一个属性调用Keep-Alive，该属性调用包含当前连接将保持活动的时间。此外，Apache客户端还为您提供了一个接口ConnectionKeepAliveStrategy，用于自定义您自己的重用连接策略。|937294|entityMap|0|LINK|mutability|MUTABLE|url|https://hc.apache.org/httpcomponents-client-4.5.x/current/tutorial/html/connmgmt.html#d5e405^0|0|X|Y|2W|2|0|0|21|4|0|10|A|2H|R|0^^$0|@$1|2|3|4|5|6|7|U|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|V|8|@$D|W|E|X|F|G]]|9|@$D|Y|E|Z|1|10]]|A|$]]|$1|H|3|I|5|6|7|11|8|@$D|12|E|13|F|J]]|9|@]|A|$]]|$1|K|3|L|5|6|7|14|8|@$D|15|E|16|F|G]|$D|17|E|18|F|G]]|9|@]|A|$]]|$1|M|3|-4|5|6|7|19|8|@]|9|@]|A|$]]]|N|$O|$5|P|Q|R|A|$S|T]]]]

I have spent recent days working on this so just want to share some &quot;everyone-known&quot; knowledges with you.
First, as you are dealing with the same server, it is recommended to use a single HTTP client to execute your requests. With the help of <code>PoolingHttpClientConnectionManager</code>, your client can be used to execute multiple requests concurrently. The official example of multithreaded request execution can be found <a href="https://hc.apache.org/httpcomponents-client-4.5.x/current/tutorial/html/connmgmt.html#d5e405" rel="nofollow noreferrer">here</a>.
Secondly, HTTP/1.1 (and enhanced versions of HTTP/1.0) allows HTTP clients to keep the connections open after transactions complete so that it can be reused for future requests. This is often refered as Persistent Connection.
Also for the purpose of reusing client for multiple requests, the response header from a server often include an attribute call <code>Keep-Alive</code> that contain the time current connection will be kept alive. Besides that, Apache Http Client also provides you an interface <code>ConnectionKeepAliveStrategy</code>to customize your own policy for reusing connection.

<ul>
<li>How can I create a pool of connections using HttpClient?</li>
<li>I have to make frequent connections to the same server. Is it worth creating such a pool?</li>
<li>Is it possible to keep HTTP connections live and use them for various requests, and if yes how can I do so?</li>
</ul>

Connection pooling in java using HttpClient

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

如何使用HttpClient创建连接池？我必须经常连接到同一台服务器。创造这样一个游泳池值得吗？是否有可能使HTTP连接处于活动状态，并将它们用于各种请求，如果可以，我如何做到？

问使用HttpClient在java中使用连接池
EN

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用HttpClient在java中使用连接池EN