RocketMQ原始碼閱讀(1) 環境搭建

2021-09-26 21:29:38 字數 2245 閱讀 7387

# nameserver位址,分號分割

namesrvaddr=127.0.0.1:9876

# 儲存路徑

storepathrootdir=d:\\rocketmq\\store

# commitlog 儲存路徑

storepathcommitlog=d:\\rocketmq\\store\\commitlog

# 消費佇列儲存路徑

storepathconsumequeue=d:\\rocketmq\\store\\consumequeue

# 訊息索引儲存路徑

storepathindex=d:\\rocketmq\\store\\index

# checkpoint 儲存路徑

storecheckpoint=d:\\rocketmq\\store\\checkpoint

# abort檔案儲存路徑

producer.setnamesrvaddr("127.0.0.1:9876");
然後執行該類的main方法,有如下響應證明訊息傳送成功:

sendresult [sendstatus=send_ok, msgid=c0a8008149ac18b4aac2189669d503e7, offsetmsgid=c0a8380100002a9f000000000002e11d, messagequeue=messagequeue [topic=topictest, brokername=broker-a, queueid=0], queueoffset=249]
consumer.setnamesrvaddr("127.0.0.1:9876");
然後執行該類的main方法,有如下響應證明訊息消費成功:

consumemessagethread_12 receive new messages: [messageext [queueid=1, storesize=189, queueoffset=239, sysflag=0, borntimestamp=1567679710658, bornhost=/192.168.56.1:55552, storetimestamp=1567679710658, storehost=/192.168.56.1:10911, msgid=c0a8380100002a9f000000000002c15e, commitlogoffset=180574, bodycrc=730101603, reconsumetimes=0, preparedtransactionoffset=0, tostring()=message, body=[80, 114, 111, 100, 117, 99, 101, 114, 45, 72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 53, 54], transactionid='null'}]]

openstack原始碼閱讀筆記1 開發環境搭建

openstack原始碼閱讀筆記1 開發環境搭建 以下是windows7的環境,大體步驟如下 先裝python 2.7.12 和git客戶端工具,python ide乙個,pycharm或是eclipse pydev 1.git clone相應的倉庫,如cinder元件的。2.先用virtualen...

除錯RocketMQ原始碼

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

OpenCV原始碼閱讀 1

開始從讀取檔案的函式說起,這裡主要有兩個函式用於讀取影象的 實際上,當我們在做數字影象處理系統的時候,主要要考慮的也是怎麼讀乙個進來。第乙個函式 cvloadimage主要是用於返回乙個iplimage 的資料結構。第二個函式 cvloadimagem主要是用於返回乙個cvmat 的資料結構。實際上...