RocketMQ 控制台

RocketMQ 控制台 是管理 RocketMQ 的工具，提供事件和用戶端與應用程式效能的各種統計資訊，並支援可視化工具來取代命令列操作，例如主題設定和代理管理。

簡介

功能概觀

控制台	功能
OPS	修改名稱伺服器地址；使用 VIPChannel
控制台	檢查代理、主題訊息量
叢集	叢集分佈、代理設定、執行時期資訊
主題	搜尋、篩選、刪除、更新/新增主題、訊息路由、傳送訊息、重設消費點
消費者	搜尋、刪除、新增/更新消費者群組、終端、消費詳細資料、設定
訊息	訊息記錄、私訊、訊息追蹤等訊息詳情

操作面板：

快速上手

系統需求：

1. Linux/Unix/Mac
2. 64bit JDK 1.8+
3. Maven 3.2.x
4. 啟動 RocketMQ

網路配置：

1. 雲端伺服器可遠端存取或本機虛擬機可 PING 外網
2. rocketmq 設定檔 broker.conf / broker-x.properties 設定 nameserver 的地址和埠。
3. 使用設定檔啟動 broker

1. Docker image 安裝

① 安裝 docker 並拉取 rocketmq-dashboard image

docker pull apacherocketmq/rocketmq-dashboard:latest

② 在 docker 容器中執行 rocketmq-dashboard

docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest

提示

將 namesrv.addr:port 替換成 rocketmq 中設定的 nameserver 地址和埠

1. 開啟埠號：8080、9876、10911、11011

• 雲端伺服器：設定安全群組存取規則
• 本機虛擬機：關閉防火牆，或 -add-port

2. 原始碼安裝

原始碼地址：apache/rocketmq-dashboard

下載、解壓縮，並進入原始碼目錄 rocketmq-dashboard-master/

① 編譯 rocketmq-dashboard

mvn clean package -Dmaven.test.skip=true

② 執行 rocketmq-dashboard

java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar

提示

在 x.xxx 秒內啟動應用程式（JVM 執行 x.xxx），表示啟動成功。

瀏覽器頁面存取：namesrv.addr:8080

關閉 rocketmq-dashboard：ctrl + c

重新啟動：執行 ②

提示：下載的原始碼需要上傳到 Linux 系統編譯，本地編譯可能會報錯

教學

1.建立主題-Topic

Topic > 新增/更新

2.建立消費者群組-Consumer

Consumer > 新增/更新

3.重設消費位移

Topic > 重設消費者位移

提示

• 叢集消費支援重設消費位移，但廣播模式不支援。
• 如果消費者不在線上，則無法重設消費位移。

4.擴充主題佇列

Topic > 主題設定

5.擴充 Broker

• 在與目前叢集相同名稱伺服器地址安裝並部署新的仲介

  

• 更新主題的 BROKER_NAME

  Topic > 新增/更新 > BROKER_NAME

6.傳送訊息

• 傳送訊息至特定主題

  Topic > 傳送訊息

  

• 傳送結果