rocketmq 源码调试

rocketmq 源码调试

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

源码调试

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

broker文件内容如下:

1
2
3
4
5
6
7
8
9
10
11
12
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_namesrc.xml文件内容中的根目录改一下:

1
2
3
4
<!--将${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环境搭建完成了。

-------------本文结束感谢您的阅读-------------
坚持分享,您的支持将鼓励我继续创作!
0%