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
同時要把nsq的bin目錄(D:\nsq\bin)添加到系統(tǒng)環(huán)境變量中屯换。
2. 啟動nsqlookupd
新建一個CMD窗口1:
可以看到,nsqlookupd啟動之后与学,監(jiān)聽TCP 4160端口彤悔,用于管理nsqd服務;監(jiān)聽HTTP 4161端口索守,用于給nsqadmin提供服務晕窑。
3. 啟動nsqd
(1)再新建一個CMD窗口2,需指定要連接的nsqlookupd的地址和端口卵佛,這里我們就連接上一步已經啟動的nsqlookupd杨赤,地址即127.0.0.1:
nsqd連接成功nsqlookupd后,會初始化topic截汪、channal的元數據疾牲,獲取nsqlookupd信息。
(2)與此同時衙解,nsqlookupd的窗口1輸出:
表明新建一個客戶端連接:new client<127.0.0.1:64679>
(3)之后nsqd每隔15s向nsqlookupd發(fā)送一個心跳包说敏,表明nsqd處于在線狀態(tài),而nsqlookupd回復pinged丢郊。
窗口1:
窗口2:
- 往nsqd發(fā)布一條初始化消息
新建一個CMD窗口3(window上使用git bash),發(fā)布消息方法pub医咨,消息主題為test枫匾,消息內容為"hello world lee":
此時nsqd窗口2輸出表明新注冊一個主題test:
而nsqlookupd窗口1輸出:
此時并沒有任何通道channels來連接該主題topic,只是生產了消息拟淮,存在topic本身內部干茉。
- 新建channal來消費消息
(1)新建一個CMD窗口4:
這里我們用到nsq_to_file來消費topic為test的消息內容,并將其輸出到指定路徑(--output-dir=E:/tmp/)
打開該文件:
6. 用nsqadmin查看topic很泊、channal信息
(1)啟動nsqadmin角虫,新建一個CMD窗口5:
這時,nsqadmin進程已經啟動了委造。
(2)打開nsqadmin界面
瀏覽器輸入:127.0.0.1:4171
轉載地址