rocketMq - master/slave同步

简介: 本章主要需要讲清楚两个概念,第一个是slave主动和master同步,第二个是master主动和slave同步。而且我保证这是唯一一篇能够把这两个过程讲清楚的文章,至少在这篇文章之前我找了很多文章,没有一篇文章将整个过程合起来讲解清楚的,说明还是花了时间在里面的。

本章主要需要讲清楚两个概念,第一个是slave主动和master同步,第二个是master主动和slave同步。而且我保证这是唯一一篇能够把这两个过程讲清楚的文章,至少在这篇文章之前我找了很多文章,没有一篇文章将整个过程合起来讲解清楚的,说明还是花了时间在里面的。

slave->master同步:主要是指slave会定期向master发起同步数据请求,master向slave返回数据。

master->slave同步:在设置为同步双写的时候,master每写入一条消息都会同步到slave当中。


master/slave同步报文格式

img_d63ca1a865de3b1f5a1a2f6433b3de7a.png
报文格式

说明

    1、slave上报进度的时候只要一个位置就够了

    2、master同步slave的时候需要传递物理位移,数据长度以及数据。


slave上报进度并同步数据

img_c6052cfa825520401457b7a4d5a42921.png
slave同步master

说明:共享自互联网

1、作为slave角色的broker启动的时候会读取本地mappedFile文件获取消息最大偏移量

2、作为master的角色在收到broker上报的消息偏移量开始基于这个位置循环向slave发送消息

3、作为slave角色的broker在收到master发来的消息开始写mappedFile并同时上报偏移量

4、补充说明一下步骤2的过程中master只参考slave第一次上报的位移作为起始偏移发送消息,在这之后master向slave发送数据是自循环的

--------------------------slave->master过程---------------------------

slave->master的master端代码

img_96bad31a0dceef9b2f13a15074714b17.png
slave同步master核心类

说明:

1、HAConnection主要用于slave向master同步数据时候master端的处理逻辑。

2、ReadSocketService负责读取slave上报的数据并更新同步进度。

3、WriteSocketService负责源源不断的往slave发送数据。


slave->master的master同步进度

img_c0b29d9e37a8ea21e6fd11c22163c7f6.png
ReadSocketService核心代码

说明

    1、ReadSocketService负责读取slave上报进度,并在第一次作为起始位移开始同步数据

    2、非第一次读取slave上报的进度的时候,通知其他等待进程消息已经同步到slave当中,这里所谓的其他线程是指配置了master/slave同步写的进程,那些进程写完master后等待slave同步完数据并上报进度后才会被唤醒。

    3、重点来了,好好理解步骤2中这句话的意思。


slave->master的master同步数据

img_f23328dd48a8c98b8f3810ac2896d1d7.png
master同步数据给slave

说明:

    1、master第一次以slave上报的偏移量作为起始偏移量,注意强调了第一次采用上报偏移量

    2、master有了起始偏移量后就自行源源不断的同步数据给slave

    3、组装报文并发送给slave节点


slave->master的slave端处理逻辑

img_771a4916955d0001c3e1716d4bb782c1.png
slave上报master并解析返回结果

说明:参见HAService。

    1、slave定期上报进度

    2、处理master同步过来的数据并保存

    3、如果同步数据成功后立即向master汇报最新的位移



img_c3e94008b91cd9738e178d5d9f0afe97.png
slave实际保存数据

说明:

    1、这部分的处理逻辑实际上是slave处理逻辑的进一步深入也就是保存消息数据的地方

    2、保存完以后立即调用reportSlaveMaxOffsetPlus上报数据

    3、reallocateByteBuffer函数内部的实现非常巧妙,解决了buffer不够的问题


--------------------------master->slave过程---------------------------

这个过程需要理解一个过程,一个比较绕的过程

1、master写完数据数据后生成master->slave同步请求并wakeup同步线程立即执行

2、master同步等待master->slave同步完成,同步过程是一个链路

3、master->slave同步请求发出去过,master处于等待状态,slave同步完master以后会回传进度,监控进程会不停的检查回传进度,检测回传的进度大于刚发送出去的master->slave的进度的时候认为同步写完成,然后就返回。


master_sync模式下的写

img_5906507974f151d3f5b53513ad6081f2.png
master写完数据同步slave

说明:参见CommitLog类的putMessage方法

    1、appendMessage数据写到commitLog

    2、handleHA内部判断如果是master_sync且为master节点才开始同步消息


