NSQ訊息佇列

2021-09-13 14:14:32 字數 874 閱讀 3418

前面的總結中提到過這個玩意,所以簡單說說,win上面的測試驗證

網上有比較合適的博文,我先推薦幾篇

我在簡化一下,給大家說說幾個win什麼的東西。

核心元件:

nsqd.exe 該元件負責接收資料和**資料。生產者發布資料到這裡,消費者來這裡取資料。

類似集群部署元件

輔助工具

nsqadmin.exe  該元件在訊息系統中沒有作用,只是乙個輔助工具,提供乙個網頁介面方便檢視主題資訊,該元件從nsqlookupd獲取主題資料並且展示。你可以簡單理解成這是乙個小web,為你提供資訊。

在win上,預設啟動是這樣的。

這就是大概情況。結合c#的客戶端nsqcsharp,給大家解釋下。

1.生產者

客戶端例子:

var producer = new producer("127.0.0.1:4150");

producer.publish("test-topic-name", "hello!");

說明:nsqd啟動,看圖,tcp的預設埠是4150,生產者直接將資料推出。

2.消費者

var consumer = new consumer("test-topic-name", "channel-name");

consumer.addhandler(new messagehandler());

consumer.connecttonsqlookupd("127.0.0.1:4161"); 

上面這種方式,生產者直接連線nsqd,消費者先通過nsqlookupd獲取nsqd,然後再連線,是nsq官方推薦的方式。

nsq(訊息佇列)

搭建服務 啟動 nsqd 指定 broadcast address 127.0 0nsqd broadcast address 127.0 0.1 1.啟動 nsqlookupd 命令 nsqlookupd 2.啟動nsqd 命令 nsqd broadcast address 127.0 0.1 l...

golang訊息佇列nsq

golang訊息佇列nsq win下安裝 追加i nsq 1.2.0.windows amd64.go1.12.9 bin 2.開啟命令視窗,執行 nsqlookupd 3.開啟新的命令視窗,執行 nsqd lookupd tcp address 127.0.0.1 4160 此處4160是nsqd...

Golang訊息佇列之NSQ

目錄nsq安裝 nsq是乙個實時分布式訊息傳遞平台,設計用於大規模操作,能每天處理數十億條訊息。它促進了沒有單點故障的分布式和分散拓撲,支援容錯和高可用性,並提供可靠的訊息傳遞保證。優缺點 優點 1 部署非常方便,沒有任何環境的依賴,乙個二進位制可執行檔案 2 輕量級沒有過多的配置引數,只需要簡單配...