RocketMQ底层架构
2021-11-12 18:44:57 2 举报
RocketMQ底层架构
作者其他创作
大纲/内容
每个consumer定时或者kill阶段提交各自对应queue的offset值
Name Server-2
consumerOffset.json
Name Server-1
commit log
1、注册自己2、获取集群的broker、queue等信息
pull/push
Name Server Cluster
Topic
async
sync
consumer-0
queue group
broker-salve-1
broker-master-1
和消费broker-master2策略一样
Producer-N
queue-0
注册
Broker Cluster
1.随机挑选一个queue发送消息
RocketMQ底层架构
2.将发送成功的消息生成offset写入到commit log
broker-master-2
Round Robin 负载均衡策略
Consumer Group
每个topic默认有4个queue,可以自行设置
consumer-1
push
0 条评论
下一页