RocketMq4 7原始碼解析之一 環境配置

2021-10-23 16:40:43 字數 2229 閱讀 7513

問題排查

設定檔案讀取位置

配置環境變數

啟動成功

注意:新版本不需要啟動的時候設定autocreatetopicenable = true;

分析原始碼可得

啟動報錯

配置環境變數

啟動成功

還需要分別設定

不說了,重啟電腦去的.

當記憶體撐爆後,我給c盤整理了5g記憶體,發現每次啟動broker失敗.後來分析原始碼

這個result每次返回false,造成執行緒直接退出.

後來刪除c:\users\administrator\store目錄下5g的訊息資料後,恢復正常.

設定brokerstartup配置檔案的讀取位置

-c e:\workspace\my\spring\rocketmq\distribution\conf2\conf\broker.conf

因為配置檔案配置了namesrvaddr=127.0.0.1:9876,所以環境變數namesrv_addr="localhost:9876"可以刪除了

brokerclustername = defaultcluster

brokername = broker-a

brokerid =

0deletewhen =

04filereservedtime =

48brokerrole = async_master

flushdisktype = async_flush

namesrvaddr=

127.0

.0.1

:9876

#儲存路徑

storepathrootdir = e:\\rocketmq\\store

#commitlog 儲存路徑

storepathcommitlog = e:\\rocketmq\\store\\commitlog

#消費佇列儲存路徑

storepathconsumequeue = e:\\rocketmq\\store\\consumequeue

#訊息索引|儲存路徑

storepathindex = e:\\rocketmq\\store\\index

#checkpoint 檔案儲存路徑

storecheckpoint = e:\\rocketmq\\store\\checkpoint

#abort 檔案儲存路徑

abortfile = e:\\rocketmq\\store\\abort

# 每個commitlog大小,預設為1g

mapedfilesizecommitlog =

1024

*1024

maxindexnum =

100diskmaxusedspaceratio=

95

除錯RocketMQ原始碼

拷貝namesrv broker的配置檔案到指定目錄,為了避免直接修改 中的配置檔案。1.1 在f盤建立rocketmq資料夾,建立三個子資料夾conf logs store,我的 中多了dev data的資料夾 1.2 將distribution原始碼conf目錄下的broker.conf log...

rocketmq原始碼打包步驟

1,從git上面轉殖好原始碼之後,進入rocketmq目錄,執行 mvn prelease all dskiptests clean install 2,打包完成之後,進入distribution target目錄,可以看到生成的包 第乙個是未壓縮的包,第二個是linux上面的壓縮包 第三個是win...

RocketMQ原始碼分析 訊息儲存

訊息儲存的地方,資料夾下有多個檔案,每個檔案的大小預設為1g 訊息的組成 欄位名 長度 備註totalsize 4 訊息的長度 magiccode 4 bodycrc 4 body的校驗碼 queueid 4 佇列id flag 4 queueoffset 8 儲存著佇列下訊息的數量,該值儲存在co...