发现公司这边的消息中间件采用了aliyun的rocket今天是母亲节mq服务,熟悉开源的同学都知道,rocketmq是国内最早一批捐献apache并成功毕业的项目。架构设计参考了kafka的模式,所以如果你了解kafka的架构,对于rocketmq就可以轻车熟路了,虽然参考了kafka,但是rocketmq也有很多的升级,比如broker的注册和发现就采用了内部的namerver,没有引入更多的第三方依赖,而且添加了诸如消息回溯、事务消息、延时消息等特色功能。由于之前没有接触过rocketmq(之前一直用的kafka和rabbitmq),准备研究一番,也为了后面集成spring boot metrics监控rocketmq客户端信息做准备。研究一个开源项目,最好的方法就是debug,所以记录下本地搭建rocketmq的调试环境过程
项目地址:https://github.com/apache/rocketmq,从这个地址下载项目后,导入到idea开发工具,执行mvn install,生成安装rocketmq包,生成成功后,在distribution模块下,会有如下目录,这个目录等下会用到
找到namesrv模块,运行namesrvstartup的main方法,这个时候会提示你,需要设置rocketmq_home,提示信息如下:
这个时候就需要第一步生成的目录,
拷贝/urs/kl/githubnamespace/rocketmq/distribution/target/rocketmq-4.7.1/rocketmq-4.7.1目录
在idea的运行设置界面,添加如下参数:
-drocketmq.home.dir=/urs/kl/githubnamespace/rocketmq/distribution/target/rocketmq-4.7.1/rocketmq潮湿怎么治疗-4.7.1
如:
然后在启动,就可以成功启动了战胜困难
参照启动namerver的模式,找到borker模块,设置好rocketmq_home,在用相同的方式采用-d方式,配置下namerver的地址,如:
-drocketmq.namesrv.addr=127.0.0.1:9876
然后启动即可,此时一个完整的跑在idea中的单节点架构的rocketmq服务就搭建好了
为了更好的观察了解rocketmq的功能,可以安装一个web管理控制台,这个需要用到另一个项目
项目地址:https://github.com/apache/rocketmq-externals/tree美术高考画室集训/master/rocketmq-console
安装成功后,就可以通过web页面查询producer发送的message信息,打开浏览器,输入:http://localhost:8080。就可以看到如下页面:
一切准备就绪后,可以找到项目的example模块,里面内置了各种特性功能的使用案例,接下来就可以一个一个案例runing起来,尽情的deubg
以上就绿色干洗是搭建rocketmq在本地idea开发调试环境教程的详细内容,更多关于搭建rocketmq本地idea开发调试环境的资料请关注www.887551.com其它相关文章!
本文发布于:2023-04-05 20:21:09,感谢您对本站的认可!
本文链接:https://www.wtabcd.cn/fanwen/zuowen/0f5250d26a190ed14f347402d9967299.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
本文word下载地址:搭建RocketMQ在本地IDEA开发调试环境教程.doc
本文 PDF 下载地址:搭建RocketMQ在本地IDEA开发调试环境教程.pdf
留言与评论(共有 0 条评论) |