場景描述

RocketMQ集群信息是指描述RocketMQ集群的配置和狀態的信息。它包括集群的名稱、角色、節點信息、主題信息等。通過集群信息，可以管理和監控RocketMQ集群的運行情況，包括節點的狀態、消息的發送和消費情況，以及負載均衡等。集群信息對于配置、監控和管理RocketMQ集群非常重要，能夠確保集群的正常運行和高可用性。

• 配置管理：集群信息可以用于管理RocketMQ集群的配置，包括節點的IP地址、端口號、角色（如Master、Slave）、存儲路徑等。通過集群信息，可以方便地查看集群配置，協助保障集群的正常運行。
• 監控和管理：集群信息可以用于監控RocketMQ集群的狀態和健康狀況。通過集群信息，可以查看集群的運行狀態、消息的發送和消費情況，以及節點的負載情況等。這對于集群的管理和故障排查非常重要。
• 負載均衡：集群信息可以用于實現RocketMQ的負載均衡。通過集群信息，可以根據節點的負載情況，動態地調整消息的分布和消費的負載，保證集群的高可用性和性能。
• 容災和高可用性：集群信息可以用于實現RocketMQ的容災和高可用性。通過配置主備節點和多副本模式，可以保證消息的可靠傳遞和數據的一致性。集群信息可以用于監控主備節點的狀態，并在主節點故障時自動切換到備節點，保證集群的高可用性。

集群列表

分布式消息服務RocketMQ集群信息界面展示如下圖：

以下適用于南京3、上海7、重慶2、烏魯木齊27、保定、石家莊20、內蒙6、晉中、北京5 節點。

列表展示該集群每個broker的統計指標概況：

其中關鍵指標

• 昨天生產總數為前一天24小時內生產消息總數
• 昨天消費總數為前一天24小時內消費消息總數
• 今日生產總數為當前生產消息總量減去當天點集群內的生產消息總數
• 今日消費總數為當前消費消息總量減去當天點集群內的消費消息總數

以下適用于華東1、華北2、西南1、華南2、上海36、青島20、長沙42、南昌5、武漢41、杭州7、西南2-貴州、太原4、鄭州5、西安7、呼和浩特3 節點。

列表展示該集群每個broker的統計指標概況：

其中關鍵指標

• 生產TPS（1min），即生產TPS（每分鐘事務數），是指RocketMQ消息生產者在一分鐘內發送的消息數量。TPS是衡量系統性能的重要指標之一，它反映了系統處理能力的強弱。對于RocketMQ來說，生產TPS代表了消息生產者的發送速度和系統的處理能力。較高的生產TPS意味著系統能夠處理更多的消息請求，具有更高的吞吐量。監控和優化生產TPS可以幫助提高系統的性能和可擴展性。
• 消費TPS（1min），即消費TPS（每分鐘事務數），是指RocketMQ消息消費者在一分鐘內成功消費的消息數量。消費TPS反映了系統消費消息的速度和處理能力。較高的消費TPS表示系統能夠高效地處理大量的消息，具有更高的吞吐量。監控和優化消費TPS可以幫助提高系統的消費能力和性能。

Broker信息

展示該集群具體broker信息，包括該broker的詳細指標，如下圖：

其中關鍵指標為：

• commitLogMaxOffset為當前brokercommitLog最大的物理偏移。通過commitLogMaxOffset，RocketMQ可以追蹤和管理消息的存儲位置。當有新的消息寫入時，RocketMQ會將消息追加到Commit Log文件的末尾，并更新commitLogMaxOffset的值。消費者在消費消息時，可以根據commitLogMaxOffset來確定從哪個偏移量開始消費消息。
• consumeQueueDiskRatio為消費隊列存儲的文件占用的磁盤空間比例。通過配置consumeQueueDiskRatio，可以在保證消費隊列的性能的同時，控制磁盤空間的占用。較小的consumeQueueDiskRatio值可以提高消費隊列的讀寫性能，但會增加內存的使用。較大的consumeQueueDiskRatio值可以降低內存的使用，但可能會降低消費隊列的讀寫性能。根據實際需求，可以根據系統的內存和磁盤資源情況來調整consumeQueueDiskRatio的值，以獲得更好的性能和資源利用率。
• putMessageDistributeTime為消息寫入commitLog的耗時分布。通過配置putMessageDistributeTime，可以了解消息從發送到最終被消費的整體時間。這對于監控和優化消息傳遞的性能和延遲非常有用。注意，putMessageDistributeTime是一個估計值，實際的消息傳遞時間可能會受到網絡狀況、消費者處理能力等多種因素的影響。因此，在配置putMessageDistributeTime時，需要根據實際情況進行調整，并結合其他指標進行綜合分析。

Broker詳情