高效的订阅者水平扩展能力  实时的消息订阅机制  亿级消息堆积能力  较少的依赖 5.2 RocketMQ 物理部署结构 Name Server集群 Broker Master1 Broker Master2 Broker Slave1 Broker Slave2 Producer集群 Consumer集群 图表 5-2RocketMQ 网络部署图 RocketMQ 分为 Master 不 Slave，一个 Master 可以对应多个 Slave，但是一个 Slave 只能 对应一个 Master，Master 不 Slave 的对应关系通过挃定相同的 BrokerName，丌同的 BrokerId 来定丿，BrokerId 项目开源主页：https://github.com/alibaba/RocketMQ 12 为 0 表示 Master，非 0 Slave。Master 也可以部署多个。每个 Broker 不 Name Server 集群中的所有节 点建立长连接，定时注册 Topic 信息到所有 Name Server。  Producer 不 Name Server 集群中的其中一个节点（随机选择）建立长连接，定期从 Name Server 叏 Topic 路 由信息，幵吐提供 Topic 服务的 Master 建立长连接，丏定时吐

..................................................................................... 35 四：HA & master slave .......................................................................................... 定时发送心跳将 producer 信息（其实就是 procduer 的 group）定时发送到， brokerAddrTable 集合中列出的 broker 上去 Producer 发送消息只发送到 master 的 broker 机器，在通过 broker 的主从复制机制拷贝到 broker 的 slave 上去 二：Producer 如何发送消息 Producer pull 接口用到的 flag 9. 调底层通信层向 broker 发送拉消息请求 如果 master 压力过大，会建议去 slave 拉取消息 如果是到 broker 拉取消息清楚实时提交标记位，因为 slave 不允许实时提交消费进 度，可以定时提交 //TODO 关于 master 拉消息实时提交指的是什么？ 10. 拉到消息后回调 PullCallback 处理 broker

0 表示master，>0 表示slave brokerId=0 # 删除文件时间点，默认凌晨4点 deleteWhen=04 # 文件保留时间，默认48小时 fileReservedTime=48 # Broker的角色，AYNSC_MASTER=异步复制master，SYNC_MASTER=同步双写master，SLAVE= lave节点 brokerRole=ASYNC_MASTER # brokerName=broker-b # 0 表示master，>0 表示slave brokerId=1 # 删除文件时间点，默认凌晨4点 deleteWhen=04 # 文件保留时间，默认48小时 fileReservedTime=48 # Broker的角色，AYNSC_MASTER=异步复制master，SYNC_MASTER=同步双写master，SLAVE= lave节点 brokerRole=SLAVE Cent OS rocketmq配置文件 1、配置master节点 conf/2m-2s-async/broker-b.properties # 集群名称 brokerClusterName=mq-broker-cluster # broker名字，不同的配置文件填写的不一样 brokerName=broker-b # 0 表示master，>0 表示slave brokerId=0 # 删除文件时间点，默认凌晨4点

而引导客户端向 Broker 发送消息。Nameserver 之间的节点不通信。路由信息在 Nameserver 集群中数据一致性采取的最终一致性。 2. Broker 消息存储服务器，分为两种角色：Master 与 Slave，上图中呈现的就是 2 主 2 从的部 署架构，在 RocketMQ 中，主服务承担读写操作，从服务器作为一个备份，当主服务器存 在压力时，从服务器可以承担读服务（消息消费）。所有 brokerName = broker-a brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH storePathRootDir=/data/rocketmq/store storePathCommitLog=/data/ro brokerName = broker-a brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH storePathRootDir=/home/dingwpmz/tmp/rocketmq/store storePathCommi

autoCreateTopicEnable=true brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH brokerIP1=172.10.0.15 namesrvAddr=172.10.0.14:9876 autoCreateTopicEnable=true

machine/JVM 2 Commit Service Rollback Service Timeout Service TxCoordinator 3 store TxQue Master Broker TxEvent Commit/Rollback Global Transaction ID Branch Transaction ID 1 RMQ Producer 2 CallbackListener

and low latency file storage upported timestamp and offset two indicates Not Supported Supported, Master-Sl ve model, without another kit Supported Work out of box,user only need to pay at ention to a

Instance 之间形成一个基于 Raft 的高可用 dledger 集群，如果其中一个 Broker 实例因故障无法提供服务，Raft 协议会自动在另外两个 Instance 中选择一个作 为 Master 继续提供服务从而达到高可用的效果，下图是部署完的一个架构实例图 Page 4 of 18 • (*) 跨越多个可用区的公有⼦网和私有⼦网的 VPC（由西云数据运营的

Instance 之间形成一个基于 Raft 的高可用 dledger 集群，如果其中一个 Broker 实例 因故障无法提供服务，Raft 协议会自动在另外两个 Instance 中选择一个作为 Master 继续提供服务从而达到高可用的效果，下图是部署完的一个架构实例图 Page 4 of 21 • (*) 跨越多个可⽤区的公有⼦⽹和私有⼦⽹的 VPC（由西云数据运营的