RocketMQ源码解析：如何在IDEA中调试RocketMQ源码

RocketMQ源码解析：如何在IDEA中调试RocketMQ源码

配置RocketMQ运行时环境

首先从github-rocketmq源码：nameserver的地址namesrvAddr = 127.0.0.1:9876# 这是存储路径，你设置为你的rocketmq运行目录的store子目录storePathRootDir = /Users/peng/software/rocketmq/store# 这是commitLog的存储路径storePathCommitLog = /Users/peng/software/rocketmq/store/commitlog# consume queue文件的存储路径storePathConsumeQueue = /Users/peng/software/rocketmq/store/consumequeue# 消息索引文件的存储路径storePathIndex = /Users/peng/software/rocketmq/store/index# checkpoint文件的存储路径storeCheckpoint = /Users/peng/software/rocketmq/store/checkpoint# abort文件的存储路径abortFile = /Users/peng/software/rocketmq/abort

启动NameServer

启动Broker

-c /Users/peng/software/rocketmq/conf/broker.conf

启动即可

测试

在org.apache.rocketmq.example.quickstart.Producer这个类中，增加一行代码指定nameserver的地址，然后就能正常发送消息

在org.apache.rocketmq.example.quickstart.Consumer这个类中，增加一行代码指定nameserver的地址，然后就能正常接收消息

参考博客

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。