NSQ的消息訂閱發布測試


在測試NSQ的Quick Start發現這樣一個問題,就是同時只能有一個訂閱實例

$ nsq_to_file --topic=test --output-dir=/tmp --lookupd-http-address=127.0.0.1:4161 

當存在兩個實例時則消息會被發送給其中的一個實例,而另一個則獲取不到消息

在閱讀到NSQ中NSQD的啟動參數時,發現其支持在一個topic下建立多個channel,通過向topic發送消息,會向所有的channel發布。

測試

//創建topic
$ curl http://10.191.197.209:4151/create_topic?topic=public

//創建三個channel

$ curl http://10.191.197.209:4151/create_channel?topic=public\&channel=t1
$ curl http://10.191.197.209:4151/create_channel?topic=public\&channel=t2
$ curl http://10.191.197.209:4151/create_channel?topic=public\&channel=t3

//建立nsqdata t1 t2 t3四個文件夾分別存放nsqd數據及三個測試channel數據
mkdir nsqdata t1 t2 t3

//啟動nsqd,nsqd可以獨立啟動,無需啟動nsqlookupd
nsqd -data-path=/home/sunsl/nsqdata

//啟動三個channel的接收端,這里使用nsq_to_file監聽nsqd的tcp端口
nsq_to_file --topic=public --channel=t1 --output-dir=/home/sunsl/t1 --nsqd-tcp-address=127.0.0.1:4150
nsq_to_file --topic=public --channel=t2 --output-dir=/home/sunsl/t2 --nsqd-tcp-address=127.0.0.1:4150
nsq_to_file --topic=public --channel=t3 --output-dir=/home/sunsl/t3 --nsqd-tcp-address=127.0.0.1:4150

//向public發送測試數據
curl -d '向三個channel發送數據' 'http://10.191.197.209:4151/put?topic=public'
//cat t1,t2,t3文件夾下的log文件,數據顯示正常獲取

 

問題

  • 接收數據有延遲,原因未知,待查


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM