?

RocketMQ安裝教程?一文中，詳細(xì)探討了如何搭建RocketMQ，這一節(jié)來(lái)搭建RocketMQ控制臺(tái)，RocketMQ的可視化管理界面。

一、下載代碼

# 方式一、git下載，執(zhí)行如下命令 git clone https://github.com/apache/rocketmq-externals.git# 方式二、直接下載，訪問如下地址即可 https://github.com/apache/rocketmq-externals/archive/master.zip

二、修改控制臺(tái)代碼

2.1 修改配置

找到rocketmq-console/src/main/resources/application.properties?根據(jù)需求，修改配置

# 管理后臺(tái)訪問上下文路徑，默認(rèn)為空 # 如果填寫，需寫成/xxx的形式，例如/console server.contextPath=# 控制臺(tái)的端口 server.port=8080...# if this value is empty,use env value rocketmq.config.namesrvAddr NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876 # Name Server地址 rocketmq.config.namesrvAddr=# if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true rocketmq.config.isVIPChannel=#rocketmq-console's data path:dashboard/monitor rocketmq.config.dataPath=/tmp/rocketmq-console/data#set it false if you don't want use dashboard.default true rocketmq.config.enableDashBoardCollect=true#set the message track trace topic if you don't want use the default one rocketmq.config.msgTrackTopicName=rocketmq.config.ticketKey=ticket#Must create userInfo file: ${rocketmq.config.dataPath}/users.properties if the login is required rocketmq.config.loginRequired=false

筆者只修改了如下兩項(xiàng)：

# console端口 server.port=17890 # name server地址 # 也可以不修改，在啟動(dòng)完console后，在控制臺(tái)導(dǎo)航欄 - 運(yùn)維 - NameSvrAddrList一欄設(shè)置 rocketmq.config.namesrvAddr=localhost:9876

2.2 修改依賴

修改?pom.xml?，修改RocketMQ相關(guān)依賴的版本

找到

<rocketmq.version>4.4.0</rocketmq.version>

修改為

<rocketmq.version>你的RocketMQ版本</rocketmq.version>

筆者使用的是RocketMQ 4.5.1，故而改為

<rocketmq.version>4.5.1</rocketmq.version>

2.3 修改代碼

修改pom.xml后，org.apache.rocketmq.console.service.impl.MessageServiceImpl#queryMessageByTopic編譯會(huì)報(bào)錯(cuò)，所以需要解決一下。將

DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, null);

改為：

RPCHook rpcHook = null; DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, rpcHook);

即可。

2.4 打包構(gòu)建

# 切換到代碼根目錄 cd rocketmq-externals# 切換到控制臺(tái)目錄 cd rocketmq-console# 構(gòu)建 mvn clean package -DskipTests

三、懶人包

筆者已經(jīng)將修改好的RocketMQ控制臺(tái)發(fā)布到GitHub了。

下載地址：https://github.com/eacdy/rocketmq-externals/releases

四、啟動(dòng)

java -jar rocketmq-console-ng-1.0.1.jar

五、訪問

訪問?http://localhost:17890?(端口用上面?application.properties?中的?server.port=17890?指定，默認(rèn)是8080) ，即可看到類似如下的界面：

六、控制臺(tái)使用說(shuō)明

RocketMQ控制臺(tái)使用文檔

本文首發(fā)

http://www.itmuch.com/rocketmq/rocketmq-console-install/

總結(jié)

以上是生活随笔為你收集整理的RocketMQ控制台安装教程的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。