Redis系列(四):哨兵机制详解

首发博客地址

https://blog.zysicyj.top/

前面我们说过,redis采用了读写分离的方式实现高可靠。后面我们说了,为了防止主节点压力过大,优化成了主-从-从模式

思考一个问题,主节点此时挂了怎么办

alt

这里主从模式下涉及到的几个问题:

  1. 主库真的挂了吗?
  2. 我们应当选择哪个从库作为主库?
  3. 怎样让其他从库知道新的主库信息呢?
  4. 中断的数据如何恢复?

哨兵机制就完美的解决了以上问题。

什么是哨兵机制?

Redis引入哨兵(Sentinel)机制的主要目的是为了增强其高可用性和自动故障恢复能力。在分布式系统中,特别是用作数据存储的数据库系统中,保障高可用性是至关重要的,以确保系统在面对节点故障等情况时能够继续提供服务。

以下是引入Redis哨兵机制的原因:

  1. 故障检测和自动故障切换: 哨兵允许您配置多个Redis节点,并监视它们的运行状况。如果主节点(Master)出现故障,哨兵可以自动检测到并执行故障切换,将一个可用的从节点(Slave)晋升为新的主节点,从而保证服务的可用性。

  2. 自动配置更新: 当Redis节点的拓扑结构发生变化(比如添加或移除节点)时,哨兵能够自动地通知客户端和其他Redis节点进行配置更新,从而确保整个集群的正确配置。

  3. 监控和报警: 哨兵不仅监视节点的健康状态,还可以提供有关节点运行状况的信息,例如主从复制是否正常、延迟情况等。这可以帮助管理员及时发现问题并采取措施。

  4. 无需人工干预的恢复: 哨兵允许自动故障切换,这意味着当主节点出现问题时,系统可以自动将一个从节点提升为新的主节点,而无需管理员手动介入,从而缩短恢复时间。

Redis引入哨兵机制使得在分布式环境中更容易实现高可用性和故障恢复,而无需太多手动操作。哨兵机制可以确保Redis集群在节点故障时继续提供稳定的服务,对于那些对于高可用性要求较高的应用场景非常有用。

哨兵机制的基本流程

哨兵其实就是一个运行在特殊模式下的Redis进程,其随着主从实例同时运行。

那么哨兵负责哪些活呢?主要是以下三点:

  1. 监控
  2. 选主(选择主库)
  3. 通知
哨兵机制的三项任务与目标
哨兵机制的三项任务与目标

监控

Redis哨兵的监控流程涉及多个步骤,用于实时监控Redis集群中各个节点的状态并采取必要的措施来确保集群的可用性和稳定性。

  1. 节点发现和配置: 哨兵通过配置文件指定要监控的主节点和从节点。启动哨兵后,它会连接到指定的节点,并获取有关其他节点的信息,形成一个初始的监控拓扑。

  2. 心跳检测: 哨兵会定期向监控的节点发送PING命令来检测节点是否存活。这些节点可以是主节点、从节点或其他哨兵节点。如果哨兵在一定时间内没有收到响应,它会认为节点不可用。

  3. 节点状态变更: 当哨兵连续多次无法连接到一个节点时,它会将该节点标记为主观下线。当多个哨兵都将节点标记为主观下线时,这个节点会被认为是客观下线。

  4. 故障判断和选举: 当主节点被标记为客观下线时,哨兵会执行故障判断。它会从剩余的健康主节点中选举一个作为新的主节点,并将该信息广播给其他哨兵和客户端。故障判断的逻辑考虑了多个因素,包括优先级、最近一次复制偏移量等。

  5. 自动故障切换: 如果主节点被标记为客观下线,哨兵会通知从节点晋升为新的主节点。同时,哨兵会更新其他从节点的配置,使其复制新的主节点。这确保了即使主节点发生故障,集群仍然可以继续提供服务。

  6. 监控从节点: 哨兵还会监控从节点的状态,包括从节点是否与主节点保持同步,以及从节点的复制延迟情况。如果从节点无法同步或者复制延迟过高,哨兵会将其标记为不健康。

  7. 节点恢复: 如果一个节点从客观下线状态恢复,哨兵会将其标记为健康,并将其重新纳入集群中。从节点恢复后,它会重新同步主节点的数据。

  8. 配置更新: 如果集群的拓扑发生变化,例如添加或移除节点,哨兵会自动更新配置,以便客户端能够正确连接到集群。

  9. 事件通知: 哨兵通过发布订阅机制向订阅者(通常是客户端)发送有关集群状态变化的消息。这使得应用程序能够根据实时的集群状态做出相应的决策。

  10. 持续监控: 哨兵会持续地监控集群中的节点,定期执行心跳检测、状态更新和故障判断,以确保集群的稳定运行。

