在測試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文件,數據顯示正常獲取
問題
- 接收數據有延遲,原因未知,待查
