突破Java面试(23-9) - 深入解析Redis哨兵底层原理

简介: ​# 0 Github1 sdown和odown转换机制两种失败状态1.1 概念sdown主观宕机一个哨兵自己觉得一个master宕机odown客观宕机quorum数量的哨兵都觉得一个master宕机1.

​# 0 Github

1 sdown和odown转换机制

两种失败状态

1.1 概念

  • sdown主观宕机
    一个哨兵自己觉得一个master宕机
  • odown客观宕机
    quorum数量的哨兵都觉得一个master宕机

1.2 达成条件

  • sdown
    一个哨兵ping一个master,超过is-master-down-after-milliseconds
  • odown
    一个哨兵在指定时间内,收到了quorum指定数量的其他哨兵也认为那个master是sdown了,那么就认为是odown

2 自动发现机制

通过Redis的pub/sub实现哨兵互相之间的发现,每个哨兵都会往__sentinel__:hello这个channel发一个消息,此时所有其他哨兵都可消费到该消息,于是感知到其他哨兵的存在.

每隔2s,哨兵都会往自己监控的某个master+slaves对应的__sentinel__:hello channel里发一个消息,内容为自己的host、ip和runid还有对该master的监控配置

每个哨兵也会去监听自己监控的每个master+slaves对应的__sentinel__:hello channel,然后去感知到同样在监听这个master+slaves的其他哨兵的存在

每个哨兵还会跟其他哨兵交换对master的监控配置,互相进行监控配置的同步

3 slave配置的自动纠正

哨兵会负责自动纠正slave的一些配置,比如

  • slave要成为潜在的master候选人,哨兵会确保slave复制现有master的数据
  • slave连接到了一个错误的master上,比如故障转移之后,那么哨兵会确保它们连接至正确的master

4 slave => master选举算法

若一个master被认为odown了,而且majority数量的哨兵都允许了主备切换,那么某个哨兵就会执行主备切换操作,此时首先要选举一个slave,会考虑slave的一些信息

  • 跟master断开连接的时长
  • slave优先级
  • 复制offset
  • run id

若一个slave跟master断开连接的时间已经超过down-after-milliseconds的10倍,外加master的宕机时长,那么slave就会被认为不适合选举为master

(down-after-milliseconds * 10) + milliseconds_since_master_is_in_SDOWN_state

接下来会对slave进行排序

  1. 按照slave优先级进行排序,slave priority越低,优先级就越高
  2. 如果slave priority相同,那么看replica offset,哪个slave复制了越多的数据,offset越靠后,优先级就越高
  3. 如果上面两个条件都相同,那么选择一个run id比较小的那个slave

5 quorum和majority

每次一个哨兵要做主备切换,首先需要quorum数量的哨兵认为odown,然后选举出一个哨兵来做切换
该哨兵还得得到majority个哨兵的授权,才能正式执行切换

  • 若quorum < majority
    比如5个哨兵,majority就是3,quorum设置为2,那么就3个哨兵授权就可以执行切换
  • 若quorum >= majority
    那么必须quorum数量的哨兵都授权,比如5个哨兵,quorum是5,那么必须5个哨兵都同意授权,才能执行切换

6 configuration epoch

哨兵会监控一套Redis master+slave,并有相应的监控配置

执行切换的哨兵,会从要切换到的新master(salve => master)那里得到一个configuration epoch,这就是一个version号,每次切换的version号都必须是唯一的

如果第一个选举出的哨兵切换失败,那么其他哨兵,会等待failover-timeout时间,然后接替继续执行切换,此时会重新获取一个新的configuration epoch,作为新的version号

7 configuraiton传播

哨兵完成切换之后,会在自己本地更新生成最新的master配置,然后同步给其他哨兵

这里是通过pub/sub机制传递的

到了这里,之前提到的version号就很重要了,因为各种消息都是通过一个channel去发布和监听的,所以一个哨兵完成一次新的切换之后,新的master配置是跟着新的version号的

其他的哨兵也都是根据版本号的大小来更新自己的master配置的

参考

《Java工程师面试突击第1季-中华石杉老师》

目录
相关文章
|
8月前
|
存储 缓存 NoSQL
Redis常见面试题全解析
Redis面试高频考点全解析:从过期删除、内存淘汰策略,到缓存雪崩、击穿、穿透及BigKey问题,深入原理与实战解决方案,助你轻松应对技术挑战,提升系统性能与稳定性。(238字)
|
9月前
|
算法 Java
50道java集合面试题
50道 java 集合面试题
|
9月前
|
算法 Java
50道java基础面试题
50道java基础面试题
|
存储 Java
【IO面试题 四】、介绍一下Java的序列化与反序列化
Java的序列化与反序列化允许对象通过实现Serializable接口转换成字节序列并存储或传输,之后可以通过ObjectInputStream和ObjectOutputStream的方法将这些字节序列恢复成对象。
|
存储 算法 Java
大厂面试高频:什么是自旋锁?Java 实现自旋锁的原理?
本文详解自旋锁的概念、优缺点、使用场景及Java实现。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
大厂面试高频:什么是自旋锁?Java 实现自旋锁的原理?
|
存储 缓存 算法
面试官:单核 CPU 支持 Java 多线程吗?为什么?被问懵了!
本文介绍了多线程环境下的几个关键概念,包括时间片、超线程、上下文切换及其影响因素,以及线程调度的两种方式——抢占式调度和协同式调度。文章还讨论了减少上下文切换次数以提高多线程程序效率的方法,如无锁并发编程、使用CAS算法等,并提出了合理的线程数量配置策略,以平衡CPU利用率和线程切换开销。
面试官:单核 CPU 支持 Java 多线程吗?为什么?被问懵了!
|
存储 缓存 Java
大厂面试必看!Java基本数据类型和包装类的那些坑
本文介绍了Java中的基本数据类型和包装类,包括整数类型、浮点数类型、字符类型和布尔类型。详细讲解了每种类型的特性和应用场景,并探讨了包装类的引入原因、装箱与拆箱机制以及缓存机制。最后总结了面试中常见的相关考点,帮助读者更好地理解和应对面试中的问题。
436 4
|
算法 Java 数据中心
探讨面试常见问题雪花算法、时钟回拨问题,java中优雅的实现方式
【10月更文挑战第2天】在大数据量系统中,分布式ID生成是一个关键问题。为了保证在分布式环境下生成的ID唯一、有序且高效,业界提出了多种解决方案,其中雪花算法(Snowflake Algorithm)是一种广泛应用的分布式ID生成算法。本文将详细介绍雪花算法的原理、实现及其处理时钟回拨问题的方法,并提供Java代码示例。
2604 2
|
XML 存储 JSON
【IO面试题 六】、 除了Java自带的序列化之外,你还了解哪些序列化工具?
除了Java自带的序列化,常见的序列化工具还包括JSON(如jackson、gson、fastjson)、Protobuf、Thrift和Avro,各具特点,适用于不同的应用场景和性能需求。