主观下线与客观下线

在Redis的哨兵监控机制中,有两个关键概念:主观下线(Subjective Down)和客观下线(Objective Down)。这些概念帮助哨兵判断节点的可用性和故障状态。

  1. 主观下线(Subjective Down): 主观下线是指单个哨兵节点认为一个特定的Redis节点(主节点、从节点或其他哨兵)不可用。主观下线是一种主观的判断,是基于单个哨兵节点的观察结果得出的。当一个哨兵无法连接到某个Redis节点,它会将该节点标记为主观下线。多个哨兵节点可能会对同一个节点发出主观下线标记。

  2. 客观下线(Objective Down): 客观下线是指在整个哨兵集合中达成一致,认为某个特定的Redis节点不可用。客观下线是一种更客观的判断,需要多个哨兵节点共同达成一致。当多个哨兵节点都主观下线同一个Redis节点时,这个节点会被认为是客观下线。

举例说明:

  • 假设有三个哨兵节点:Sentinel A、Sentinel B 和 Sentinel C,以及一个主节点 Master 和一个从节点 Slave。如果 Sentinel A 无法连接到 Master 节点,它会将 Master 标记为主观下线。同样地,如果 Sentinel B 也无法连接到 Master 节点,它也会将 Master 标记为主观下线。但这还不足以让 Master 被认为是客观下线。

  • 当 Sentinel A 和 Sentinel B 都主观下线了 Master 节点,并且他们相互通信时发现了这个情况,他们就会在达成一致意见后将 Master 节点标记为客观下线。这时,整个哨兵集合达成一致,认为 Master 节点已下线。

客观下线是一个更严格的判断,需要多个哨兵节点一致认为某个节点不可用,才会触发后续的故障判断和自动故障切换等动作。这种机制确保了在一个哨兵节点认为某节点下线时,不会立即触发故障切换,以避免误判造成不必要的切换。只有多个哨兵节点一致认为节点下线,才会触发后续的故障处理流程。

客观下线的判断
客观下线的判断

如何选定新主库

在Redis Sentinel模式中,当主节点(Master)发生故障导致下线后,哨兵会通过选举过程选择一个新的主节点(Master)来取代原来的主节点。选定新主库的过程如下:

  1. 主观下线和客观下线判断: 当哨兵节点主观下线(单个哨兵认为不可用)一个主节点时,如果多数哨兵都主观下线了同一个主节点,那么这个主节点会被标记为客观下线(多数派共识)。

  2. 选举新主节点: 当一个主节点被标记为客观下线后,哨兵节点会开始选举一个新的主节点。选举过程如下:

    • 哨兵会在所有没有下线的从节点(Slaves)中选择一个作为新主节点。 哨兵会选择一个延迟最小、复制偏移量最大的从节点作为新主节点。这确保了新主节点是最接近原主节点的从节点。
    • 如果没有合适的从节点,哨兵会选择一个具备最高优先级的从节点,将其升级为主节点。如果优先级相同,那么哨兵会选择一个复制偏移量最大的从节点。
  3. 故障转移和切换: 一旦新主节点被选定,哨兵会发起故障转移操作。旧主节点会变成新主节点的一个从节点。其他从节点会重新配置,指向新的主节点。这个过程会保证尽量不丢失数据,并且保证整个集群的高可用性。

