【MQ-Apache|RocketMQ-初体验RocketMQ(08)-IDEA拉取调测RocketMQ源码
文章目录
- 从Git上迁出源码
- 修改源码,启动namersrv
- 修改源码,启动broker

文章图片
从Git上迁出源码

文章图片
Github: https://github.com/apache/rocketmq/
【【MQ-Apache|RocketMQ-初体验RocketMQ(08)-IDEA拉取调测RocketMQ源码】

文章图片
clone ,等待…

文章图片
完成后,如下

文章图片
修改源码,启动namersrv

文章图片
需要ROCKETMQ_HOME , 这里可以通过配置IDEA的方式,也可以通过修改源码直接setRocketmqHome,我们选择后者
修改
org.apache.rocketmq.namesrv.NamesrvStartup#createNamesrvController
namesrvConfig.setRocketmqHome("D:\\IdeaProjects\\rocketmqSource\\rocketmq\\distribution")

文章图片
修改工程参数 ,启动namesrv

文章图片

文章图片
参数 :
‐n localhost:9876 &
启动namesrv ,如下

文章图片
修改源码,启动broker 同样的,也需要设置RocketMQ_HOME,我们也通过修改源码的方式来调整
修改
org.apache.rocketmq.broker.BrokerStartup#createBrokerController
brokerConfig.setRocketmqHome("D:\\IdeaProjects\\rocketmqSource\\rocketmq\\distribution");

文章图片
启动参数设置

文章图片
‐n localhost:9876 ‐c D:\IdeaProjects\rocketmqSource\rocketmq\distribution\confbroker.conf &

文章图片
启动broker

文章图片
推荐阅读
- 【MQ-Apache|RocketMQ-初体验RocketMQ(02)_单节点RocketMQ的安装
- 【MQ-Apache|RocketMQ-初体验RocketMQ(04)_使用RocketMQ Console源码搭建RocketMQ Console与基本使用
- 【MQ-Apache|RocketMQ-初体验RocketMQ(03)_RocketMQ多机集群部署