rocketmq-broker接受消息流程是怎么样的
1、消息发送
RocketMQ中,消息的发送是通过客户端发送到Broker的,客户端发送的消息,会先经过NameServer进行路由,然后再发送到Broker,Broker收到消息后,会将消息存储到存储设备,同时,也会将消息发送给消费者,完成消息的发送。
2、消息路由
在RocketMQ中,消息的路由是通过NameServer来完成的,客户端发送消息时,会先向NameServer发送消息,NameServer会根据Topic的路由规则,将消息路由到对应的Broker,然后再发送到Broker。
3、消息存储
Broker收到消息后,会将消息存储到存储设备,RocketMQ支持两种存储方式,一种是基于内存的存储,一种是基于磁盘的存储,内存存储可以实现更快的消息发送,但是存储量有限,磁盘存储可以实现更大的存储量,但是消息发送的速度会慢一些。
4、消息发送给消费者
Broker收到消息后,会将消息发送给消费者,消费者收到消息后,会根据消息的Topic和Tag,进行消息的过滤,只有符合条件的消息,才会被消费者接收,否则,消费者将不会收到该消息。
猜您想看
-
如何分析python二叉树的层次遍历
一、什么是层次...
2023年05月26日 -
如何利用selenium库爬取京东python书籍一百页存入csv
利用selen...
2023年07月23日 -
如何使用Night Shift保护您的眼睛
如何使用Nig...
2023年05月05日 -
TencentOS tiny消息队列的说明以及消息队列的相关操作介绍
1.Tence...
2023年05月26日 -
rem怎么通过端口杀kill进程
一、什么是端口...
2023年05月26日 -
CenterNet中怎么利用deepsort实现多目标由于OO由于OOM导致锁没有释放的定位问题是怎么就觉得
利用DeepS...
2023年05月26日