选定新主库的过程是一个由哨兵节点协同工作的流程,确保了在主节点故障的情况下,尽可能地选择一个合适的从节点作为新的主节点,实现集群的高可用性和数据完整性。

新主库的选择
新主库的选择

如何配置哨兵

  1. 哨兵配置文件: 在Redis 6.x版本中,哨兵的配置文件名称默认为redis-sentinel.conf

  2. 配置变化: Redis 6.x版本引入了一些新的哨兵配置选项,以适应新的功能和改进。以下是一些常见的配置选项:

    sentinel monitor mymaster 127.0.0.1 6379 2   # 监控名为 "mymaster" 的主节点,2表示至少需要2个哨兵同意主观下线才会执行故障转移
    sentinel down-after-milliseconds mymaster 5000   # 主观下线判定为5秒无响应
    sentinel parallel-syncs mymaster 1   # 执行故障转移时同时同步的从节点数量
    sentinel failover-timeout mymaster 10000   # 故障转移超时时间为10秒
    sentinel auth-pass mymaster mypassword   # 主节点的访问密码
    
  3. 启动哨兵节点: 在Redis 6.x版本中,启动哨兵节点的命令为:

    redis-server /path/to/redis-sentinel.conf --sentinel
  4. 查看哨兵状态: 使用以下命令查看Redis 6.x版本哨兵节点的状态:

    redis-cli -p 26379
    sentinel master mymaster   # 查看主节点的信息
    sentinel slaves mymaster   # 查看从节点的信息
    sentinel sentinels mymaster   # 查看其他哨兵节点的信息

哨兵是如何互相发现的?

我们查看配置可以看到,我们并没有配置从节点的哨兵,我们只配置了主节点地址。

那么哨兵之间是如何互相发现通信的呢?

在Redis Sentinel(哨兵)集群中,哨兵节点之间通过发布订阅机制来互相发现和通信。这种方式使得哨兵节点能够监控主节点和从节点的状态,并进行故障检测和故障转移。

以下是哨兵集群如何通过发布订阅机制互相发现的工作流程:

  1. 初始连接: 在启动时,每个哨兵节点会尝试连接到指定的主节点。这些哨兵节点通过配置文件中的sentinel monitor命令指定要监控的主节点信息。

  2. Sentinel命令发布: 当一个哨兵节点成功连接到主节点后,它会开始定期向主节点发送PING命令,以确保主节点处于活跃状态。如果哨兵节点检测到主节点不可用,它会将一个+switch-master命令发布到频道中,通知其他哨兵节点。

  3. 发布订阅机制: Redis的发布订阅机制允许一个节点(发布者)向一个或多个节点(订阅者)广播消息。在哨兵集群中,每个哨兵节点都订阅了一个名为__sentinel__:hello的频道,用于接收其他哨兵节点发送的信息。alt

  4. 发现其他哨兵节点: 当一个哨兵节点成功连接到主节点后,它会向__sentinel__:hello频道发布一个"Hello"消息,其中包含它自己的信息(如IP地址和端口号)。其他哨兵节点通过订阅这个频道,可以获取所有其他哨兵节点的信息。

  5. 收集哨兵信息: 每个哨兵节点通过订阅__sentinel__:hello频道,收集到其他哨兵节点的信息。这使得每个哨兵节点都知道了集群中其他哨兵节点的存在。

  6. 故障检测和转移: 当一个哨兵节点检测到主节点不可用时,它会通过发布+switch-master命令来通知其他哨兵节点。这个命令包含了新的主节点信息,以及在执行故障转移时需要的其他信息。其他哨兵节点收到这个命令后,会进行判断并可能发起故障转移。

