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與lookupd進行tcp連線的埠
4. 開啟新的命令視窗，執行： nsqadmin --lookupd-http-address=127.0.0.1:4161 //此處4161是nsqadmin與lookupd進行http連線的埠

//nsqd的位址，使用了tcp監聽的埠

tcpnsqdaddrr = "

127.0.0.1:4150")

func main()

//主題

topic := "

insert"//

主題內容

tcommand := "

new data!"//

發布訊息

err = tpro.publish(topic, byte

(tcommand))

if err !=nil }}

執行如上**

生產了100個

接下來消費

//nsqd的位址，使用了tcp監聽的埠

tcpnsqdaddrr = "

127.0.0.1:4150")

//宣告乙個結構體，實現handlemessage介面方法（根據文件的要求）

type nsqhandler struct

//實現handlemessage方法

//message是接收到的訊息

func (s *nsqhandler) handlemessage(message *nsq.message) error

func main()

//新增處理**

com.addhandler(&nsqhandler)

//連線對應的nsqd

err =com.connecttonsqd(tcpnsqdaddrr)

if err !=nil

//只是為了不結束此程序，這裡沒有意義

這個nsq 問題有點多 建議不要用

Golang訊息佇列之NSQ

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

NSQ訊息佇列

前面的總結中提到過這個玩意，所以簡單說說，win上面的測試驗證 網上有比較合適的博文，我先推薦幾篇 我在簡化一下，給大家說說幾個win什麼的東西。核心元件 nsqd.exe 該元件負責接收資料和 資料。生產者發布資料到這裡，消費者來這裡取資料。類似集群部署元件 輔助工具 nsqadmin.exe 該...

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...