一、下載源碼 --- 目前是windows

進(jìn)入https://github.com/apache/rocketmq地址拿到rocketmq git的地址

image.png

打開idea 操作如下

image.png

等待代碼下載完畢后執(zhí)行 maven命令 mvn(maven) clean install，進(jìn)行編譯和下載依賴，當(dāng)看到控制臺(tái)BULID SUCCESS 信息，說明編譯成功，即可進(jìn)行下一步

二、啟動(dòng)namesrc和broker進(jìn)行消息的生產(chǎn)和消費(fèi)

啟動(dòng)namesrv

image.png

當(dāng)前頁(yè)右鍵后顯示如下圖，點(diǎn)擊debug 'NameSrvStartup.main()'

image.png

然后右上角操作如下

image.png

然后為當(dāng)前這個(gè)要執(zhí)行的main函數(shù)添加環(huán)境變量,如下圖

image.png

創(chuàng)建三個(gè)目錄如下圖

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地址，分號(hào)分割
namesrvAddr = 127.0.0.1:9876
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
#存儲(chǔ)路徑
storePathRootDir = D:\\code\\own\\rocketmq\\storeOwn
#commitLog 存儲(chǔ)路徑
storePathCommitLog=D:\\code\\own\\rocketmq\\storeOwn\\commitLog
#消費(fèi)隊(duì)列存儲(chǔ)路徑
storePathConsumeQueue=D:\\code\\own\\rocketmq\\storeOwn\\consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=D:\\code\\own\\rocketmq\\storeOwn\\index
#checkpoint 文件存儲(chǔ)路徑
storeCheckPoint=D:\\code\\own\\rocketmq\\storeOwn\\checkpoint
#abort 文件存儲(chǔ)路徑
abortFile=D:\\code\\own\\rocketmq\\storeOwn\\abort

建議將logback_broker.xml、logback_namesrc.xml文件內(nèi)容中的根目錄改一下，方便看相關(guān)日志

image.png

運(yùn)行NamesrvStartup下的main函數(shù)，輸出如下圖，說明啟動(dòng)成功

image.png

啟動(dòng)broker，流程和namesrv的啟動(dòng)差不多

image.png

image.png

再次使用debug啟動(dòng)BrokerStartUp.main 函數(shù)，顯示如下圖，啟動(dòng)成功

image.png

以下是borker的啟動(dòng)日志

image.png
使用rocketmq 提供的示例代碼發(fā)送消息和消費(fèi)消息
設(shè)置生產(chǎn)者、消費(fèi)者的namesrvAddr 端口默認(rèn)是9876，也可以自己設(shè)置

[圖片上傳中...(image.png-3c5ec8-1551506179828-0)]

image.png

運(yùn)行生產(chǎn)者、消費(fèi)者，截圖如下，表示成功

image.png

image.png