Redis PubSub连接异常求助：订阅客户端频繁断开

结合你的错误栈和配置信息，我来拆解下这个连接重置问题的核心原因和解决步骤：

核心原因分析 #

错误栈的根因是 java.net.SocketException: Connection reset，虽然你已经把客户端和服务端的超时都设为0，但Pub/Sub场景下还有几个容易忽略的触发点：

1. 客户端消费速度跟不上消息生产速度：Redis会给Pub/Sub客户端维护输出缓冲区，当缓冲区达到硬限制时，即使超时设为0，Redis也会强制断开连接。
2. TCP层面的空闲连接被网络设备断开：防火墙、负载均衡等中间件可能会主动断开长时间无数据传输的连接，和Redis的超时配置无关。
3. 订阅连接未正确利用TCP KeepAlive：你的客户端配置没开启TCP KeepAlive，无法主动维持长连接。

具体排查与解决步骤 #

1. 优先排查消费速度问题 #

这是Pub/Sub连接断开最常见的原因：

• 用Redis命令 CLIENT LIST 查看你的订阅客户端，重点关注 omem 字段（输出缓冲区内存占用），如果这个值持续增长接近256MB（你配置的pubsub硬限制），说明消费速度跟不上。
• 解决方案：
  • 优化消息监听器的处理逻辑：把耗时操作（比如DB写入、远程调用）丢到独立线程池异步处理，不要在订阅线程里阻塞。
  • 拆分订阅频道：把高流量的频道拆分成多个，分散单客户端的消息负载。

2. 调整服务端输出缓冲区配置（谨慎操作） #

如果确认是缓冲区容量不足，且暂时无法优化消费速度，可以适当调大Pub/Sub的缓冲区限制：

# 临时生效，调整pubsub硬限制到512MB，软限制到256MB
CONFIG SET client-output-buffer-limit "normal 0 0 0 slave 268435456 67108864 60 pubsub 536870912 268435456 0"
# 持久化到配置文件，避免重启失效
CONFIG SAVE

⚠️ 注意：要确保服务器有足够的内存，避免因缓冲区过大导致Redis OOM。

3. 优化客户端订阅连接配置 #

订阅连接是独占长连接，不走连接池，你的连接池配置对它无效，需要针对性调整：

GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMaxTotal(10);
poolConfig.setMaxIdle(5);
poolConfig.setBlockWhenExhausted(true);
poolConfig.setMinIdle(2);
poolConfig.setTestOnBorrow(true);

JedisConnectionFactory factory = new JedisConnectionFactory();
factory.setHostName(HOST);
factory.setPort(PORT);
factory.setDatabase(Protocol.DEFAULT_DATABASE);
factory.setPoolConfig(poolConfig);
// 订阅连接不走连接池，必须设置为false
factory.setUsePool(false);

JedisShardInfo shardInfo = new JedisShardInfo(factory.getHostName(), factory.getPort(), 0);
// 开启TCP KeepAlive，防止网络设备断开空闲连接
shardInfo.setTcpKeepAlive(true);
// 可选：设置Java层面的KeepAlive间隔（60秒）
System.setProperty("tcp.keepalive.interval", "60000");

factory.setShardInfo(shardInfo);

// 配置订阅容器的自动重试机制
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(factory);
// 断开后5秒重试订阅，避免频繁重试
container.setRecoveryInterval(5000);
// 添加你的消息监听器...

4. 排查网络层面的空闲超时 #

检查客户端与Redis之间的防火墙、负载均衡设备，看是否有空闲连接超时配置（比如10分钟），如果有：

• 在Redis配置文件中设置 tcp-keepalive 60（每60秒发送一次KeepAlive包），确保KeepAlive间隔小于设备的超时时间。
• 重启Redis使配置生效。

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