img_bcda25ecc8d5dfdcb86ba82a141a5892.png
生成master->slave同步请求并通知同步线程工作

说明:

    1、创建master->slave同步请求并投递,wakeupAll同步线程立即同步数据

    2、等待同步数据的进度,flushOK表示已经同步完成

    3、这里要看清楚,putRequest是调用的this.groupTransferService.putRequest。



img_09d661ce4ec1db54d2294ee8beb1b3ce.png
检查是否同步完成的代码逻辑

说明:

    1、这个图说明了检查同步完成的整个过程,通过检查返回的位移大于发送消息的位移来保证同步完成。

    2、req.wakeupCustomer其实就是用来告知一个开始投递的req数据同步已完成,对照上面两个图就可以看懂了,一定对比上面两张图。

    3、那么问题来了,这个的push2SlaveMaxOffset是什么时候更新的呢?



img_d4e0ab50431fe49f42276b61f3443b69.png
master同步了slave的进度
img_00c15a5fcd871411065d6acb5f986a69.png
通知同步进度

说明:

    1、也就是说真正触发整个过程是有AcceptSocketService服务引起的,AcceptSocketService服务接收上报进度并通知notify机制通知原本在等待同步完成的线程。



img_6076762f98657b7e270f3288200f91a7.png
交互过程

说明:

    1、master->slave同步的过程整体过程如上图,需要自己稍微消化一下。

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
5月前
|
消息中间件 网络安全 RocketMQ
消息队列 MQ产品使用合集之配置controller时,出现无法选举master,该怎么解决
阿里云消息队列MQ(Message Queue)是一种高可用、高性能的消息中间件服务,它允许您在分布式应用的不同组件之间异步传递消息,从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
|
25天前
|
消息中间件 监控 Java
RocketMQ 同步发送、异步发送和单向发送,如何选择?
本文详细分析了 RocketMQ 中同步发送、异步发送和单向发送三种消息发送方式的原理、优缺点及适用场景。同步发送可靠性高但延迟较大,适合订单系统等场景;异步发送非阻塞且延迟低,适用于实时数据处理等场景;单向发送高效但可靠性低,适用于日志收集等场景。文章还提供了示例代码和核心源码分析,帮助读者更好地理解每种发送方式的特点。
127 4
|
14天前
|
存储 消息中间件 安全
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
【10月更文挑战第9天】本文介绍了如何利用JUC组件实现Java服务与硬件通过MQTT的同步通信(RRPC)。通过模拟MQTT通信流程,使用`LinkedBlockingQueue`作为消息队列,详细讲解了消息发送、接收及响应的同步处理机制,包括任务超时处理和内存泄漏的预防措施。文中还提供了具体的类设计和方法实现,帮助理解同步通信的内部工作原理。
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
|
4月前
|
消息中间件 开发工具 RocketMQ
消息队列 MQ使用问题之一直连接master失败,是什么原因
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
4月前
|
消息中间件 传感器 负载均衡
消息队列 MQ使用问题之如何配置一主一从的同步复制模式
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
消息队列 MQ使用问题之如何配置一主一从的同步复制模式
|
4月前
|
消息中间件 运维 RocketMQ
MetaQ/RocketMQ 原理问题之slave broker是从master同步信息的问题如何解决
MetaQ/RocketMQ 原理问题之slave broker是从master同步信息的问题如何解决
|
5月前
|
消息中间件 存储 Java
后端开发Spring框架之消息介绍 同步异步 JMS AMQP MQTT Kafka介绍
后端开发Spring框架之消息介绍 同步异步 JMS AMQP MQTT Kafka介绍
37 0
|
5月前
|
消息中间件 负载均衡 Apache
消息队列 MQ产品使用合集之是否支持Master/Slave模式进行部署?
阿里云消息队列MQ(Message Queue)是一种高可用、高性能的消息中间件服务,它允许您在分布式应用的不同组件之间异步传递消息,从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
|
6月前
|
消息中间件 数据可视化 RocketMQ
RocketMQ一直连接master失败可能有以下几种原因:
RocketMQ一直连接master失败可能有以下几种原因:
167 2
|
12月前
|
数据库
淘东电商项目(43) -MQ与Logstash实现数据库同步到ES的区别
淘东电商项目(43) -MQ与Logstash实现数据库同步到ES的区别
111 0