# 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 的資料結構。實際上...