rocketmq 源码调试

从rocketmq的github地址获取最新源码。在源码下载完后,执行mvn clean install -Dmaven.test.skip。稍等一段时间，可以看到代码编译成功。

源码调试

在项目根目录下创建3个目录conf,data和logs。将distribution目录下的broker.conf,logback_broker.xml和logback_namesrc.xml文件拷贝到conf目录下。

broker文件内容如下:

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH

#存储路径
storePathRootDir = /yourpath/rocketmq/data
#nameServer地址，分号分割
namesrvAddr = 127.0.0.1:9876

建议将logback_broker.xml、logback_namesrv.xml文件内容中的根目录改一下：

<!--将${user.home} 换成你的根目录-->
<appender name="DefaultAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
  <file>${user.home}/logs/rocketmqlogs/namesrv_default.log</file>
</appender>

• nameServer:
  • org.apache.rocketmq.namesrv.NamesrvStartup.main() 启动nameserver。启动时要加上环境变量ROCKETMQ_HOME=/yourpath/rocketmq。最好选择代码根目录作为HOME路径。
• broker:
  • org.apache.rocketmq.broker.BrokerStartup.main() 启动nameserver。启动时要加上环境变量ROCKETMQ_HOME=/yourpath/rocketmq。最好选择代码根目录作为HOME路径。
  • 指定程序参数 -c /yourpath/rocketmq/conf/broker.conf
• Producer & Consumer:
  • 指定环境变量NAMESRV_ADDR=127.0.0.1:9876
  • Producer 测试demo: org.apache.rocketmq.example.quickstart.Producer
  • Consumer 测试demo: org.apache.rocketmq.example.quickstart.Consumer

至此debug环境搭建完成了。