場景描述

RocketMQ中的(de)(de)Topic是(shi)消息(xi)發(fa)布和訂閱的(de)(de)核心概念之一(yi)。主題(ti)可以理解為消息(xi)的(de)(de)分(fen)類或(huo)者標(biao)簽，用(yong)于將一(yi)組相關的(de)(de)消息(xi)進行歸(gui)類和管理。

• 在RocketMQ中，消息發送者通過指定主題來發布消息，而消息消費者則通過訂閱主題來接收消息。一個主題可以有多個生產者和多個消費者。生產者將消息發送到主題，而消費者從主題中訂閱消息。
• 主題的創建和管理是由RocketMQ的管理員或者應用程序開發者負責的。創建主題時，需要指定主題的名稱，并可以設置一些屬性，如主題的存儲策略、消息的過期時間等。主題的名稱應該具有一定的描述性，能夠清楚地表達所屬消息的含義或用途。
• 主題在RocketMQ中具有一定的靈活性和擴展性。可以根據業務需求創建多個主題，每個主題用于處理不同類型或不同業務場景下的消息。通過合理地設計和管理主題，可以實現消息的高效傳遞和靈活的消息路由。

總之(zhi)，主(zhu)題是RocketMQ中用(yong)于分類和(he)管(guan)理消息(xi)(xi)的(de)重要概(gai)念，通(tong)過主(zhu)題可以實現消息(xi)(xi)的(de)發布和(he)訂閱，幫助開發者更好地組織(zhi)和(he)管(guan)理消息(xi)(xi)系統。

Topic列表

1、 進入Topic管理(li)菜單(dan)查看(kan)Topic列(lie)表，若列(lie)表為空則新建(jian)Topic，創建(jian)Topic詳情見(jian)具體(ti)操作步驟。

2、 支持按照集群、Broker和Topic查(cha)詢(xun)，下拉選擇或(huo)者輸(shu)入查(cha)詢(xun)內容，點擊【查(cha)詢(xun)】按鈕即可展(zhan)示需(xu)要(yao)的Topic數據。

3、 查看Topic基本(ben)信息，包括Topic名(ming)、brokerName、讀(du)隊列(lie)數(shu)量(liang)、寫隊列(lie)數(shu)量(liang)、權(quan)(quan)限(xian)、是否(fou)有序。其(qi)中Topic權(quan)(quan)限(xian)包括讀(du)寫、只讀(du)、只寫3類權(quan)(quan)限(xian)。

Topic詳情

展(zhan)示當前Topic的統計指(zhi)標、隊列(lie)分(fen)布信息(xi)、消費組(zu)、生產組(zu)的情況。

1、隊列信息

2、消費組

標識正在連接該topic的(de)消(xiao)費(fei)組列表。

消費方式分為兩種：

• CONSUME_PASSIVELY為push消費模式
• CONSUME_ACTIVELY為pull消費模式

路由

展示topic的隊列(lie)分布(bu)(bu)情(qing)況，隊列(lie)分布(bu)(bu)在(zai)哪些(xie)broker上

RocketMQ的(de)隊列(lie)分布情況是根(gen)據Broker的(de)配(pei)置(zhi)和(he)主題(ti)的(de)配(pei)置(zhi)來確定的(de)。在RocketMQ中，每個主題(ti)可(ke)以(yi)有多(duo)(duo)個隊列(lie)，每個隊列(lie)可(ke)以(yi)有多(duo)(duo)個Broker來提供服務(wu)。

隊列的(de)分(fen)布情況可以(yi)通過(guo)以(yi)下幾個因素(su)來(lai)確定：

• Broker的配置：在RocketMQ中，每個Broker都有一個唯一的名稱，可以通過名稱來識別和配置Broker。當創建主題時，可以指定消息隊列的數量和分布策略。分布策略可以是固定的，也可以是根據一定規則動態分配的。
• 主題的配置：在創建主題時，可以指定隊列的數量和分布策略。分布策略可以是按照固定數量進行分配，也可以是根據一定規則進行動態分配。例如，可以將消息隊列均勻地分布在不同的Broker上，也可以根據消息的屬性將消息路由到不同的隊列。
• 負載均衡策略：RocketMQ提供了多種負載均衡策略，用于在Broker集群中均衡地分布消息隊列。負載均衡策略可以根據Broker的負載情況、網絡延遲等因素來進行動態調整，以確保消息隊列的均衡分布和高效處理。

總的(de)(de)來(lai)說(shuo)，RocketMQ的(de)(de)隊(dui)列分布情況(kuang)是根(gen)據Broker的(de)(de)配(pei)置、主題的(de)(de)配(pei)置和負(fu)載(zai)(zai)均(jun)(jun)衡(heng)策略來(lai)確定的(de)(de)。通過合理的(de)(de)配(pei)置和使用(yong)負(fu)載(zai)(zai)均(jun)(jun)衡(heng)策略，可以(yi)實(shi)現消(xiao)息隊(dui)列的(de)(de)均(jun)(jun)衡(heng)分布和高效(xiao)處理，提高消(xiao)息系統的(de)(de)性能和可擴展性。

導出

將勾選的topic，導出(chu)其(qi)配置(zhi)及路由情況(kuang)，為excel文件，導出(chu)格式如下：

備注：

如果(guo)勾選(xuan)了(le)topic，則導(dao)出勾選(xuan)的topic;如果(guo)沒有(you)勾選(xuan)，則導(dao)出該集(ji)群，選(xuan)定broker下的所有(you)topic信息。

堆積量

展示該topic被哪些消(xiao)費組消(xiao)費，及(ji)該消(xiao)費組對應的未(wei)消(xiao)費的消(xiao)息數量統計；

通過“offset查詢”，可以查找隊(dui)列相應(ying)偏移(yi)量(liang)的消息；

“TPS監(jian)控(kong)”：顯示指定topic的(de)生產、消費的(de)tps趨(qu)勢圖。