快捷導(dǎo)航

使用Idea調(diào)試RocketMQ源碼教程

更新時(shí)間：2022年11月16日 09:05:28 作者：夢(mèng)想實(shí)現(xiàn)家_Z

這篇文章主要為大家介紹了使用Idea調(diào)試RocketMQ源碼教程詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

為了更好地了解RocketMQ，我打算看一看它的源碼了。隨著RocketMQ5.0版本的發(fā)布，應(yīng)該有更多小伙伴在實(shí)際應(yīng)用中選擇RocketMQ。那么我們就從這一篇文章開始，逐步來(lái)了解RocketMQ的神秘源碼吧！接下來(lái)我們先把調(diào)試環(huán)境搭建好。

下載源碼

源碼地址：github.com/apache/rock…

我們先把RocketMQ源碼下載下來(lái)，為了方便一點(diǎn)，建議小伙伴先f(wàn)ork到自己的倉(cāng)庫(kù)，然后再通過(guò)git拉下來(lái)。

導(dǎo)入idea

我們通過(guò)idea把下載的源碼導(dǎo)入：

有任何報(bào)紅或者錯(cuò)誤先不用管。

代碼編譯

不要直接打開namesrv找到main函數(shù)就運(yùn)行，這樣是跑不起來(lái)的，會(huì)產(chǎn)生以下錯(cuò)誤：

我們找到源碼所在的本地目錄，或者直接在項(xiàng)目中打開Terminal:

首先執(zhí)行java -version檢查安裝的java版本，建議該版本不能超過(guò)java 11，測(cè)試下來(lái)java 17是編譯不了的。

如果版本沒問(wèn)題的話，執(zhí)行mvn clean install -DskipTests編譯該項(xiàng)目。

編譯成功后，結(jié)果如下：

運(yùn)行namesrv

設(shè)置ROCKETMQ_HOME

在啟動(dòng)namesrv之前，我們要先設(shè)置以下對(duì)應(yīng)的環(huán)境變量ROCKETMQ_HOME，這個(gè)變量可以直接在啟動(dòng)配置里面設(shè)置。namesrv在啟動(dòng)的時(shí)候就會(huì)去ROCKETMQ_HOME/conf里面去找相應(yīng)的配置，比如logback_namesrv.xml。

添加logback_namesrv.xml
我們拉下來(lái)的項(xiàng)目中已經(jīng)有現(xiàn)成的logback_namesrv.xml，所以我們只需要拷貝一下。從distribution/conf里面就可以找到logback_namesrv.xml，直接拷貝到我們指定的ROCKETMQ_HOME/conf路徑中。

啟動(dòng)

直接在idea中點(diǎn)擊run或者debug啟動(dòng)namesrv服務(wù)。

啟動(dòng)broker

設(shè)置環(huán)境變量ROCKETMQ_HOME和配置文件

同樣的我們需要設(shè)置環(huán)境變量ROCKETMQ_HOME，目的和namesrv一樣，是為了讀取日志配置文件；另一個(gè)-c xx/xx/broker.conf是為了指定服務(wù)的配置文件。

配置文件

我們的broker啟動(dòng)需要兩個(gè)配置文件，一個(gè)是日志配置文件logback_broker.xml，一個(gè)是broker.conf配置。這兩個(gè)配置文件我們都可以從項(xiàng)目中的distribution/conf中找到，我們把找到的兩個(gè)文件放到指定的路徑下。broker.conf文件需要做一些簡(jiǎn)單的修改：

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# namesrv服務(wù)地址
namesrvAddr = 127.0.0.1:9876
# 運(yùn)行自動(dòng)創(chuàng)建topic，避免調(diào)試的時(shí)候麻煩
autoCreateTopicEnable = true
# 數(shù)據(jù)存儲(chǔ)路徑
storePathRootDir = /Users/zouwei/Documents/projects/github_project/rocketmq/data_store
# commitlog存儲(chǔ)文件
storePathCommitLog = /Users/zouwei/Documents/projects/github_project/rocketmq/data_store/commitlog
# 消費(fèi)隊(duì)列存儲(chǔ)文件
storePathConsumeQueue = /Users/zouwei/Documents/projects/github_project/rocketmq/data_store/consumequeue
# 索引存儲(chǔ)文件
storePathIndex = /Users/zouwei/Documents/projects/github_project/rocketmq/data_store/index
# checkpoint存儲(chǔ)文件
storeCheckpoint = /Users/zouwei/Documents/projects/github_project/rocketmq/data_store/checkpoint
# abort文件
abortFile = /Users/zouwei/Documents/projects/github_project/rocketmq/data_store/abort

小伙伴們需要根據(jù)自己的實(shí)際情況來(lái)修改上述配置。

啟動(dòng)broker

接下里，我們就可以通過(guò)idea來(lái)啟動(dòng)broker了，點(diǎn)擊run或者debug按鈕，最后broker啟動(dòng)成功。

為了更好地看到啟動(dòng)效果和相關(guān)配置，小伙伴們可以適當(dāng)修改一下logback_broker.xml：

    <logger name="RocketmqBroker" additivity="false">
        <level value="INFO"/>
        <appender-ref ref="STDOUT"/>
        <appender-ref ref="RocketmqBrokerAppender"/>
    </logger>

在RocketmqBroker里面加上<appender-ref ref="STDOUT"/>，這樣我們就可以在控制臺(tái)中看到相關(guān)的日志了。