当前位置: 首页 > news >正文

CloseableHttpClient.close() 导致 Connection pool shut down 的问题

TL;DR;

  • CloseableHttpClient.close() 方法默认行为是关闭 HttpClientConnectionManager
  • 如果多个 CloseableHttpClient 共用了同一个 HttpClientConnectionManager,则第一个请求执行完,其他请求就会爆 Connection pool shut down 异常
  • 备注:httpclient 版本是 4.5.6

1. 背景

某次上线以后,观察到所有的方法调用量都变得特别多,几百倍的增长,但因为当时统一时间段上线逻辑较多,并没有及时定位到问题。

第二天继续排查时,有同事指出 httpclient 连接池 Connection pool shut down 异常增多,于是想到前一天确实使用了相关的方法,代码如下

try {@Cleanup CloseableHttpClient client = Requests.getHttpclient(15000, 15000, 15000, proxyIpInfo);HttpGet httpGet = new HttpGet(url);@Cleanup final CloseableHttpResponse execute = client.execute(httpGet);return EntityUtils.toByteArray(execute.getEntity());
} catch (IOException e) {throw new RuntimeException(e);
}

2. CloseableHttpClientclose 方法

CloseableHttpClient 示例是通过如下代码创建的,其中 CONNECTION_MANAGER 是一个全局静态的共用的 HttpClientConnectionManager 实例。

HttpClients.custom().setConnectionManager(CONNECTION_MANAGER).setDefaultRequestConfig(requestConfig).build();

让我们深入 org.apache.http.impl.client.HttpClientBuilder#build 的源码,看一下如何构建 CloseableHttpClientclose 方法的,核心代码如下,注意看其中我补充的注释

List<Closeable> closeablesCopy = closeables != null ? new ArrayList<Closeable>(closeables) : null;
// 如果 connManagerShared 属性是 false(默认值)
// 那么其 close 方法的逻辑就是关闭 ConnectionManager
if (!this.connManagerShared) {if (closeablesCopy == null) {closeablesCopy = new ArrayList<Closeable>(1);}final HttpClientConnectionManager cm = connManagerCopy;... ...closeablesCopy.add(new Closeable() {@Overridepublic void close() throws IOException {cm.shutdown();}});
}

3. bug 定位

结合上面两个代码片段,真相已经大白,当 @Cleanup CloseableHttpClient client = Requests.getHttpclient(15000, 15000, 15000, proxyIpInfo); 执行过后,@Cleanup 自动执行 clientclose 方法,这时关闭了共用的全局静态 ConnectionManager

当其他请求获取 CloseableHttpClient 对象并请求时,ConnectionManager 已经被关闭,遂报出 Connection pool shut down 异常

这一过程速度非常快,导致原来函数执行时间缩短很多。因为一次 http 请求 100ms - 数秒,而检测 ConnectionManager 关闭报错只要几 ms。这进而导致了单位时间内,所有函数的执行次数都飙升的很高。

http://www.lryc.cn/news/410791.html

相关文章:

  • centos7 docker空间不足
  • C#基于SkiaSharp实现印章管理(5)
  • 【C#】ThreadPool的使用
  • 【Python系列】Python 中`eval()`函数的正确使用及其风险分析
  • 使用Spring Boot开发应用:基于请求参数MD5的缓存键及其他缓存方式
  • typescript中interface常见3种用法
  • windows10 安装CUDA教程
  • 计算机毕业设计选题推荐-某炼油厂盲板管理系统-Java/Python项目实战
  • PSO求解函数最小值的MATLAB例程|MATLAB源代码
  • scrapy 爬取旅游景点相关数据(一)
  • 构建铁塔基站安全防护网:视频AI智能监控技术引领智慧化转型
  • Java中的分布式缓存:Ehcache与Hazelcast
  • 前端开发工程师的薪资,主要取决于哪3个方面?
  • springboot美食网站—计算机毕业设计源码11574
  • WordPress建站:如何使用ChemiCloud搭建外贸独立站
  • 在 Vim 编辑器中,如果某个单词被意外地高亮显示,使用:noh可以取消高亮显示
  • 一条命令安装mysql,php
  • 配置maven环境
  • 飞书打卡 快捷指令
  • LeYOLO,一种用于目标检测的新型可扩展且高效的CNN架构
  • docker安装phpMyAdmin
  • 举例详细学习和分析后端业务逻辑代码开发思路
  • 面试经典算法150题系列-数组/字符串操作之轮转数组
  • 苹果手机怎么录屏?一键操作,轻松掌握录屏技巧
  • [Vue3] - 3 数据响应式
  • 【话题】“八股文”在实际工作中是助力、阻力还是空谈?
  • Windows 10 安装 WSL、安装 Go 以及配置环境变量的详细教程
  • 论文阅读:基于生物神经元的模拟游戏世界感知与学习
  • 理解最先进模型的起点GPT-2 源码 配置的解释
  • C++11 可变参数模板