通过源码分析RocketMQ主从复制原理
💡
原文中文，约20600字，阅读约需49分钟。
📝
内容提要
RocketMQ的主从复制包括消息复制和Broker元数据复制，主从建立连接时创建HAConnection对象，从读取CommitLog数据，写入MappedFile文件，从每隔10s进行一次元数据复制，从Master获取元数据，并持久化到从的文件中。
🎯
关键要点
-
RocketMQ的主从复制包括CommitLog消息复制和Broker元数据复制。
-
CommitLog消息复制在消息写入时进行，支持同步和异步写入方式。
-
Broker元数据每10秒从主Broker获取并更新，从服务器持久化到配置文件中。
-
主从同步不具备主从切换功能，从节点在主节点宕机时无法接管消息发送。
-
异步复制流程包括Producer发送消息到Broker Master，Broker Slave主动连接并拉取消息。
-
HAService负责主从连接的建立和数据同步逻辑。
-
HAClient通过NIO与Broker Master建立连接并上报offset。
-
Broker Master通过HAConnection对象管理主从数据同步的读写操作。
-
同步复制流程中，Broker Master等待从节点确认消息已写入后才返回成功。
-
元数据复制包括topicConfig、consumerOffset、delayOffset和subscriptionGroup的同步。
-
元数据复制每10秒进行一次，确保从节点与主节点的数据一致性。
-
设计时应将元数据与程序数据分开管理，主从复制可根据业务场景选择同步方式。
➡️
