1. nsq安裝
下載地址: http://nsq.io/deployment/installing.html
目前的穩(wěn)定版是V1.0.0-compat,由于在window平臺上安裝,所以選擇:
nsq-1.0.0-compat.windows-amd64.go1.8.tar.gz
下載之后解壓到某目錄,這里是放在D盤 D:\nsq
同時(shí)要把nsq的bin目錄(D:\nsq\bin)添加到系統(tǒng)環(huán)境變量中。
2. 啟動nsqlookupd
新建一個(gè)CMD窗口1:

可以看到,nsqlookupd啟動之后,監(jiān)聽TCP 4160端口,用于管理nsqd服務(wù);監(jiān)聽HTTP 4161端口,用于給nsqadmin提供服務(wù)。
3. 啟動nsqd
(1)再新建一個(gè)CMD窗口2,需指定要連接的nsqlookupd的地址和端口,這里我們就連接上一步已經(jīng)啟動的nsqlookupd,地址即127.0.0.1:
nsqd連接成功nsqlookupd后,會初始化topic、channal的元數(shù)據(jù),獲取nsqlookupd信息。
(2)與此同時(shí),nsqlookupd的窗口1輸出:

表明新建一個(gè)客戶端連接:new client<127.0.0.1:64679>
(3)之后nsqd每隔15s向nsqlookupd發(fā)送一個(gè)心跳包,表明nsqd處于在線狀態(tài),而nsqlookupd回復(fù)pinged。
窗口1:

窗口2:

- 往nsqd發(fā)布一條初始化消息
新建一個(gè)CMD窗口3(window上使用git bash),發(fā)布消息方法pub,消息主題為test,消息內(nèi)容為"hello world lee":

此時(shí)nsqd窗口2輸出表明新注冊一個(gè)主題test:

而nsqlookupd窗口1輸出:

此時(shí)并沒有任何通道channels來連接該主題topic,只是生產(chǎn)了消息,存在topic本身內(nèi)部。
- 新建channal來消費(fèi)消息
(1)新建一個(gè)CMD窗口4:

這里我們用到nsq_to_file來消費(fèi)topic為test的消息內(nèi)容,并將其輸出到指定路徑(--output-dir=E:/tmp/)

打開該文件:

6. 用nsqadmin查看topic、channal信息
(1)啟動nsqadmin,新建一個(gè)CMD窗口5:

這時(shí),nsqadmin進(jìn)程已經(jīng)啟動了。
(2)打開nsqadmin界面
瀏覽器輸入:127.0.0.1:4171
轉(zhuǎn)載地址