RocketMQ提供了一些扩展项目支持,地址:https://github.com/apache/rocketmq-externals
其中一个rocketmq-connect-console 项目,就是我们需要的可视化控制台; 
我们把整个项目下载下来,打开rocketmq-connect-console 项目;项目是SpringBoot开发;
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ZVbftyD6-1629617532705)(C:\Users\java1234\Desktop\RocketMQ\课件\RocketMQ分布式消息队列课件.assets\image-20210819082240090.png)]](https://img-blog.csdnimg.cn/1c9d0e81e26246c98ad312f5a6b1c950.png)
打开application.properties 配置文件,我们至少需要修改两个配置项;
server.port=8080,这个是可视化项目启动端口,我们改成8888;
rocketmq.config.namesrvAddr=,这个是指定nameServer地址和端口,我们暂时先搞成localhost:9876,等后面搞集群的话,要再修改;
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-2oPqih07-1629617532706)(C:\Users\java1234\Desktop\RocketMQ\课件\RocketMQ分布式消息队列课件.assets\image-20210819082759143.png)]](https://img-blog.csdnimg.cn/19e28d4c1a4142c683167e882e700fa5.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0,size_16,color_FFFFFF,t_70)
修改后保存,进入命令行,执行:
mvn clean package -Dmaven.test.skip=true
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-dQKdqB1W-1629617532707)(C:\Users\java1234\Desktop\RocketMQ\课件\RocketMQ分布式消息队列课件.assets\image-20210819085630112.png)]](https://img-blog.csdnimg.cn/fecb91b5f5924f3a8dbab9d2e808c244.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0,size_16,color_FFFFFF,t_70)
打包执行完后,在target目录,会生成一个可运行jar rocketmq-console-ng-2.0.0.jar
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-5fCQFvRg-1629617532708)(C:\Users\java1234\Desktop\RocketMQ\课件\RocketMQ分布式消息队列课件.assets\image-20210819085720878.png)]](https://img-blog.csdnimg.cn/be39d7739cd44156bb14f4502c513895.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0,size_16,color_FFFFFF,t_70)
我们运行这个jar,进入命令行执行:
java -jar rocketmq-console-ng-2.0.0.jar
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-G3tWm3VV-1629617532709)(C:\Users\java1234\Desktop\RocketMQ\课件\RocketMQ分布式消息队列课件.assets\image-20210819085843407.png)]](https://img-blog.csdnimg.cn/9f1af4eeacf24eaa852c543815e8a6db.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0,size_16,color_FFFFFF,t_70)
启动成功后,浏览器输入:http://localhost:8888/
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-mFc8dMJc-1629617532709)(C:\Users\java1234\Desktop\RocketMQ\课件\RocketMQ分布式消息队列课件.assets\image-20210819085938782.png)]](https://img-blog.csdnimg.cn/23c9391f52d24277abe9fc994b44d1d6.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0,size_16,color_FFFFFF,t_70) 说明:这个是锋哥的RocketMQ备课笔记,等备课完,会发布配套的视频教程,如有需要,可以先加锋哥WX:java3459 欢迎白嫖
说明一切OK;
微信搜一搜公众号【java1234】关注这个放荡不羁的程序员,关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。
|