Quarkus Redis Client连接数远超池上限问题排查与限流咨询

连接数过高的原因 #

• 集群模式下连接池按节点分配：Quarkus Redis Client的maxPoolSize是每个集群节点的连接上限，并非全局总连接数。如果你的Elasticache集群包含多个主分片和副本节点，每个节点都会创建对应大小的连接池，叠加后总连接数会远超你设置的6。比如10个主节点+10个副本，每个节点6个连接，总连接数就有120，分片越多数值越高。
• 连接池配置未生效：你提到配置了maxPoolSize和maxPoolWaiting，但给出的application.properties里没有这些配置项，大概率是没加正确的前缀（quarkus.redis.cache.pool.*），导致客户端使用了默认连接池参数，默认值可能远高于6。
• 副本共享模式放大连接数：配置replicas=share后，客户端会向所有副本节点发送读请求，每个副本都会占用连接池的连接，进一步推高总连接数。
• 潜在连接泄漏：虽然Reactive模式下客户端会自动管理连接，但如果代码中存在订阅未完成、异常处理不当的情况，可能导致连接无法归还到池里，长期积累后连接数飙升。

限制连接数的解决办法 #

1. 正确配置连接池参数
   在application.properties中添加针对cache客户端的连接池配置，确保参数生效：

   quarkus.redis.cache.pool.max-size=6
   quarkus.redis.cache.pool.max-waiting=24
   quarkus.redis.cache.pool.idle-timeout=5s
   quarkus.redis.cache.pool.validation-timeout=1s
   

2. 根据集群节点数调整单节点连接池大小
   因为maxPoolSize是单节点上限，要结合集群总节点数计算合理值。比如集群有20个节点（主+副本），如果想总连接数控制在120以内，就保持maxPoolSize=6；如果想压到60，就设为3。
3. 优化副本使用策略
   • 不需要从副本读的话，把quarkus.redis.cache.replicas=share改成replicas=ignore，客户端只连接主节点，直接减少一半以上的连接数。
   • 需要读副本的话，改用replicas=prefer（优先主节点，副本仅作为 fallback），减少对副本的连接占用。
4. 检查自定义RedisOptions的影响
   如果你在customize方法里没有明确设置连接池参数，可能会覆盖配置文件的设置。可以在方法里补充连接池配置（更推荐用配置文件，避免硬编码）：

   @Override
   public void customize(String clientName, RedisOptions options) {
       NetClientOptions netOptions = options.getNetClientOptions();
       netOptions.setSsl(true).setHostnameVerificationAlgorithm("HTTPS")
               .setReconnectAttempts(reconnectAttempts).setReconnectInterval(reconnectInterval).setConnectTimeout(connectTimeout)
               .setTcpKeepAlive(true).setIdleTimeout(5000).setIdleTimeoutUnit(TimeUnit.MILLISECONDS);
       // 显式设置连接池参数
       PoolConfiguration poolConfig = new PoolConfiguration()
               .setMaxSize(6)
               .setMaxWaiting(24)
               .setIdleTimeout(Duration.ofMillis(5000));
       options.setPoolConfiguration(poolConfig);
   }
   

5. 排查连接泄漏
   开启Redis客户端的DEBUG日志，监控连接的获取和归还情况：

   quarkus.log.category."io.quarkus.redis".level=DEBUG
   

   查看日志中是否有大量连接创建但未归还的记录，定位代码中可能存在的订阅未完成、异常未处理的情况。

内容的提问来源于stack exchange，提问作者Konstantin Rezchikov