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

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

image.png

打开idea 操作如下

image.png

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

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

启动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
运行NamesrvStartup下的main函数，输出如下图，说明启动成功

image.png

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