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