ROCKETMQ_HOME}/store/config/topics.json。 在 RocketMQ4.5.0 版本后引入了多副本机制，即一个复制组（m-s）可以演变为基 于 raft 协议的复制组，复制组内部使用 raft 协议保证 broker 节点数据的强一致性，该部署 架构在金融行业用的比较多。 二、消息订阅模型 在 RocketMQ 的消息消费模式采用的是发布与订阅模式。 top { // @6 response.setCode(ResponseCode.QUERY_NOT_FOUND); response.setRemark("Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first"); } } return response; } 代码@1：从消费消息进度文件中查询消息消费进度。 g 是否启用 DLedger，即是否启用 RocketMQ 主从切换，默认值为 false。如果需要 开启主从切换，则该值需要设置为 true 。  dLegerGroup 节点所属的 raft 组，建议与 brokerName 保持一致，例如 broker-a。  dLegerPeers 集群节点信息，示例配置如下：n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127

for Taobao B2C Trading Aliw a reM Q Ap a che In cuba tin g 分布式事务消息 原生消息轨迹，AC L 支持 存储架构全面升级，RAFT 存储开源 轻量级Pull con sum er 发布 Request-Rep ly 特性支持 IPv 6 支持 © 2 0 1 7 A l i b a b a M i d d eta Q v 2 .0 RocketM Q v 3 .0 Ap a che RocketM Q 4.x Lin ux Op en M essa gin g 主从复制架构升级，性能提升数倍 RAFT 存储生产可用 rocketm q-con n ect 进入孵化 2021 5.0 -p rev iew 发布 性能优化、PoP 消费，多存储目录， 轻量级队列 rocketm q-strea 力 • 容量调整时，不能产生数据迁移，且要在秒级完成 固定分区使用场景 • 任务计算过程中，会将同一个业务类型的数据发到同一个队列 • Binlog 等数据同步过程中，需要保证严格顺序 RAFT 存储支持：自动主从切换，强一致性保证 逻辑队列：秒级无损弹性扩缩，无数据复制，流量精准调度 消息与流融合索引支持 核心问题 • 消息体小且存储结构面向单 条消息，导致提升吞吐困难 •

Broker Instance 上面启动三个 Broker 实例，每个 Broker 实例会在 三个 Broker Instance 之间形成一个基于 Raft 的高可用 dledger 集群，如果其中一个 Broker 实例因故障无法提供服务，Raft 协议会自动在另外两个 Instance 中选择一个作 为 Master 继续提供服务从而达到高可用的效果，下图是部署完的一个架构实例图

Broker Instance 上面启动三个 Broker 实例，每个 Broker 实例会在三个 Broker Instance 之间形成一个基于 Raft 的高可用 dledger 集群，如果其中一个 Broker 实例 因故障无法提供服务，Raft 协议会自动在另外两个 Instance 中选择一个作为 Master 继续提供服务从而达到高可用的效果，下图是部署完的一个架构实例图

rocketmq-acl-4.9.2-SNAPSHOT.jar ├── rocketmq-broker-4.9.2-SNAPSHOT.jar ├── rocketmq-client-4.9.2-SNAPSHOT.jar ├── rocketmq-common-4.9.2-SNAPSHOT.jar ├── rocketmq-example-4.9.2-SNAPSHOT.jar ├── 9.2-SNAPSHOT.jar ├── rocketmq-logging-4.9.2-SNAPSHOT.jar ├── rocketmq-namesrv-4.9.2-SNAPSHOT.jar ├── rocketmq-openmessaging-4.9.2-SNAPSHOT.jar ├── rocketmq-remoting-4.9.2-SNAPSHOT.jar ├── rocketmq-srvutil-4.9.2-SNAPSHOT.jar ├── rocketmq-store-4.9.2-SNAPSHOT.jar ├── rocketmq-tools-4.9.2-SNAPSHOT.jar ├── slf4j-api-1.7.7.jar ├── snakeyaml-1.19.jar ├── tomcat-annotations-api-8