如何利用Redis发布订阅监测集群节点变更_监听__sentinel_

不能用 __sentinel__:hello 监听节点变更，因为它是 sentinel 内部通信频道，格式不公开、不保证稳定，仅在 sentinel 节点间广播，普通客户端订阅后收到的是不可解析的二进制或乱序字符串，缺乏语义且官方禁止依赖；应改用 +switch-master 和 +sdown 等语义化事件。

如何利用redis发布订阅监测集群节点变更_监听__sentinel__:hello频道

直接监听 __sentinel__:hello 频道无法可靠获取 Redis 集群节点变更 —— 这是 Sentinel 内部通信频道，格式不公开、不保证稳定，且仅在 Sentinel 节点间广播，普通客户端订阅后收到的是二进制或不可解析的字符串，不是结构化事件。

为什么不能用 `sentinel:hello` 监听节点变更

Sentinel 使用该频道同步自身状态（如配置纪元、leader 投票），而非向外部暴露集群拓扑变化。实测中订阅该频道会收到大量无意义的乱序消息，例如："127.0.0.1,26379,127.0.0.1,6379,0,1,1" 这类字段顺序依赖 Sentinel 版本，且缺失上下文（是新增？下线？还是心跳？）。官方文档明确将其列为内部实现细节，禁止依赖。

真正有效的节点变更监听方式：订阅 `+switch-master` 和 `+sdown`

这些是 Sentinel 明确对外发布的语义化事件频道，格式固定、可解析，且与故障转移强相关：

Redis Skill - 高性能缓存管理

Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。

下载

+switch-master：主从切换完成时触发，消息格式为 mymaster 127.0.0.1 6379 127.0.0.1 6380（旧主地址+新主地址），是判断集群主节点变更的唯一可靠信号
+sdown：某节点被标记为“主观下线”时触发，含节点类型（master/slave）、IP、端口，可用于感知节点失联
+odown：升级为“客观下线”时触发，表示多数 Sentinel 已确认该节点失效
所有事件都通过 PUBLISH 发到 __sentinel__:pubsub 频道，但客户端应使用 SUBSCRIBE 直接监听上述事件名（Sentinel 自动路由）

Jedis 订阅示例必须避开的坑

常见错误是调用 jedis.subscribe() 后未保持连接活跃，导致超时断连、事件丢失：

必须在单独线程中执行 subscribe，不能放在主线程阻塞等待
不要在 onMessage 里做耗时操作（如 DB 写入），否则会积压后续消息；建议只发通知或写本地队列
连接池中的 Jedis 实例不能复用作 Pub/Sub —— 必须用独立的、非池化的连接，否则会污染连接状态
务必捕获 JedisConnectionException 并重连，Sentinel 可能因网络抖动短暂不可达

new Thread(() -> {
    Jedis jedis = new Jedis("127.0.0.1", 26379);
    jedis.subscribe(new JedisPubSub() {
        @Override
        public void onMessage(String channel, String message) {
            if ("+switch-master".equals(channel)) {
                String[] parts = message.split("\s+");
                System.out.println("主节点已切至: " + parts[3] + ":" + parts[4]);
                // 触发下游配置刷新逻辑
            }
        }
    }, "+switch-master", "+sdown");
}).start();

Lettuce 更适合生产环境的自动重连机制

Jedis 的 Pub/Sub 是阻塞式 API，异常恢复需手动处理；Lettuce 基于 Netty，原生支持异步监听和断线自动重订阅：

用 StatefulRedisSentinelConnection 获取连接，调用 addListener() 注册回调
设置 RedisURI 的 timeout 和 retry 参数，Lettuce 会在连接失败后自动重试
事件回调在独立线程执行，不阻塞 I/O 线程
注意：Lettuce 默认不启用 autoReconnect，需显式配置 ClientOptions.builder().autoReconnect(true)