1、消息发送

RocketMQ 中,消息的发送是通过客户端发送到 Broker 的,客户端发送的消息,会先经过 NameServer 进行路由,然后再发送到 Broker,Broker 收到消息后,会将消息存储到存储设备,同时,也会将消息发送给消费者,完成消息的发送。

2、消息路由

在 RocketMQ 中,消息的路由是通过 NameServer 来完成的,客户端发送消息时,会先向 NameServer 发送消息,NameServer 会根据 Topic 的路由规则,将消息路由到对应的 Broker,然后再发送到 Broker。

3、消息存储

Broker 收到消息后,会将消息存储到存储设备,RocketMQ 支持两种存储方式,一种是基于内存的存储,一种是基于磁盘的存储,内存存储可以实现更快的消息发送,但是存储量有限,磁盘存储可以实现更大的存储量,但是消息发送的速度会慢一些。

4、消息发送给消费者

Broker 收到消息后,会将消息发送给消费者,消费者收到消息后,会根据消息的 Topic 和 Tag,进行消息的过滤,只有符合条件的消息,才会被消费者接收,否则,消费者将不会收到该消息。