哨兵
- 作用和原理
- 服务状态监控
- 选举新的master
- 搭建哨兵集群
- RedisTemplate的哨兵模式
作用和原理
Redis提供了哨兵机制来实现主从集群中的自动故障恢复:
哨兵也是一个集群
- 监控:会不断检查master和slave是否按预期工作
- 自动故障恢复:如果master故障,Sentinel会将一个slave提升为master,当故障实例恢复也以新的master为主
- 通知:哨兵充当Redis客户端的服务发现来源,当集群发生故障转移时,会将新信息推送给Redis客户端
服务状态监控
哨兵基于心跳机制监测服务状态,每个1秒向集群的每个实例发送ping命令:
主观下线:
如果某哨兵节点发现某实例未在规定时间内响应,则认为该实例主观下线
客观下线:
若超过指定数量的哨兵都认为该实例主观下线,则该实例客观下线,这个值最好超过哨兵实例数量的一半
选举新的master
当master故障,哨兵需要在salve中选择一个作为新的master,依据:
- 判断salve节点与master节点断开时间长短,如果超过指定值(
down-after-milliseconds*10
)则会排除slave节点 - 然后判断slave节点的slave-priority值,越小优先级越高,如果是0则永不参与选举
- 如果slave-priority一样,则判断slave节点的offset值,越大说明数据较新,优先级越高
- 最后判断slave节点的运行id大小,越小优先级越高
- 选择完成之后如何让从节点变为主节点
- 哨兵给备选的slave节点发送
slaveof no one
命令,让该节点成为master - 哨兵给所有其他的slave节点发送
slaveof 192.168.75.135 7002
命令,让这些slave成为新master的从节点,开始从新的master上同步数据 - 最后,哨兵将故障节点标记为slave,当故障节点恢复后会自动成为新的master的slave节点
搭建哨兵集群
这里我们讲述在Linux下搭建三个三个哨兵
- 在
/tmp
下创建三个目录,mkdir s1 s2 s3
- 在s1目录下创建一个sentinel.conf文件,添加内容
port 27001 #配置端口
sentinel announce-ip 192.168.150.101 # 声明自己的ip实例
sentinel monitor mymaster 192.168.150.101 7001 2 # 监控master,时间监控整个集群,2标识之前主观下线的值
sentinel down-after-milliseconds mymaster 5000 #与master连接的超时时间
sentinel failover-timeout mymaster 60000 #与故障恢复的超时时间
dir "/tmp/s1" #工作目录,实例的存放位置
- 将该配置文件拷贝到s2,s3目录中
echo s2 s3 | xargs -t -n 1 cp s1/sentinel.conf
- 修改两个目录下的配置文件将端口分别修改为
27002,27003
sed -i -e 's/27001/27002/g' -e 's/s1/s2/g' s2/sentinel.conf
,其他目录相同命令 - 启动,打开三个窗口执行
redis-sentinel s1/sentinel.conf
,剩下两个也同样
RedisTemplate的哨兵模式
在Sentinel集群监管下的Redis主从集群,其节点会因为自动故障转移而发生变化,Redis的客户端必须感知这种变化,及时更新连接信息。Spring的RedisTemplate底层利用lettuce实现了节点的感知和自动切换。
- 引入redis的start的依赖
- 在配置文件中设置哨兵信息
spring:redis:sentinel:master: hhh #指定master名称nodes: #指定哨兵集群信息-192.168.75.135:27001-192.168.75.135:27002-192.168.75.135:27003
- 在配置类中配置Redis集群的读写分离
@Bean
public LettceClientConfigurationBuilderCustomizer configurationBuilderCustomizer(){return configBuilder->configBuilder.readFrom(ReadFrom.REPLICA_PREFERRED);
}
这里的ReadFrom是配置Redis的读取操作,是一个枚举:
标识 | 意义 |
---|---|
MASTER | 从主节点读取 |
MASTER_PREFERRED | 优先从master节点读取,master不可用才读取replica |
REPLICA | 从slave(replica)节点读取 |
REPLICA_PREFERRED | 优先从slave节点读取,所有的节点都不可用才读取master |