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 | brokerClusterName = DefaultCluster |
建议将logback_broker.xml、logback_namesrv.xml文件内容中的根目录改一下:
1 | <!--将${user.home} 换成你的根目录--> |
- 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环境搭建完成了。