除錯RocketMQ原始碼

拷貝namesrv、broker的配置檔案到指定目錄，為了避免直接修改**中的配置檔案。

1.1 在f盤建立rocketmq資料夾，建立三個子資料夾conf、logs、store，我的**中多了dev data的資料夾

1.2 將distribution原始碼conf目錄下的broker.conf、logback_broker.xml、logback_namesrv.xml拷貝到新建的conf目錄下

1.3 修改拷貝的broker.conf檔案，如下所示，注意：一定要使用雙斜槓\\或者使用單斜槓/，因為多了dev data資料夾，中間有空格

brokerclustername = defaultcluster

brokername = broker-a
brokerid =
0namesrvaddr=
127.0
.0.1
:9876
deletewhen =
04filereservedtime =
48brokerrole = async_master
flushdisktype = async_flush
storepathrootdir=f:\\dev data\\rocketmq\\store
storepathcommitlog=f:\\dev data\\rocketmq\\store\\commitlog
storepathconsumequeue=f:\\dev data\\rocketmq\\store\\consumequeue
storepathindex=f:\\dev data\\rocketmq\\store\\index
storecheckpoint=f:\\dev data\\rocketmq\\store\\checkpoint
abortfile=f:\\dev data\\rocketmq\\store\\abort
"info"

/>
"stdout"
/>
……<
/root>

啟動org.apache.rocketmq.broker.brokerstartup，指定program arguments的值：-c "f:\\dev data\\rocketmq\\conf\\broker.conf"，指定environment variables的值：rocketmq_home=f:\\dev data\\rocketmq。注意：由於多了dev data資料夾，中間有空格，所以program arguments加了雙引號

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...

RocketMQ 位移提交原始碼分析

rocketmq 訊息消費進度是如何提交的，併發消費的時候，一次從 乙個佇列拉 32 條訊息，這 32 條訊息會提交到執行緒池中處理，如果偏移量 m5 比 m4 先執行完成，訊息消費後，提交的消費進度是哪個？是提交訊息 m5 的偏移量？下面跟著我的節奏，擼一波原始碼。rocketmq 每次拉取完訊息...