一聚教程网:一个值得你收藏的教程网站

最新下载

热门教程

Redis发布订阅模式处理长连接有哪些实用技巧?

时间:2026-08-16 10:24:48 编辑:袖梨 来源:一聚教程网

Redis服务端必须配置tcp-keepalive=60和timeout=600,以防止Pub/Sub空闲连接被静默关闭;客户端需按Lettuce、Redisson或Jedis差异启用心跳,同时校验DNS与节点状态。

Redis服务端必须配tcp-keepalive和timeout

默认配置下,Redis 会静默关闭空闲连接——timeout 默认是 300 秒(5 分钟),而 Pub/Sub 连接几乎不发命令,纯等消息,必然被踢。光靠客户端重连救不了命。

必须在 redis.conf 中显式设置:

  1. tcp-keepalive 60:启用内核 TCP 心跳,每 60 秒发一次 ACK 探测,能快速发现 NAT、云 LB 或防火墙中途断连
  2. timeout 600:把服务端空闲断连阈值拉到 10 分钟,给客户端留出心跳探测与重连窗口

这两项必须写入配置文件并执行 CONFIG REWRITE 或重启生效,否则重启即丢。注意:tcp-keepalive 0 表示禁用,不能省略。

Lettuce/Redisson/Jedis 的心跳配置差异很大

客户端设了 autoReconnect=true 不等于连接不会僵死。不同客户端的心跳机制完全不同,且多数不默认开启:

  1. Lettuce(Spring Boot 默认):spring.redis.lettuce.keep-alive=true 仅控制普通命令连接;StatefulRedisPubSubConnection 需手动监听 onException 后调 connection.ping()
  2. Redisson:必须显式设 setHeartbeatInterval(15000)(15 秒),同时确保 setSubscriptionConnectionPoolSize(20),避免单连接排队阻塞订阅线程
  3. Jedis:没有内置心跳,得在订阅线程里自己起定时器,定期调 jedis.ping(),且必须复用当前 PubSub 所绑定的那个 Jedis 实例,不能从连接池随便取一个

DNS 缓存和 VIP 漂移会导致“假连接”

客户端连的是域名(如 redis-prod.cluster.example.com),DNS 缓存过久或云 Redis VIP 漂移后,旧连接可能还连着已下线节点——PING 成功但 PUBLISH 失败,错误表现为 READONLY You can't write against a read only replica 或无响应。

应对方式:

  1. JVM 启动加 -Dsun.net.inetaddr.ttl=60,强制 DNS 缓存 60 秒刷新
  2. Redisson 用户检查 dnsMonitoringInterval,建议保持默认 5000ms 或调至 3000ms
  3. 所有客户端应定期执行 INFO replicationCLUSTER NODES,校验当前连接是否仍指向有效 master 节点

别把 Pub/Sub 当成可靠消息队列用

Redis 的 Pub/Sub 是纯内存转发,不持久化、不确认、不重试。订阅者掉线期间的消息直接丢弃,上线后收不到任何补偿。

如果业务需要消息不丢,要么:

  1. 改用 Stream + XREADGROUP,支持消费者组、ACK 和消息重播
  2. 在应用层兜底:发布前先写 DB 或 LIST,再发 PUBLISH 通知;订阅端收到通知后主动拉取最新状态

真正稳定的 Pub/Sub 不是靠“不断重连”,而是让连接在空闲时持续被探测、被确认、被刷新。任何一个环节缺位,都会在高并发或云网络环境下暴露为偶发性收不到消息。

热门栏目