【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式

这篇具有很好参考价值的文章主要介绍了【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

在RocketMQ 5.0以前,有两种集群部署模式,分别为主从模式(Master-Slave模式)和Dledger模式。

主从模式
主从模式中分为Master和Slave两个角色,集群中可以有多个Master节点,一个Master节点可以有多个Slave节点。Master节点负责接收生产者发送的写入请求,将消息写入CommitLog文件,Slave节点会与Master节点建立连接,从Master节点同步消息数据(有同步复制和异步复制两种方式)。
消费者可以从Master节点拉取消息,也可以从Slave节点拉取消息。
【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式
在RocketMQ 4.5版 本之前,如果Master宕机,不支持自动将Slave切换为Master,需要人工介入。

Dledger模式
为了解决主从架构下Slave不能自动切换为Master的问题,4.5版本之后提供了DLedger模式,使用Raft算法,如果Master节点出现故障,可以自动从Slave节点中选举出新的Master进行切换。

存在问题
(1)根据Raft算法的多数原则,集群至少有三个节点以上,在消息写入时,也需要大多数的Follower节点响应成功才能认为消息写入成功;
(2)Dledger模式下,进行消息写入的时候,使用的是openmessaging包中提供的接口,无法利用RocketMQ原生的存储和复制能力(比如非Dledger模式下使用暂存池方式写入);
(3)存在两套日志复制流程(主从模式下一套、Dledger模式下一套),不统一;
主从同步实现原理

Dledger模式下的日志复制

Controller模式
为了解决如上问题,RocketMQ 5.0以后推出了Controller模式,它的特点如下:
(1)在主从部署模式下就具有自动切换Master的能力,5.0之前需要使用DLedger才可以;
(2)可以利用RocketMQ原生存储复制能力,并统一RocketMQ的存储和复制能力;

RocketMQ 5.0对Broker选主相关的功能进行了抽离,放在Controller中,实现了在主从部署模式下就可以自动切换Master,Controller可以独立部署也可以嵌入在NameServer中部署。

独立部署下的Controller:
【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式

嵌入NameServer中的部署图如下:
【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式

Controller
也称为Controller控制器,一般集群中部署多个Controller,使用Raft算法选举出一个Active DLedger Controller作为主控制器,它主要用来管理一个SyncStateSet集合,
这个集合中存储的是一组跟上Master进度的Broker节点集合,如果Controller发现某个Master Broker下线时,会从集合中选出新的Master Broker并切换,Controller可以单独部署可以嵌在NameServer中部署。

SyncStateSet

SyncStateSet中维护了一个Broker副本组集合,包含当前Master Broker和它的Slave Broker,需要注意在集合内的节点都是跟上Master进度的节点,在节更变动时,由Master Broker向Controller控制器发起变更请求,更新Controller中的SyncStateSet数据,在选举Master的时候,Controller只需从这个列表中选出一个节点成为新的Master即可。

节点变更分为Shrink操作和Expand操作,需要Master Broker发起,它会通过定时任务以及在数据同步过程中判断是否需要进行Shrink或Expand。

Shrink
Shrink指的是将SyncStateSet副本集合中与Master节点差距过大的副本移除,差距的判断条件如下:

  1. 节点是否与Master Broker的连接已断,如果断开需要将该节点从SyncStateSet移除;
  2. 节点的复制进度是否过大,新增了haMaxTimeSlaveNotCatchup参数,Master Broker会通过定时任务扫描每一个Slave节点的复制信息,里面有每个节点上一次跟上Master进度的时间戳lastCaughtUpTimeMs,如果当前时间减去这个lastCaughtUpTimeMs超过了haMaxTimeSlaveNotCatchup的值,会认为该Slave节点的复制进度过后;
haMaxTimeSlaveNotCatchup:表示Slave没有跟上 Master 的最大时间间隔,若在 SyncStateSet 中的 slave 超过该时间间隔会将其从 SyncStateSet 移除。默认为 15000(15s)。

Expand
如果Master Broker发现某个Slave节点赶上了Master节点的进度,需要将其重新加入到SyncStateSet。

需要注意以上两个操作,都需要Master Broker向Controller节点发送通知,请求更新SyncStateSet中的数据。

选举Master

不管是Controller独立部署,还是嵌入到NameServer中部署,Controller都会监听每个Broker的连接,Broker会定期向Controller发送心跳包,Controller会定时扫描,如果某个Broker心跳包发送超时,会认为这个Broker已经失效,此时会判断Broker是否是Master角色,如果是Master角色就需要从该组的SyncStateSet中重新选出一个节点作为Master。

选举Master的方式比较简单,从该组的SyncStateSet中,挑选一个心跳包发送正常的Slave成为新的Master节点即可,并将结果通知到该组所有的Broker,每个Broker也会定时向Controller发送请求获取主备信息。

Broker端设计

主从架构部署模式下,需要配置brokerRole和brokerId,也就是手动分配Master和Slave,在Controller模式下,这两个参数会失效,不需要再进行配置,角色和ID由Controller来分配。

