哨兵：自动故障转移

   +----------+   +----------+   +----------+
   | Sentinel1|   | Sentinel2|   | Sentinel3|     互相通信, 交换对节点的看法
   +----+-----+   +----+-----+   +----+-----+
        |  \        /  |  \        /  |
        |   监控主库+从库（PING、INFO）  |
        v              v              v
    +-------+      +-------+      +-------+
    | Master| ---> |Replica| ---> |Replica|
    +-------+      +-------+      +-------+

# sentinel.conf
port 26379
# 监控名为 mymaster 的主库, quorum=2 (2 个哨兵认为它挂了才算真挂)
sentinel monitor mymaster 192.168.1.10 6379 2
sentinel auth-pass mymaster Your_Strong_Pass123
sentinel down-after-milliseconds mymaster 5000    # 5 秒无响应视为主观下线
sentinel failover-timeout mymaster 60000
sentinel parallel-syncs mymaster 1     # 切换后同时向新主同步的从库数

redis-sentinel /etc/redis/sentinel.conf
# 或 redis-server /etc/redis/sentinel.conf --sentinel

# 哨兵管理命令
$ redis-cli -p 26379
127.0.0.1:26379> SENTINEL get-master-addr-by-name mymaster
1) "192.168.1.10"
2) "6379"
127.0.0.1:26379> SENTINEL replicas mymaster
...
127.0.0.1:26379> SENTINEL sentinels mymaster
...

Sentinel1: "你们看 master 挂了吗?"  (SENTINEL is-master-down-by-addr)
Sentinel2: "挂了+1"
Sentinel3: "挂了+1"
 
同意数 >= quorum (2)  =>  客观下线 (Objectively Down)
                          可以启动故障转移了

1. 发现 ODOWN 的哨兵把自己的"纪元(epoch)"+1, 请求其他哨兵投票给自己
2. 每个哨兵在每个纪元里只有一票, 先到先得
3. 拿到 多数派(超过半数) 且 >= quorum 票的哨兵当选
4. 平票/超时? 纪元再+1, 随机延迟后重新拉票

第 1 步: 挑选新主库。从库候选按优先级过滤与排序:
         ① 剔除: 已下线/断连时间过长的
         ② 比较 replica-priority (配置项, 越小越优先, 0 = 永不当选)
         ③ 比较复制偏移量 offset (数据最全的赢)
         ④ 比较 runid (最后的平局裁决)
 
第 2 步: 对选中的从库执行 REPLICAOF NO ONE, 使其成为主库
 
第 3 步: 对其余从库执行 REPLICAOF 新主库地址
         (parallel-syncs 控制同时切几个, 防止新主库被同步请求打垮)
 
第 4 步: 把旧主库标记为新主库的从库
         (它恢复后, 哨兵会命令它 REPLICAOF 新主库, 自动归队)

# 手动触发一次故障转移（演练/维护时用）
127.0.0.1:26379> SENTINEL failover mymaster
OK

应用启动/重连时:
  1. 连任意一个哨兵
  2. SENTINEL get-master-addr-by-name mymaster -> 得到当前主库地址
  3. 连接主库, 校验其 role 确实是 master
运行中:
  订阅哨兵的 +switch-master 事件频道, 收到即重建连接

# Python redis-py
from redis.sentinel import Sentinel
sentinel = Sentinel([('10.0.0.1', 26379), ('10.0.0.2', 26379), ('10.0.0.3', 26379)],
                    socket_timeout=0.5)
master = sentinel.master_for('mymaster', password='xxx')   # 写走主库
replica = sentinel.slave_for('mymaster', password='xxx')   # 读走从库
master.set('k', 'v')

// Java Jedis
Set<String> sentinels = Set.of("10.0.0.1:26379", "10.0.0.2:26379", "10.0.0.3:26379");
JedisSentinelPool pool = new JedisSentinelPool("mymaster", sentinels, "xxx");
try (Jedis jedis = pool.getResource()) {
    jedis.set("k", "v");    // 池自动指向当前主库, 切换后自动更新
}