一、下载源码 --- 目前是windows

进入https://github.com/apache/rocketmq地址拿到rocketmq git的地址

image.png

打开idea 操作如下

image.png

image.png

等待代码下载完毕后执行 maven命令 mvn(maven) clean install，进行编译和下载依赖，当看到控制台BULID SUCCESS 信息，说明编译成功，即可进行下一步

二、启动namesrc和broker进行消息的生产和消费

1. 启动namesrv
   
   image.png
   
   当前页右键后显示如下图，点击debug 'NameSrvStartup.main()'
   
   image.png
   
   然后右上角操作如下
   
   image.png
   
   然后为当前这个要执行的main函数添加环境变量,如下图
   
   image.png
   
   创建三个目录如下图
   
   image.png
   
   从distribution目录下copy broker.conf、logback_broker.xml、logback_namesrc.xml文件到conf目录下，见下图
   
   image.png
   
   broker.conf文件代码如下

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
#nameServer地址，分号分割
namesrvAddr = 127.0.0.1:9876
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
#存储路径
storePathRootDir = D:\\code\\own\\rocketmq\\storeOwn
#commitLog 存储路径
storePathCommitLog=D:\\code\\own\\rocketmq\\storeOwn\\commitLog
#消费队列存储路径
storePathConsumeQueue=D:\\code\\own\\rocketmq\\storeOwn\\consumequeue
#消息索引存储路径
storePathIndex=D:\\code\\own\\rocketmq\\storeOwn\\index
#checkpoint 文件存储路径
storeCheckPoint=D:\\code\\own\\rocketmq\\storeOwn\\checkpoint
#abort 文件存储路径
abortFile=D:\\code\\own\\rocketmq\\storeOwn\\abort

建议将logback_broker.xml、logback_namesrc.xml文件内容中的根目录改一下，方便看相关日志

image.png

image.png

2. 启动broker，流程和namesrv的启动差不多
   
   image.png
   
   
   image.png
   
   再次使用debug启动BrokerStartUp.main 函数，显示如下图，启动成功
   
   image.png
   
   以下是borker的启动日志
   
   image.png
3. 使用rocketmq 提供的示例代码发送消息和消费消息
   设置生产者、消费者的namesrvAddr 端口默认是9876，也可以自己设置
   
   [图片上传中...(image.png-3c5ec8-1551506179828-0)]
   
   
   image.png
   
   运行生产者、消费者，截图如下，表示成功
   
   image.png
   
   
   image.png

接下来就可以随意调试rocketmq的任意代码了