13篇文章 · 2659字 · 3人關(guān)注
-
nsq 消息隊列設(shè)計消息傳遞設(shè)計 nsqlookupd：作用類似nsqd的注冊中心僧界，也復(fù)制給消費者提供nsqd地址 nsqd：管理topic和channel的守護(hù)進(jìn)...
-
nsq源碼(12) nsqd 延時消息的投遞
除了常規(guī)的PUB指令發(fā)布消息爷光，nsq還支持延遲投遞，例如發(fā)布一個延時消息：30秒后自動斷開連接 支持DPUB延時投遞消息 雖然官方文檔中nsqd...
-
nsq源碼(10) nsqlookupd 注冊nsqd
nsqlookupd 總共支持4種指令執(zhí)行合蔽，分別是PING料皇、IDENTIFY、REGISTER涡匀、UNREGISTER nsqlookupd運行日...
-
nsq源碼(11) nsqlookupd與消費者交互
nsq一共提供了幾種消費者客戶端工具：nsq_to_file盯腌、nsq_to_http、nsq_to_nsq nsq_to_file 消息寫入文件...
-
nsq源碼(8) 生產(chǎn)和消費流程
總覽nsqd陨瘩、nsqlookupd的啟動過程腕够，消息的生產(chǎn)到消費的過程 綁定注冊 nsqd --lookupd-tcp-address=127.0...
-
nsq源碼(9) nsqlookupd與nsqd交互
nsqlookupd與nsq交互 nsqd帶參數(shù)啟動 除了接收pub發(fā)布的topic级乍，還可以通過硬盤備份的文件恢復(fù)創(chuàng)建topic 在nsqd啟動...
-
nsq源碼(7) nsqd messageID
messageID 消息唯一標(biāo)識 GenerateID()返回ID NewGUID()生成ID
-
nsq源碼(6) nsqd 通知消息完成
通知nsqd執(zhí)行完成操作 在客戶端接收到消息并處理完成之后，按照協(xié)議會向nsqd 發(fā)送一個 "FIN" 命令通知nsqd帚湘，移除隊列信息
-
nsq源碼(5) nsqd 消息投遞
保證成功投遞 nsq保證了"至少一次"成功投遞玫荣，而不是僅一次 通過client.subChannel.StartInFlightTimeout(...
