Redis 哨兵（Sentinel）不仅负责监控和管理 Redis 主从复制集群的高可用性，还需要与客户端进行有效的交互来实现故障转移后的透明连接切换。下面详细探讨 Redis 哨兵如何与客户端进行交互，并结合代码示例加以说明。

哨兵与客户端的交互

Redis 哨兵与客户端的交互主要包括以下几个方面：

发现主节点：
- 客户端可以连接到哨兵，并通过哨兵来获取当前的主节点信息。哨兵会提供一个指向当前活跃主节点的地址。
监听主节点变化：
- 客户端可以订阅哨兵的事件，及时获知主节点的变化，从而重新连接到新的主节点。
自动重连：
- 客户端库如 Jedis、Lettuce 可以配置为自动处理从哨兵获取主节点信息，并在主节点故障转移时自动重新连接到新的主节点。

详细代码示例

以下是一个具体的代码示例，展示了如何配置和使用 Redis 哨兵与客户端进行交互。

哨兵配置 (`sentinel.conf`)

port 26379
dir /tmp# 监控主节点
sentinel monitor mymaster 127.0.0.1 6379 2# 主节点不可用时间(毫秒)
sentinel down-after-milliseconds mymaster 5000# 同步从节点的数量
sentinel parallel-syncs mymaster 1# 故障转移超时时间(毫秒)
sentinel failover-timeout mymaster 60000# 通知脚本
sentinel client-reconfig-script mymaster /path/to/notification/script.sh

启动哨兵：

redis-sentinel sentinel.conf

Java 客户端示例

使用 Jedis 库连接 Redis 哨兵集群，并进行简单的 Redis 操作。

引入 Jedis 库

在 Maven 项目中添加 Jedis 依赖：

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>4.0.1</version>
</dependency>

Java 代码示例

以下 Java 代码展示了如何使用 Jedis 库连接和操作带有 Sentinel 的 Redis 集群，并自动处理主节点故障转移。

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisSentinelPool;import java.util.HashSet;
import java.util.Set;public class RedisSentinelExample {private static final String MASTER_NAME = "mymaster";public static void main(String[] args) {// 定义 Sentinel 节点Set<String> sentinels = new HashSet<>();sentinels.add("127.0.0.1:26379");// 创建 JedisPoolConfig 对象JedisPoolConfig poolConfig = new JedisPoolConfig();poolConfig.setMaxTotal(10);poolConfig.setMaxIdle(5);poolConfig.setMinIdle(1);// 创建 JedisSentinelPool 对象try (JedisSentinelPool sentinelPool = new JedisSentinelPool(MASTER_NAME, sentinels, poolConfig);Jedis jedis = sentinelPool.getResource()) {// 执行 Redis 操作jedis.set("mykey", "myvalue");String value = jedis.get("mykey");System.out.println("mykey: " + value);// 输出连接的主节点信息System.out.println("Connected to master: " + jedis.getClient().getHost() + ":" + jedis.getClient().getPort());// 模拟主节点故障后，JedisSentinelPool 会自动连接到新的主节点// 可以手动杀死主节点进程来测试} catch (Exception e) {System.err.println("Error: " + e.getMessage());}}
}

Python 客户端示例

使用 redis-py 库连接 Redis 哨兵集群，进行简单的 Redis 操作。

引入 `redis-py` 库

在 Python 环境中安装 redis-py 库：

pip install redis

Python 代码示例

以下 Python 代码展示了如何使用 redis-py 库连接和操作带有 Sentinel 的 Redis 集群，并自动处理主节点故障转移。

import redis
from redis.sentinel import Sentineldef main():# 定义 Sentinel 节点sentinel = Sentinel([('127.0.0.1', 26379)], socket_timeout=0.1)# 获取主节点master = sentinel.master_for('mymaster', socket_timeout=0.1)slave = sentinel.slave_for('mymaster', socket_timeout=0.1)# 执行 Redis 操作master.set('mykey', 'myvalue')value = slave.get('mykey')print('mykey:', value.decode('utf-8'))# 输出连接的主节点信息print('Connected to master:', master.connection_pool.get_master_address())# 模拟主节点故障后，Sentinel 会自动连接到新的主节点# 可以手动杀死主节点进程来测试if __name__ == '__main__':main()