从Git上迁出源码
Github: https://github.com/apache/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