RocketMq流程图
2021-08-30 18:59:14 0 举报RocketMq流程图
作者其他创作
大纲/内容
Producer Cluster
6、Consumer从对应的broker上拉去消息
2、心跳检测
NameServer Cluster
1、注册两部分信息(每个broker向所有的NS上都注册一遍)a:集群的Topic-Queue的路由配置；b:Broker的实时配置信息
Slave2
Slave1
6、pull
Sync
Producer2
4、消费者每隔30秒从一台NS获取所有Topic-Queue的路由配置，获取当前订阅Topic存在哪些Broker上
2、Broker与NS保持长连接，每隔30秒向所有NS发送心跳，心跳包含了自身的Topic配置信息
3、获取topic-queue配置信息
1、注册
Master2
5、send
Consumer2
Producer3
Master1
Consumer Cluster
1、消费者发送的Message会在Broker中的Queue队列中记录。2、一个Topic的数据可能会存在多个Broker中。3、一个Broker存在多个Queue。4、单个的Queue也可能存储多个Topic的消息。
3、生产者每隔30秒从一台NS上获取所有Topic-Queue的路由配置
4、pull
5、producer可以根据当前topic查出可以往哪些broker发消息，并根据负载均衡算出发往哪个queue。producer与broker建立长连接
SERVER
Producer1
Broker Cluster
Consumer1
Consumer3
0 条评论
下一页
