啟動好服務以后，總得有一個可視化界面來看看我們配置的節點情況吧。rocket官方提供了一個可視化控制臺，大家可以在這個地址下載

https://github.com/apache/rocketmq-externals?

這個是rocketmq的擴展，里面不僅包含控制臺的擴展，也包含對大數據flume、hbase等組件的對接和擴展。

下載源碼包?

https://github.com/apache/rocketmq-externals/archive/master.zip?

解壓并修改配置?

cd /${rocketmq-externals-home}/rocket-console/?

修改application.properties文件

配置namesrvAddr地址，指向目標服務的ip和端口:?

rocketmq.config.namesrvAddr=192.168.13.162:9876?

運行?

1. cd /${rocketmq-externals-home}/rocket-console/?

2. mvn spring-boot:run?

通過控制臺創建消息?

要能夠發送和接收消息，需要先創建Topic，這里的Topic和kafka的topic的概念是一樣的進入到控制臺，選擇topic?

readQueueNums和writeQueueNums分別表示讀隊列數和寫隊列數

writeQueueNums表示producer發送到的MessageQueue的隊列個數

readQueueNumbs表示Consumer讀取消息的MessageQueue隊列個數，其實類似于kafka的分區的概念

這兩個值需要相等，在集群模式下如果不相等，假如說writeQueueNums=6,readQueueNums=3, 那么每個broker上會有3個queue的消息是無法消費的。

?

總結

以上是生活随笔為你收集整理的rocketmq控制台安装的全部內容，希望文章能夠幫你解決所遇到的問題。

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