通过以上机制,哨兵节点可以相互发现和通信,共同监控主节点和从节点的状态,并在主节点下线时协同执行故障转移操作。这种发布订阅机制确保了哨兵集群中节点之间的实时信息传递和协作。

alt

由哪个哨兵执行主从切换?

客观下线具体判断流程

  1. 故障检测: 哨兵节点定期向集群中的所有主节点和从节点发送PING命令来检测节点的可用性。如果一个哨兵节点连续一定次数没有收到节点的回复,就会将该节点标记为可能进入客观下线状态。

  2. Quorum判断: 在判断一个节点是否客观下线时,需要考虑Quorum的概念。Quorum是指一个最小的投票数,当达到或超过这个投票数时,哨兵认为节点可能进入客观下线状态。Quorum的值通常设置为哨兵节点数量的一半加一。

  3. 投票过程: 当哨兵节点开始怀疑某个节点可能客观下线时,它会向其他哨兵节点发送一个SENTINEL is-master-down-by-addr命令,询问其他哨兵节点是否也认为该节点客观下线。其他哨兵节点会对此做出回应,根据回应的数量来判断是否达到Quorum。

  4. 达到Quorum: 如果收到的回应数量达到或超过Quorum,那么哨兵节点就会认为该节点进入客观下线状态。这表示集群中有足够多的哨兵都认为该节点可能下线,进而触发后续的主从切换流程。

  5. 执行后续操作: 一旦一个节点被认为客观下线,哨兵节点将开始执行故障转移操作,选择新的主节点并开始同步数据。这将最终导致一个新的主节点被选出,从而实现高可用性。 alt

选举Leader流程

Redis Sentinel(哨兵)是用于监控和管理Redis主从复制以及自动故障切换的工具。当主节点失效时,哨兵会协调选择一个从节点作为新的主节点,这涉及到选举Leader的过程。详细流程如下:

  1. 监控主节点: 哨兵持续监控Redis主节点的状态,包括主节点是否在线,主从复制是否正常,以及哨兵和其他节点的通信情况。

  2. 检测主节点失效: 当哨兵检测到主节点失效(例如,无法响应PING命令),它会将主节点标记为“主观下线”。

  3. 广播主观下线状态: 一旦主观下线状态被确认,哨兵会广播该信息给其他哨兵和节点,告知主节点已经“主观下线”。

  4. 投票: 当其他哨兵收到关于主观下线状态的广播时,它们会进行投票来决定是否需要进行领导者选举。

  5. 选举Leader: 如果多个哨兵都认为主节点失效,它们将进入领导者选举过程。选举过程使用了Raft算法的变体。

  6. 提议投票: 在选举过程中,哨兵会提议自己作为领导者,然后请求其他哨兵投票支持。

  7. 投票表决: 哨兵在收到提议后会表决是否支持该提议。通常,哨兵会投票给具有最高配置版本号的提议者。

  8. Quorum判断: 在选举过程中,哨兵需要收集足够数量的投票,达到Quorum(大多数)的支持才能选举成功。

  9. 选出新领导者: 如果某个哨兵获得足够多的投票,超过了Quorum,那么它将被选为新的领导者。

  10. 通知其他节点: 新选出的Leader会向其他哨兵和节点广播其成为领导者的消息,确保集群中的所有节点都知道领导者的变更。

  11. 故障切换: 一旦新的Leader选举完成,哨兵会协调进行故障切换,将一个从节点提升为新的主节点,使整个集群继续正常运行。

  12. 恢复正常状态: 一旦故障切换完成,新的主节点将开始处理客户端请求,集群会恢复到正常运行状态。

需要注意的是,Redis Sentinel的选举Leader过程受到Paxos算法和Raft算法等分布式一致性算法的影响,以保证在主节点失效时能够选择合适的节点作为新的主节点,从而保持数据的一致性和高可用性。

alt

