java中用Apache HttpClient写的连接池，用的PoolingHttpClientConnectionManager方法，写一个多线程执行的实例？

迈不过友情╰ 2024-02-19 10:02 24阅读 0赞

下面是一个使用PoolingHttpClientConnectionManager的多线程执行示例：

import org.apache.http.HttpEntity;  
import org.apache.http.client.methods.CloseableHttpResponse;  
import org.apache.http.client.methods.HttpGet;  
import org.apache.http.impl.client.CloseableHttpClient;  
import org.apache.http.impl.client.HttpClients;  
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;  
import org.apache.http.util.EntityUtils;

public class HttpClientExample \{  
public static void main(String\[\] args) \{  
// 创建连接池管理器  
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();  
// 设置最大连接数  
connectionManager.setMaxTotal(10);  
// 设置每个路由的最大连接数  
connectionManager.setDefaultMaxPerRoute(5);

// 创建HttpClient对象，使用连接池管理连接  
CloseableHttpClient httpClient = HttpClients.custom()  
.setConnectionManager(connectionManager)  
.build();

try \{  
// 创建多个线程来执行请求  
Thread\[\] threads = new Thread\[5\];  
for (int i = 0; i < threads.length; i++) \{  
threads\[i\] = new Thread(new RequestTask(httpClient));  
threads\[i\].start();  
\}

// 等待所有线程执行完成  
for (Thread thread : threads) \{  
thread.join();  
\}  
\} catch (Exception e) \{  
e.printStackTrace();  
\} finally \{  
try \{  
// 关闭HttpClient连接  
httpClient.close();  
\} catch (Exception e) \{  
e.printStackTrace();  
\}  
// 关闭连接池  
connectionManager.close();  
\}  
\}

static class RequestTask implements Runnable \{  
private final CloseableHttpClient httpClient;

public RequestTask(CloseableHttpClient httpClient) \{  
this.httpClient = httpClient;  
\}

@Override  
public void run() \{  
try \{  
// 创建HttpGet请求  
HttpGet httpGet = new HttpGet("https://api.example.com");

// 发送请求并获取响应  
CloseableHttpResponse response = httpClient.execute(httpGet);

try \{  
// 获取响应实体  
HttpEntity entity = response.getEntity();  
// 处理响应内容  
if (entity != null) \{  
String responseBody = EntityUtils.toString(entity);  
System.out.println(Thread.currentThread().getName() + ": " + responseBody);  
\}  
\} finally \{  
// 关闭响应  
response.close();  
\}  
\} catch (Exception e) \{  
e.printStackTrace();  
\}  
\}  
\}  
\}  
在上述示例中，我们创建了一个PoolingHttpClientConnectionManager作为连接池管理器，并使用它来构建CloseableHttpClient对象。然后，创建了多个线程来执行请求，每个线程都共享相同的CloseableHttpClient实例。

在RequestTask类的run()方法中，我们执行了GET请求，并处理响应。每个线程都将获取连接并执行请求，然后释放连接回连接池供其他线程使用。

最后，通过等待所有线程执行完成，关闭CloseableHttpClient和连接池中的连接。

请根据你的实际需求进行适当调整，如设置合适的最大连接数、每个路由的最大连接数等。此示例仅用于说明如何在多线程环境下使用连接池执行并发请求。