RocketMQ运行机制逻辑图
2022-04-26 14:07:32 0 举报
RocketMQ运行机制逻辑图
作者其他创作
大纲/内容
queue3
订阅
broker-b
broker-A
consumer
brocker-B
平均消费queue中的信息
queue2
主动上报broker的状态
而在broker中则按照topic来维护consumerqueue文件，而这个文件仅仅是维护了queue跟commitlog真正消息的索引
broker-a
根据订阅的topic与对应的broker建立长连接，等待消息返回，默认是轮询方式
producer
queue1
而同一个topic的queue是可能存在不同broker集群中的
nameserver
broker（master）
1、连接nameserver
nameserver2
根据nameserver返回的broker发送消息
broker（slave）
Topic
queue0
nameserver1
consumer真正消费是按照group+topic的维度来消费的不同的group是可以多次消费同一个topic下的消息的
nameserver3
往topic中发送消息
group
而topic消息真正是通过queue存储的
所有虽然producer是有序的将消息发送出去，但是由于消费者是通过queue并行消费的，所以消费的数据可能是乱序的s
0 条评论
回复 删除
下一页