Controller模式下增加了controllerAddr参数,Broker在启动时,需要配置这个参数,设置每个controller的地址:

controllerAddr:controller的地址,多个controller中间用分号隔开。例如controllerAddr = 127.0.0.1:9877;127.0.0.1:9878;127.0.0.1:9879

Broker上线

Broker配置了每个Controller的地址,Broker启动时,会先向Controller注册,并获取角色关系和brokerId,通过角色关系可以知道自己是Master还是Slave,之后再向NameServer注册。

Broker可以通过任意一个Controller获取Active Controller节点的IP,后台也会有一个定时任务,定时更新Active Controller节点的IP。

主备关系确定

初始化时,第一个Broker在向Controller注册的时候,此时并没有该Broker组的SyncStateSet,所以Active Controller会将第一个向其发送请求共识的Broker设置为Master,之后该组的其他节点会设置为Slave,Master节点的brokerId为0,
Slave节点从1开始编号,往后递增。

由于Controller控制每个节点的角色,所以每个Broker也会定时向Controller发送请求获取主备信息,以便在角色发生变化的时候可以及时更新。

【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式

日志复制

  • MasterEpoch(Epoch):Master的任期号,与Term类似,每一任Master都会有一个对应的MasterEpoch任期号,这个任期号的值由Controller控制,单独递增;
  • StartOffset:每一任Master除了有一个任期号之外,还会取当选时对应CommitLog文件中最大的偏移量(MaxPhyOffset),作为本任期期间日志的起始偏移量,记作StartOffset;
  • EpochFile:用于存放每一任Master对应的日志起始偏移量(<MasterEpoch, StartOffset> 序列),存储在 ~/store文件夹下;

当Broker成为Master时,会进行如下操作:

  1. 获取当前CommitLog文件中最后一条消息的偏移量,也就是MaxPhyOffset的值,作为StartOffset;
  2. 将当前任期号MasterEpoch和起始偏移量StartOffset的值持久化到EpochFile文件中;
  3. 监听Slave节点的连接;

日志复制整体流程

Broker在接收Controller指令之后,会根据Controller的选举结果,转变对应的角色,分别为Master和Slave。

连接阶段
连接阶段用于Master节点与Slave节点间建立连接:

  1. Master节点开始监听连接;
  2. Slave节点请求与Master节点建立连接;

HandShake阶段
Master节点与Slave节点连接建立成功之后,进入HandShake阶段:

  1. Slave节点向Master节点发送HandShake包,里面包含一些状态信息及Slave的地址,数据格式如下:
    【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式

    • Current State:表示当前状态,当前是HandShake阶段,所以表示HandShake;
    • Flags:一些标志位;
    • SlaveAddressLength:Salve节点的地址长度;
    • SlaveAddress:Slave节点的地址,发送给Master节点后,在下个阶段Master节点会判断是否需要将Slave节点加入到SyncStateSet中;
  2. Master节点向Slave节点回复HandShake包,Slave节点收到Master节点回复的包后,会使用本地的Epoch+StartOffset与Master传输的对比,找到截断点进行日志截断,与Master的日志保持一致,Master节点回复的HandShake包数据格式如下:
    【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式

    • Current State:表示当前状态,当前是HandShake阶段;
    • Body Size:存储Body的长度;
    • Offset:表示当前Master节点的CommitLog最大偏移量;
    • Epoch:表示当前Master节点任期号;
    • Body:Master端记录的所有任期信息,是一个集合,所以总大小为EpochEntry大小 * EpochEntry条数;

日志截断

  • endOffset:下一任期的StartOffset,如果没有下一任期,那么取当前CommitLog的最大偏移量作为endOffset;

Slave中将每一任Epoch对应的<Startoffset,Endoffset>序列存储在一个TreeMap中(从大到小排序):

TreeMap<Epoch, Pair<startOffset,endOffset>> epochMap;

Slave节点会遍历所有的任期(从大到小),然后根据任期号Epoch获取Master节点对应的<startOffset,endOffset>序列进行对比,如果Slave的Epoch与Master一致,并且StartOffset相等,取两者中较小的那个endOffset作为截断位点,之后Slave节点修正自己的<epoch,startoffset>信息,然后进入Transfer阶段进行日志传输。如果未找到截断位点,会一直向后遍历直到找到。
Slave保证在截断位点位置之前的日志与Master一致,之后从截断位点位置开始从Master复制日志。

// Slave从大到小遍历所有的任期
while (iterator.hasNext()) {
    // 任期信息及对应的<startOffset,endOffset>
    Map.Entry<Epoch, Pair<startOffset,endOffset>> curEntry = iterator.next();
    // 根据Epoch任期号获取Master节点对应的<startOffset,endOffset>
    Pair<startOffset,endOffset> masterOffset=findMasterOffsetByEpoch(curEntry.getKey());
    // 如果获取不为空,并且startOffset相等
    if(masterOffset != null && 
            curEntry.getKey().getObejct1() == masterOffset.getObejct1()) {
        // 返回较小的那个endOffset
        truncateOffset = Math.min(curEntry.getKey().getObejct2(), masterOffset.getObejct2());
        break;
   }
}

