Java【代码 17】httpclient PoolingHttpClientConnectionManager 连接池使用举例

httpclient 连接池使用举例

• 1. 问题
• • 1.1 TIME_WAIT 状态连接的原因和解决策略
  • 1.2 CLOSE_WAIT 状态连接的原因和解决策略
  • 1.3 诊断工具
• 2. 依赖
• 3. 代码
• • 3.1 线程池配置
  • 3.2 方法调用
• 4. 说明

1. 问题

服务器上有大量的time_wait或者close_wait状态的连接，故查询了 GPT。

1.1 TIME_WAIT 状态连接的原因和解决策略

# 减少TIME_WAIT状态的持续时间
sysctl -w net.ipv4.tcp_fin_timeout=30

1.2 CLOSE_WAIT 状态连接的原因和解决策略

1.3 诊断工具

• netstat命令：使用netstat -an | grep TIME_WAIT或netstat -an | grep CLOSE_WAIT来查看当前处于TIME_WAIT或CLOSE_WAIT状态的连接。
• ss命令：使用ss -t -a | grep TIME_WAIT或ss -t -a | grep CLOSE_WAIT来获取更详细的连接信息。

不得不说，大模型的回答还会很全面的。

2. 依赖

SpringBoot 项目依赖：

<!– https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient –>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.13</version>
</dependency>

非 SpringBoot 项目需要引入：

• httpclient-4.5.13.jar
• httpcore-4.4.13.jar

3. 代码

3.1 线程池配置

import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;

/**
* HttpClientManager管理
*/
public class HttpClientManager {

private static HttpClientBuilder httpClientBuilder = null;
private static CloseableHttpClient closeableHttpClient = null;

private HttpClientManager() {
// 创建连接管理器
PoolingHttpClientConnectionManager connMgr = new PoolingHttpClientConnectionManager();
// 整个连接池的最大连接数
connMgr.setMaxTotal(50);
// 每个路由的最大连接数
connMgr.setDefaultMaxPerRoute(50);
// 创建HttpClientBuilder并设置连接管理器
httpClientBuilder = HttpClients.custom().setConnectionManager(connMgr);
}

public static synchronized CloseableHttpClient getCloseableHttpClient() {
if (closeableHttpClient == null) {
new HttpClientManager();
closeableHttpClient = httpClientBuilder.build();
}
return closeableHttpClient;
}

}

在HTTP客户端中，“路由”是指客户端与服务器之间的一条逻辑路径。通常情况下，当客户端发送请求到不同的端点（即使是同一个服务器的不同URL），只要目标服务器相同，这些请求都会经过相同的网络路径，因此会被视为同一个路由。

3.2 方法调用

public JSONObject postHttpReq(String json, String url) {
// 获取http客户端
CloseableHttpClient httpClient = HttpClientManager.getCloseableHttpClient();
// 设置超时时间
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(5000).setSocketTimeout(20000).setConnectionRequestTimeout(5000).build();
// 封装请求参数
byte[] b = json.getBytes();
HttpEntity httpEntity = new ByteArrayEntity(b);
String responseMsg = "";
int statusCode = 0;
CloseableHttpResponse response = null;
try {
// 创建httpPost请求
HttpPost httpPost = new HttpPost(url);
httpPost.setConfig(requestConfig);
httpPost.setEntity(httpEntity);
httpPost.setHeader("Content-Type", "application/json;charset=GBK");
// 执行请求
response = httpClient.execute(httpPost);
// 获取请求结果
statusCode = response.getStatusLine().getStatusCode();
responseMsg = EntityUtils.toString(response.getEntity());
} catch (IOException e1) {
e1.printStackTrace();
} finally {
try {
// 关闭当前请求
response.close();
} catch (IOException e2) {
e2.printStackTrace();
}
}
// 解析请求结果
if (statusCode != 200) {
// 输出错误信息
} else {
return new JSONObject(responseMsg);
}
}

4. 说明

• 代码并不完善，没有关闭httpclient的方法和关闭连接池的方法。