系列

Topic可以理解為在rocketMq體系當中作為一個邏輯消息組織形式，一般情況下一類業務消息會申請一個topic來實現業務之間隔離。

Topic的存儲

Topic的實際存儲模型

說明：

Topic是一個邏輯上的概念，實際上在每個broker上以queue的形式保存，也就是說每個topic在broker上會劃分成幾個邏輯隊列，每個邏輯隊列保存一部分消息數據，但是保存的消息數據實際上不是真正的消息數據，而是指向commit log的消息索引。

Topic創建的時候可以用集群模式去創建(這樣集群里面每個broker的queue的數量相同)，也可以用單個broker模式去創建(這樣每個broker的queue數量可以不一致)。

每個broker上的角色是等同的，也就是說每個broker上面的queue保存了該topic下一部分消息，注意是一部分而不是全量消息。

rocketMq的命令行工具

rocketMq的CLI

說明：

在rocketMq編譯后的bin目錄下有一個mqadmin的工具，該工具作為rocketMq的CLI工具對外提供，使用時候可以通過sh mqadmin -h 或者sh mqadmin command -h查看用法。

updateTopic和deleteTopic是實際中操作topic的命令。

rocketMq的topic工具

topic操作的CLI

說明：

創建topic需要指定的參數，

-b 指定broker上創建topic

-c 指定cluster創建topic

-n 指定namesrv地址，cluster模式下必須從namesrv獲取broker地址

-t topic的名字標志

-r/w 讀寫隊列的個數，建議相等

-p queue的讀寫權限

-o 待研究不確定是不是保證全局有序消息的配置

topic的創建過程

rocketMq創建過程

說明：

topic的創建過程涉及到3個組件，分別是mqadmin、broker、namesrv。

整個創建過程是mqadmin->broker->namesrv。

mqadmin通知broker創建topic和對應的queue信息。

broker轉發通知namesrv保存topic和broker的原信息，同時在本地持久化一份topic配置。

broker在這個時候不真正創建本地的隊列信息

mqadmin操作過程

updateTopic的參數

說明：

參見?UpdateTopicSubCommand類

注冊參數和updateTopic顯示幫助是一致的

集群和broker模式下創建topic

說明：

支持cluster模式下創建topic和支持broker模式下創建topic

通知broker創建topic

說明：

通知broker創建topic。

集群模式下獲取broker地址

說明：

集群模式下首先通過namesrv獲取所有的broker的master地址，然后通知每個broker去創建topic，每個broker的創建過程跟指定單個broker是一致的。

broker操作過程

broker處理topic創建消息入口

說明：

參見AdminBrokerProcessor類

broker本地保存topic配置并轉發namesrv

說明：

broker本地通過updateTopicConfig保存topic的配置信息并持久化

broker通過registerBrokerAll通知namesrv保存topic信息

broker向namesrv注冊topic

說明：

broker通知namesrv注冊該broker下的topic信息，具體的namesrv地址是在registerBrokerAll內部訪問namesrv獲取的。

namesrv操作過程

namesrv處理topic創建消息

說明：

參見DefaultRequestProcessor類

namesrv解析topic信息

說明：

參見DefaultRequestProcessor類

namesrv保存注冊topic信息

說明：

參見RouteInfoManager類

總結

以上是生活随笔為你收集整理的rocketmq 消息 自定义_rocketMq-Topic创建过程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。