RocketMQ系统架构解析
2024-03-29 16:56:59 0 举报
RocketMq整理系统交互图示及举例
作者其他创作
大纲/内容
Slave
Broker Cluster
Producer Cluster
......
Producer2
2H
Broker-d
Consumer2
Queue3
6H
独立的存储单元
Broker-c
10
12H
Producer3
Queue2
注册Broker信息
40
Consumer Group_B ......
Producer Group_A1
Broker-b
Pull从拉
生产者信息注册
主从同步
8H
TagB2
9H
Broker-a
Producer1
Master
Queue1
60
1H
Consumer注册信息
50
消费者信息注册
Producer Group_A ......
TagA1
Push主推
Consumer Group_B1
Producer Group_A2
Queue0
4、将对应的消息发送给对应的消费者
7H
1、获取需要发送的Broker信息
Topic_A1
Consumer1
Consumer3
commitLog
20
单位：次
10H
48
NameServer Cluster
TagA2
TagAN
Topic_B1
MQ消息消费性能测试折线图
15
TagBN
11H
Producer ......
5H
0
2、发送消息到对应Broker中的队列中
Consumer ......
TagB1
Consumer Cluster
30
Producer注册信息
3、获取对应的消费者信息
4H
Consumer Group_B2
3H
消费者驱动： 无论是Pull还是Push，消费者都是主动发起消费的一方。Pull模式中，消费者主动发起拉取消息的请求；Push模式中，虽然消息是被动推送给消费者，但消费者仍然需要主动处理接收到的消息。
Consumer Group_BN
Producer Group_AN
0 条评论
回复 删除
下一页
