1. 下載rocketmq-console-ng
官網地址:https://github.com/apache/rocketmq-externals
拉下來之后,使用idea打開rocketmq-console,在application.properties配置文件中修改rocketmq.config.namesrvAddr(前面集群環境下的nameserver的ip:port),如下:
rocketmq.config.namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
然后打開終端 ,使用如下命令打包:
· mvn clean package -Dmaven.test.skip=true,將會在target目錄中生成一個.jar文件(因為這是一個springboot項目)
將打包生成的.jar文件上傳到linux服務器上。
使用java -jar 文件名運行服務,訪問http://47.105.145.123:8080/#/,出現如下控制台
可以看到有很多菜單可以用的,點到cluster,
看到我們前面搭的集群環境已經可以注冊上去了,可以查看信息和修改配置了。
可能出現的問題:
如果報不能連接到10909端口異常:connect to 172.31.36:10909 failed,這里默認的是使用了vip通道,需要在rocketmq-console項目源碼中修改配置文件,如下:
rocketmq.config.isVIPChannel=false
然后重新打包上傳,
如果配置之后出現不能連接私有異常:connect to 172.31.36:10911 failed,這是默認的rocketmq會將broker的訪問ip使用私有ip,這時只需要在broker配置文件中添加
brokerIP1=公網ip
重啟即可:nohup sh mqbroker -c /usr/local/middle/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &