Rocketmq消息写入原理
2022-05-10 16:02:35 0 举报rocketmq消息写入原理
作者其他创作
大纲/内容
pullMessageService-messageListener
Topic下划分Queue队列
OrderlyMessageService 有序消费
indexFile列表.
获取消息
...
msg_0
ConcurrentMessageService 并发消费
choose one
queue_10
offset_0
Topic_4
queue_1
topicRouteInfo
Topic_2
/index/20220522183402001
offset_1
topic_x
Broker
MappedFileQueue
offset_2
存储消息-commitLog
offset_3
存储消息-重放消息-构建consumerQueue
/index/20220510183402001
生产者-客户端
msg_1
ConsumerQueueTableTopic维度缓存
msg_3
Topic_3
msg_19
pullRequestQueue 阻塞队列
存储消息-重放消息-构建cindex
映射的文件文件名为offset起始值. 大小规定为fileSize。产生的文件由offset不断递进.创建顺序一定是在offset小的完成的情况下创建的
queue_0
/index/20220510153402001
msg_2
topic_y
take
/index/20220529153402001
通过topic获取消息
topic_z
消费者-客户端
收藏
收藏
0 条评论
下一页