Transfer阶段
在Transfer阶段,Master节点会不断向Slave发送日志包,开始进行日志复制:

  1. Master节点向Slave节点发送日志包;
  2. Slave节点收到日志包之后,会检测Epoch是否发生变化,然后更新本地的EpochFile,之后向Master节点回复ACK;
  3. Master节点处理Slave节点回复的ACK响应;

【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式

参考
RIP-44 Support DLedger Controller

RocketMQ设计思想

RocketMQ官方文档文章来源地址https://www.toymoban.com/news/detail-711604.html

到了这里,关于【RocketMQ】RocketMQ 5.0新特性(三)- Controller模式的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • RocketMQ 5.0 无状态实时性消费详解

    作者:绍舒 RocketMQ 5.0 版本引入了 Proxy 模块、无状态 pop 消费机制和 gRPC 协议等创新功能,同时还推出了一种全新的客户端类型:SimpleConsumer。 SimpleConsumer 客户端采用了无状态的 pop 机制,彻底解决了在客户端发布消息、上下线时可能出现的负载均衡问题。然而,这种新机制也

    2024年02月15日
    浏览(39)
  • Spring 5.0新特性

    Spring 5.x 新特性 1. JDK8 的增强 2. 核心容器的改进 3. 新的 SpringWebFlux 模块 4. 测试方面的改进 Spring FrameWork 5.0 新的功能 JDK 8+ 和 Java EE7+ 以上版本 整个框架的代码基于 java8 通过使用泛型等特性提高可读性 对 java8 提高直接的代码支撑 运行时兼容 JDK9 Java EE 7API 需要 Spring 相关的模

    2024年02月07日
    浏览(31)
  • RocketMQ 5.0 架构解析:如何基于云原生架构支撑多元化场景

    作者:隆基 本文将从技术角度了解 RocketMQ 的云原生架构,了解 RocketMQ 如何基于一套统一的架构支撑多元化的场景。 文章主要包含三部分内容。首先介绍 RocketMQ 5.0 的核心概念和架构概览;然后从集群角度出发,从宏观视角学习 RocketMQ 的管控链路、数据链路、客户端和服务端

    2024年02月12日
    浏览(37)
  • 【RocketMQ】RocketMQ5.0新特性(一)- Proxy

    为了向云原生演进,提高资源利用和弹性能力,RocketMQ在5.0进行了架构的调整与升级,先来看新特性之一,增加了Proxy层。 计算存储分离 计算存储分离是一种分层架构,将计算层与存储层分开。 计算层指的是一些消耗计算资源的功能模块比如协议解析、消费管理等,存储指的

    2024年02月08日
    浏览(35)
  • RocketMQ教程-(5)-功能特性-顺序消息

    顺序消息为 Apache RocketMQ 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,上游的事件变更需要按照顺序传递到下游进行处

    2024年02月15日
    浏览(36)
  • RocketMQ教程-(5)-功能特性-事务消息

    事务消息为 Apache RocketMQ 中的高级特性消息,本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。 事务消息为 Apache RocketMQ 中的高级特性消息,本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。 以电商交易场景为例

    2024年02月15日
    浏览(45)
  • RocketMQ教程-(5)-功能特性-消费者分类

    Apache RocketMQ 支持 PushConsumer 、 SimpleConsumer 以及 PullConsumer 这三种类型的消费者,本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这三种类型的消费者。 Apache RocketMQ 面向不同的业务场景提供了不同消费者类型,每种消费者类型的集成方式和控制方式都

    2024年02月16日
    浏览(44)
  • RocketMQ与Kafka深度对比:特性与适用场景解析

    在分布式系统中,消息队列作为解耦、缓冲和异步通信的关键组件,其选择对于系统的性能和稳定性至关重要。RocketMQ和Kafka作为两款流行的开源消息中间件,各自拥有独特的设计理念和功能特性。本文将详细对比RocketMQ与Kafka在数据可靠性、实时性、队列数与性能、消息顺序

    2024年02月21日
    浏览(32)
  • 瞬态电压抑制器(TVS)汽车级 SZESD9B5.0ST5G 工作原理、特性参数、封装形式

    什么是汽车级TVS二极管? TVS二极管是一种用于保护电子电路的电子元件。它主要用于电路中的过电压保护,防止电压过高而损坏其他部件。TVS二极管通常被称为“汽车级”是因为它们能够满足汽车电子系统的特殊要求。 在汽车电子系统中,由于车辆启动、熄火、发动机工作

    2024年02月11日
    浏览(34)
  • MQ公共特性介绍 (ActiveMQ, RabbitMQ, RocketMQ, Kafka对比)

    本文主要介绍所有MQ框架都具备的公共特点,同时对比了一些目前比较主流MQ框架的优缺点,给大家做技术选型作参考。 MQ,MessageQueue,消息中间件 从世界上第一个MQ的诞生历程来看,它最初是为了解决通信的问题。 消息队列,又叫做消息中间件。是指用高效可靠的消息传递

    2024年02月15日
    浏览(46)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包