TIP

  1. 如果哨兵集群只有 2 个实例,此时,一个哨兵要想成为 Leader,必须获得 2 票,而不是 1 票。所以,如果有个哨兵挂掉了,那么,此时的集群是无法进行主从库切换的。因此,通常我们至少会配置 3 个哨兵实例。

  2. 要保证所有哨兵实例的配置是一致的,尤其是主观下线的判断值 down-after-milliseconds。

本文由 mdnice 多平台发布

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/47714.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

快速排序 | C++|时间空间复杂度

1.概念 快速排序(QuickSort)的基本思想是:通过一趟排序将待排记录分割成独立的两部分,其中一部分记录的关键字均比另一部分记录的关键字小,则可分别对这两部分记录继续进行排序,以达到整个序列有序的目的。 2.算法思想描述 1.进行一次划分&…

深入理解JMM和并发三大特性

并发和并行 并发和并行的目的都是为了使CPU的使用率最大化,这两个概念也是我们容易混淆的。 并行(Parallel) 并行是指在同一时刻,有多条指令在多个处理器上同时执行,因为并行要求程序能同时执行多个操作&#xff0c…

python连接PostgreSQL 数据库

执行如下命令安装 pip3 install psycopg2 python代码 Author: tkhywang 2810248865qq.com Date: 2023-08-21 11:42:17 LastEditors: tkhywang 2810248865qq.com LastEditTime: 2023-08-21 11:51:56 FilePath: \PythonProject02\PostgreSQL 数据库.py Description: 这是默认设置…

C#系统锁屏事件例子 - 开源研究系列文章

今天有个网友问了个关于操作系统锁屏的问题。 我们知道,操作系统是基于消息和事件处理的,所以我们只要找到该操作系统锁屏和解屏的那个事件,然后在事件里进行处理即可。下面是例子介绍。 1、 项目目录; 下面是项目目录&#xff1a…

jQuery Editable Select可搜索下拉选项框

前言 可搜索的下拉选项框 源码地址:https://github.com/indrimuska/jquery-editable-select 可搜索的下拉选项框 引入依赖 <script src"//code.jquery.com/jquery-1.12.4.min.js"></script> <script src"//rawgithub.com/indrimuska/jquery…

漏洞指北-VulFocus靶场专栏-初级02

漏洞指北-VulFocus靶场02-初级 初级005 &#x1f338;phpunit 远程代码执行 (CVE-2017-9841)&#x1f338;step1&#xff1a;进入漏洞页step2&#xff1a; burpsuite 抓包,等待请求页&#xff0c;获得flag 初级006 &#x1f338;splunk 信息泄露 &#xff08;CVE-2018-11409&am…

工业类LMQ61460AASRJRR,汽车类LMQ61460AFSQRJRRQ1、LMQ61460AASQRJRRQ1 6A、降压转换器简化原理图

一、LMQ61460AASRJRR器件概述&#xff1a; LMQ61460 是一款具有集成旁路电容器的高性能直流/直流同步降压转换器。该器件具有集成式高侧和低侧MOSFET&#xff0c;能够在 3.0V 至 36V 的宽输入电压范围内提供高达 6A 的输出电流&#xff1b;可耐受 42V 电压&#xff0c;简化了输…

juc概述和Lock接口

目录 一、什么是JUC 1、JUC概述 2、进程与线程 3、线程的状态 4、wait/sleep 的区别 5、并发与并行 6、管程 7、用户线程和守护线程 二、Lock接口 1、Synchronized 使用synchronized实现售票案例 使用synchronized实现增减变量操作 2、什么是 Lock 买票例子使用lo…

[ MySQL ] — 复合查询和内外连接的使用

目录 复合查询 多表查询 自连接 子查询 单行子查询 多行子查询 多列子查询 在from子句中使用子查询 合并查询 union union all 表的内连接和外连接 内连接 外连接 左外连接 右外连接 复合查询 多表查询 实际开发中往往数据来自不同的表&#xff0c;所以需要多表查…

