RocketMQ存储Topic消息时会按照TopicQueue进行划分. 如下图

首先按照BrokerName划分到不同的master上(每一个master可以有自己的slave,但是slave的BrokerName和master是一样的). 划分到具体的master后又回分到不同的queue上, 每一个master维护自己的queue(即不同master之间的queue没有联系).
目前是这么理解的, 如果错误后续纠正.
RocketMQ存储Topic消息时会按照TopicQueue进行划分. 如下图
首先按照BrokerName划分到不同的master上(每一个master可以有自己的slave,但是slave的BrokerName和master是一样的). 划分到具体的master后又回分到不同的queue上, 每一个master维护自己的queue(即不同master之间的queue没有联系).
目前是这么理解的, 如果错误后续纠正.
本文标题:RocketMQ源码阅读附一TopicQueue的划分
本文链接:https://www.haomeiwen.com/subject/iejpattx.html
网友评论
推荐下,RocketMQ 源码解析 14 篇:http://www.yunai.me/categories/RocketMQ/?jianshu&401