Redis发布订阅在高可用Redis Sentinel中如何使用_处理主从切换对订阅的影响-Redis-PHP中文网

redis sentinel主从切换会导致pub/sub订阅连接硬中断，客户端须监听断连事件、通过sentinel获取新主地址、重建pubsub实例并重订阅；pub/sub不保证消息持久化，高可靠场景应改用redis stream。

redis发布订阅在高可用redis sentinel中如何使用_处理主从切换对订阅的影响

Redis Sentinel环境下订阅连接会断开，必须重连并重新订阅

Redis 发布订阅（Pub/Sub）本身不支持自动重连和订阅恢复。当 Sentinel 触发主从切换后，原订阅连接所连的节点（可能是旧主或从）会断连或拒绝新消息，PSUBSCRIBE 或 SUBSCRIBE 连接直接失效——这不是超时或延迟问题，而是 TCP 连接被对端关闭或 AUTH 失败导致的硬中断。

常见现象包括：Connection closed by server、READONLY You can't write against a read only replica（误连到只读从库）、或静默收不到消息但连接看似“活着”（实为半开连接）。

客户端必须监听连接断开事件（如 Python 的 ConnectionError、Node.js 的 error / close 事件）
重连前需通过 Sentinel 获取当前主节点地址：SENTINEL get-master-addr-by-name <master-name></master-name>
重连成功后，必须重新执行 SUBSCRIBE 或 PSUBSCRIBE，订阅关系不会继承
避免在重连间隙丢消息：Pub/Sub 本身不保证消息持久化，若需可靠性，应配合 Redis Stream 或外部队列

Python redis-py 客户端如何安全处理 Sentinel 切换后的订阅

redis-py 的 StrictRedis 和 Redis 类本身不管理 Pub/Sub 的自动恢复；其 Sentinel 类可获取主节点地址，但 PubSub 实例是独立对象，不感知 Sentinel 状态变化。

正确做法是封装一个带重试和重订阅逻辑的循环：

redis-tools

按类别查找Redis命令、检测服务器连接、监控键数量和内存占用，支持离线速查表。

下载

from redis.sentinel import Sentinel
import time
<p>sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1)
pubsub = None</p><p>def get_fresh_pubsub():
master = sentinel.master_for('mymaster', socket_timeout=0.1)
return master.pubsub()</p><p>while True:
try:
if pubsub is None:
pubsub = get_fresh_pubsub()
pubsub.subscribe('channel:log')
for msg in pubsub.listen():  # 阻塞式监听
print(msg)
except (ConnectionError, TimeoutError):
print("Pub/Sub connection lost, reconnecting...")
if pubsub:
pubsub.close()
pubsub = None
time.sleep(0.5)  # 避免密集重连
</p>