解决运行在微信小程序中报[ app.json 文件内容错误] app.json: app.json 未找到(env: Windows,mp,1.05.2204

找到project.config.json文件夹 添加 "miniprogramRoot": "unpackage/dist/dev/mp-weixin/", 即可

Docker之Compose

目录 前言 一、Docker-compose概述 1.1Docker Swarm与Docker Compose 1.1.1Docker Swarm 1.1.2Docker Compose 1.1.2.1 三层容器 ​编辑 二、YAML 2.1YAML概述 2.2注意事项 2.3Docker Compose 环境安装 2.3.1下载 三、Docker-Compose配置常用字段 四、Docker-com…

Python学习笔记_实战篇(二)_django多条件筛选搜索

多条件搜索在很多网站上都有用到&#xff0c;比如京东&#xff0c;淘宝&#xff0c;51cto&#xff0c;等等好多购物教育网站上都有&#xff0c;当然网上也有很多开源的比楼主写的好的多了去了&#xff0c;仅供参考&#xff0c;哈哈 先来一张效果图吧&#xff0c;不然幻想不出来…

06 mysql all查询 和 主键查询 和 非索引列查询

前言 本文主要调试一下 mysql 的如下两种查询语句 我们也来深入的看一下, 究竟如下两个普通的查询, mysql 做了什么事情 1. select * from user where id 991; 2. select * from user; 3. select * from user where name jerry991; 环境介绍 测试表 user schema 如下…

机器学习之数据清洗

一、介绍 数据清洗是机器学习中的一个重要步骤&#xff0c;它涉及对原始数据进行预处理和修复&#xff0c;以使数据适用于机器学习算法的训练和分析。数据清洗的目标是处理数据中的噪声、缺失值、异常值和不一致性等问题&#xff0c;以提高数据的质量和准确性。 二、方法 处理…

【3D激光SLAM】LOAM源代码解析--scanRegistration.cpp

系列文章目录 【3D激光SLAM】LOAM源代码解析–scanRegistration.cpp 【3D激光SLAM】LOAM源代码解析–laserOdometry.cpp 【3D激光SLAM】LOAM源代码解析–laserMapping.cpp 【3D激光SLAM】LOAM源代码解析–transformMaintenance.cpp 写在前面 本系列文章将对LOAM源代码进行讲解…

2023-08-21 Unity Shader 开发入门1 —— 渲染管线

文章目录 一、概述二、应用阶段三、几何阶段四、光栅化阶段 一、概述 ​ Unity 中的渲染管线和图形学中的渲染管线基本上指的是相同的概念&#xff0c;但是具体实现和细节方面可能存在一些差异。 ​ Unity 的渲染管线建立在图形学的基础上&#xff0c;但具有自己的实现和拓展。…

ClickHouse安装及部署

文章目录 Docker快速安装Ubuntu预编译安装包安装检查是否支持SSE4.2使用预编译安装包 Tgz安装包配置文件修改修改密码配置远程访问 其他主机访问文章参考 Docker快速安装 本地pull镜像 docker run -d --name ch-server --ulimit nofile262144:262144 -p 9000:9000 -p 8123:81…

stm32的命令规则

stm32型号的说明&#xff1a;以STM32F103RBT6这个型号的芯片为例&#xff0c;该型号的组成为7个部分&#xff0c;其命名规则如下&#xff1a;

Python网络爬虫入门到实战

&#x1f482; 个人网站:【工具大全】【游戏大全】【神级源码资源网】&#x1f91f; 前端学习课程&#xff1a;&#x1f449;【28个案例趣学前端】【400个JS面试题】&#x1f485; 寻找学习交流、摸鱼划水的小伙伴&#xff0c;请点击【摸鱼学习交流群】 网络爬虫&#xff08;We…

记录一个用C#实现的windows计时执行任务的服务

记录一个用C#实现的windows计时执行任务的服务 这个服务实现的功能是每天下午六点统计一次指定路径的文件夹大小 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Diagnostics; using System.IO; using Syst…