java大并发下Timeout waiting for connection from pool 解决方案

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java大并发下Timeout waiting for connection from pool 解决方案相关的知识,希望对你有一定的参考价值。

1.概述

今天我也遇到这个情况了。

转载:大并发下Timeout waiting for connection from pool 解决方案

但是我是FLink下遇到的,在processfuntion下open方法中初始化了客户端,但是调用的时候报错了。

这是因为HttpClient在并发量高的时候 , 可能会出现连接池不够用的情况 .

解决方案如下 :

// 总连接数 值不应该过大 默认20
pollingConnectionManager.setMaxTotal(200);
// 同路由的并发数 , 默认值2 . 限制数量实际使用DefaultMaxPerRoute并非MaxTotal。
// 设置过小无法支持大并发(ConnectionPoolTimeoutException: Timeout waiting for connection from pool)
pollingConnectionManager.setDefaultMaxPerRoute(200);

2.区别

maxConnTotal 和 maxConnPerRoute 的区别 ?

  1. maxConnTotal 是整个连接池的总数量大小 , 根据自己的业务需求进行设置
  2. maxConnPerRoute 是单个路由连接的最大数 , 可以根据自己的业务需求进行设置且 maxConnPerRoute * 路由数量 不会大于 maxConnTotal

比如maxConnTotal=200 , maxConnPerRoute=100 , 那么如果只有一个路由的话 , 那么最大连接数也就是100了;

如果有两个路由的话 , 那么它们分别最大的连接数是100 , 总数不能超过200

这里我有个疑问,我的是open方法创建的对象,应该是每个并行度是一个对象互不干扰,每个并行度我是只会调用一次获取远程信息,怎么就不够用呢?我设置的是20

// 总连接数 值不应该过大 默认20
pollingConnectionManager.setMaxTotal(20);
// 同路由的并发数 , 默认值2 . 限制数量实际使用DefaultMaxPerRoute并非MaxTotal。
// 设置过小无法支持大并发(ConnectionPoolTimeoutException: Timeout waiting for connection from pool)
pollingConnectionManager.setDefaultMaxPerRoute(20);

以上是关于java大并发下Timeout waiting for connection from pool 解决方案的主要内容,如果未能解决你的问题,请参考以下文章

PHP 使用redis防止大并发下二次写入(redis 锁)

聚集索引和取消外键,外键影响在大并发下的性能.删除外键

webDriver timeout waiting for driver...

MySQL事务锁问题-Lock wait timeout exceeded

Mysql错误: ERROR 1205: Lock wait timeout exceeded解决办法

Mysql错误: ERROR 1205: Lock wait timeout exceeded解决办法