【Redis 开发】Redis哨兵

embedded/2024/10/19 1:25:24/

哨兵

  • 作用和原理
    • 服务状态监控
    • 选举新的master
  • 搭建哨兵集群
  • RedisTemplate的哨兵模式

作用和原理

Redis提供了哨兵机制来实现主从集群中的自动故障恢复:
在这里插入图片描述
哨兵也是一个集群

  1. 监控:会不断检查master和slave是否按预期工作
  2. 自动故障恢复:如果master故障,Sentinel会将一个slave提升为master,当故障实例恢复也以新的master为主
  3. 通知:哨兵充当Redis客户端的服务发现来源,当集群发生故障转移时,会将新信息推送给Redis客户端

服务状态监控

哨兵基于心跳机制监测服务状态,每个1秒向集群的每个实例发送ping命令:
主观下线:如果某哨兵节点发现某实例未在规定时间内响应,则认为该实例主观下线
客观下线:若超过指定数量的哨兵都认为该实例主观下线,则该实例客观下线,这个值最好超过哨兵实例数量的一半

选举新的master

当master故障,哨兵需要在salve中选择一个作为新的master,依据:

  1. 判断salve节点与master节点断开时间长短,如果超过指定值(down-after-milliseconds*10)则会排除slave节点
  2. 然后判断slave节点的slave-priority值,越小优先级越高,如果是0则永不参与选举
  3. 如果slave-priority一样,则判断slave节点的offset值,越大说明数据较新,优先级越高
  4. 最后判断slave节点的运行id大小,越小优先级越高
  • 选择完成之后如何让从节点变为主节点
  1. 哨兵给备选的slave节点发送slaveof no one命令,让该节点成为master
  2. 哨兵给所有其他的slave节点发送slaveof 192.168.75.135 7002命令,让这些slave成为新master的从节点,开始从新的master上同步数据
  3. 最后,哨兵将故障节点标记为slave,当故障节点恢复后会自动成为新的master的slave节点
    在这里插入图片描述

搭建哨兵集群

这里我们讲述在Linux下搭建三个三个哨兵

  1. /tmp下创建三个目录,mkdir s1 s2 s3
  2. 在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"  #工作目录,实例的存放位置
  1. 将该配置文件拷贝到s2,s3目录中
    echo s2 s3 | xargs -t -n 1 cp s1/sentinel.conf
  2. 修改两个目录下的配置文件将端口分别修改为27002,27003
    sed -i -e 's/27001/27002/g' -e 's/s1/s2/g' s2/sentinel.conf,其他目录相同命令
  3. 启动,打开三个窗口执行redis-sentinel s1/sentinel.conf,剩下两个也同样

RedisTemplate的哨兵模式

在Sentinel集群监管下的Redis主从集群,其节点会因为自动故障转移而发生变化,Redis的客户端必须感知这种变化,及时更新连接信息。Spring的RedisTemplate底层利用lettuce实现了节点的感知和自动切换。

  1. 引入redis的start的依赖
  2. 在配置文件中设置哨兵信息
spring:redis:sentinel:master: hhh #指定master名称nodes: #指定哨兵集群信息-192.168.75.135:27001-192.168.75.135:27002-192.168.75.135:27003
  1. 在配置类中配置Redis集群的读写分离
java">@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

http://www.ppmy.cn/embedded/24025.html

相关文章

QT信号和槽通信机制的使用技巧

文章目录 两种信号槽的连接方式信号和槽函数的关联类型如何避免信号和槽的重复连接优化信号传递链路自动关联的信号和槽函数暂时阻塞信号获取信号发送者对象QT4和QT5信号的差异QT中的信号和槽是一种用于实现对象间通信的机制。这种机制通过信号signal和槽slot的连接,实现了一种…

android 判断文件是否存在

在 Android 中,你可以使用 java.io.File 类来判断一个文件是否存在。下面是一个简单的示例代码: import java.io.File; public class FileChecker { public static boolean isFileExist(String filePath) { File file new File(fi…

Kafka 3.x.x 入门到精通(03)——Kafka基础生产消息

Kafka 3.x.x 入门到精通(03)——对标尚硅谷Kafka教程 2. Kafka基础2.1 集群部署2.2 集群启动2.3 创建主题2.4 生产消息2.4.1 生产消息的基本步骤2.4.2 生产消息的基本代码2.4.3 发送消息2.4.3.1 拦截器2.4.3.1.1 增加拦截器类2.4.3.1.2 配置拦截器 2.4.3…

头歌Java实验面向对象高级

第1关:类的继承和super关键字 package step1;class Animal{String name;public void shout(){System.out.println(this.name "发出叫声");}public Animal(String name) {this.name name;} }// ---------------------Begin------------------------ //编…

面试:类加载过程、双亲委派

一、类加载分为三个阶段 1、加载 将类的字节码载入方法区,并创建类.class 对象如果此类的父类没有加载,先加载父类加载是懒惰执行 2、链接 验证–验证类是否符合Class规范,合法性、安全性检查准备-为static变量分配空间,设置默认…

分布式事务Seata<XA模式、AT模式>解决方案思路(针对多数据源、分库分表、微服务、微服务分库分表4种场景)

seata的xa的方式解决 保证强一致性 原理说明: 1.启动seata服务器TC(控制台7091可以查看) 2.启动spring项目 初始化TM RM,实际上TM和RM注册到TC中 3.浏览器访问执行方法,TM向TC请求开启全局事务, 返回一个全…

树的重心 题解

树的重心 题目描述 给定一颗树,树中包含 n 个结点(编号 1∼n)和 n−1 条无向边。请你找到树的重心,并输出将重心删除后,剩余各个连通块中点数的最大值。 重心定义:重心是指树中的一个结点,如果…

手拉手安装Kafka2.13发送和消费消息

Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。 Kafka启动方式有Zookeeper和Kraft,两种方式只能选择其中一种启动,不能同时使用。 Kafka下载https://downloads.apache.org/kafka/3.7.0/kafka_2.…