【MQ-Apache|RocketMQ-初体验RocketMQ(04)_使用RocketMQ Console源码搭建RocketMQ Console与基本使用【MQ-Apache|RocketMQ】

文章目录

Github地址
IDEA中部署

修改两处地方
修改application.properties配置
修改依赖
启动RokcetMQ Console

访问RocketMQ Console
更多方式安装 RocketMQ Console
UserGuide

【MQ-Apache|RocketMQ-初体验RocketMQ(04)_使用RocketMQ Console源码搭建RocketMQ Console与基本使用

文章图片

Github地址访问 rocketmq-externals
选择

文章图片

rocketmq-console ：戳这里
选择 release-rocketmq-console-1.0.0 分支

文章图片

IDEA中部署下载成功后，将rocketmq-console项目导入idea，在idea中进行编译，等待maven自动下载好依赖的jar, 耗时稍微长点，如果还是有依赖包飘红，建议到本地仓库，删除后重新下载，Reimport
修改两处地方 A: MQAdminExtImpl 重写 queryConsumeQueue方法

文章图片

B: MonitorServiceImpl#loadData方法

文章图片

修改application.properties配置

文章图片

server.contextPath= server.port=8080 #spring.application.index=true spring.application.name=rocketmq-console spring.http.encoding.charset=UTF-8 spring.http.encoding.enabled=true spring.http.encoding.force=true logging.config=classpath:logback.xml #if this value is empty,use env value rocketmq.config.namesrvAddrNAMESRV_ADDR | now, you can set it in ops page.default localhost:9876 rocketmq.config.namesrvAddr=192.168.18.130:9876; 192.168.18.131:9876; #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=C:\\temp\\rocketmq‐console\\data #set it false if you don't want use dashboard.default true rocketmq.config.enableDashBoardCollect=true

修改依赖 pom.xml中修改Rocketmq依赖版本，修改为与服务端对应的版本。我这里用的是4.3.2

文章图片

启动RokcetMQ Console 如果不是在idea中打开项目，则直接cd回项目目录：cd ${path}/rocketmq-console
执行编译命令：mvn clean package -Dmaven.test.skip=true，
此时target文件夹下会生成rocketmq-console-ng-1.0.0.jar，在target目录下，执行java -jar rocketmq-console-ng-1.0.0.jar启动console。
如果是在idea中打开的项目，
启动方式一：直接点击spring-boot:run