ASYNC
commitlog
borker cluster
namesrvs-1
queue-1
Java开发电商
延时消息批量消息过滤消息事务消息
每个topic默认有4个queue
注册自己获取mq集群的borker，queue信息
每个consumer定时或kill阶段提交各自对应queue的offset位置
queue-2
namesrvs-2
注册
borker slave2
非日志的可靠消息传输例如：订单，交易、充值阿里巴巴java语言开发，已加入Apache注册中心是nameserver，不支持自动选举可用性非常高 分布式 主从消息堆积是性能好，所有才消息存储在commitlog中同步双写 异步复制支持pull 和 push支持顺序消费支持事务消息支持消息查询
consumer-2
borker cluster2
SYNC
consumer-3
borker slave1
producer
bind & consumer message
consumer-1
consumer-0
解耦削峰填谷异步处理分布式事务-中间协调
发送消息的流程1、producer默认从broker的队列中选择一个queue发送消息2、默认选择策略：已发送的消息数量对队列数mod3、消息内容全部存储在commitlog中，queuelog记录每条消息在commitlog中存储的位置信息
RocketMQ
borker master1
namesrvs
consumer queue
queue-0
消费topic的消费组
consumerOffset.json
queue-3
