RocketMQ控制台安装教程
RocketMQ安装教程 一节中,详细探讨了如何搭建RocketMQ,这一节来搭建RocketMQ控制台,RocketMQ的可视化管理界面。
一、下载代码
1 | 方式一、git下载,执行如下命令 |
二、修改控制台代码
2.1 修改配置
找到rocketmq-console/src/main/resources/application.properties
根据需求,修改配置
1 | # 管理后台访问上下文路径,默认为空 |
笔者只修改了如下两项:
1 | # console端口 |
2.2 修改依赖
修改 pom.xml
,修改RocketMQ相关依赖的版本
找到
1 | <rocketmq.version>4.4.0</rocketmq.version> |
修改为
1 | <rocketmq.version>你的RocketMQ版本</rocketmq.version> |
笔者使用的是RocketMQ 4.5.1,故而改为
1 | <rocketmq.version>4.5.1</rocketmq.version> |
2.3 修改代码
修改pom.xml后,org.apache.rocketmq.console.service.impl.MessageServiceImpl#queryMessageByTopic
编译会报错,所以需要解决一下。将
1 | DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, null); |
改为:
1 | RPCHook rpcHook = null; |
即可。
2.4 打包构建
1 | 切换到代码根目录 |
三、懒人包
笔者已经将修改好的RocketMQ控制台发布到GitHub了。
下载地址:https://github.com/eacdy/rocketmq-externals/releases
四、启动
1 | java -jar rocketmq-console-ng-1.0.1.jar |
五、访问
访问 http://localhost:17890
(端口用上面 application.properties
中的 server.port=17890
指定,默认是8080) ,即可看到类似如下的界面:
评论系统未开启,无法评论!