# rocketMQ控制台安装教程
windows安装RocketMQ
原文档地址 (opens new window)
# 导航
# 1 下载源码
# 方式一、git下载,执行如下命令
git clone https://github.com/apache/rocketmq-externals.git
# 方式二、直接下载,访问如下地址即可
https://github.com/apache/rocketmq-externals/archive/master.zip
1
2
3
4
5
2
3
4
5
# 2 修改控制台代码
# 2.1 修改配置
下载完成之后,进入‘\rocketmq-externals-master\rocketmq-console\src\main\resources’文件夹,打开‘application.properties’进行配置。
# console端口
server.port=17890
# name server地址
# 也可以不修改,在启动完console后,在控制台导航栏 - 运维 - NameSvrAddrList一栏设置
rocketmq.config.namesrvAddr=localhost:9876
1
2
3
4
5
2
3
4
5
# 2.2 修改依赖
修改 pom.xml ,修改RocketMQ相关依赖的版本,找到
<rocketmq.version>4.4.0</rocketmq.version>
1
修改为:
<rocketmq.version>你的RocketMQ版本</rocketmq.version>
1
# 2.3 修改代码
修改pom.xml后,org.apache.rocketmq.console.service.impl.MessageServiceImpl#queryMessageByTopic编译会报错,所以需要解决一下。将
DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, null);
1
改为:
RPCHook rpcHook = null;
DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, rpcHook);
1
2
2
即可。
# 2.4 打包构建
# 切换到代码根目录
cd rocketmq-externals
# 切换到控制台目录
cd rocketmq-console
# 构建
mvn clean package -DskipTests
1
2
3
4
5
6
7
8
2
3
4
5
6
7
8
# 启动
java -jar rocketmq-console-ng-1.0.1.jar
1
访问即可
# 控制台的使用
rocketMQ控制台的使用 (opens new window)