Offset
Master2 Broker
CommitLog
地址引用
Pull模型: 每30s随机一台拉取路由信息
Message Queue0
broker集群
独立NameServer
异步生成
同一Topic的各个Queue会平均分布在各个master节点上
Slave1 Broker
Topic
近实时的将CommitLog的数据偏移写入到ConsumerQueue和indexFile
消费者
一个Broker只有一个CommitLogCommitLog对应多个ConsumerQueue
同步/异步复制
Slave2 Broker
生产者
Message Queue2
OS Page Cache
写到master
长连接发送消息
brokerA小集群
NameServer集群
消息持久化
注册长连接30s发一次心跳
一个queue只能被一个consumer消费，一个consumer可消费一个或多个queue
ReputMessageService
30s发送一次心跳，确保broker存货
同步刷盘/异步刷盘
Message Queue3
Master1 Broker
ConsumerQueue
消息
消息
brokerB小集群
长连接拉取消息
Message Queue1
Rebalance消费者组
...
1、broker管理，120s无心跳则剔除2、路由信息管理（broker集群路由信息和客户端查询的队列信息）
indexFile
