NSQ源碼剖析(一)：NSQD主要結構方法和消息生產消費過程
目錄 1 概述 2 主要結構體及方法 2.1 NSQD 2.2 tcpServer 2.3 protocolV2 2.4 clientV2 2.5 Topic 2.6 channel 3 啟動 ...
原文：NSQ源碼剖析之nsqd
NSQ簡介 NSQ 是實時的分布式消息處理平台，其設計的目的是用來大規模地處理每天數以十億計級別的消息。NSQ 具有分布式和去中心化拓撲結構，該結構具有無單點故障 故障容錯 高可用性以及能夠保證消息的可靠傳遞的特征，是一個成熟的 已在大規模生成環境下應用的產品。 NSQ 由 個守護進程組成：nsqd 是接收 保存和傳送消息到客戶端的守護進程。nsqlookupd 是管理的拓撲信息，維護着所有ns ...
2017-08-31 10:45 0 1129 推薦指數：
相關推薦
nsq源碼閱讀筆記之nsqd（四）——Channel
與Channel相關的代碼主要位於nsqd/channel.go, nsqd/nsqd.go中。 Channel與Topic的關系 Channel是消費者訂閱特定Topic的一種抽象。對於發往Topic的消息，nsqd向該Topic下的所有Channel投遞消息，而同一個Channel只投遞一次 ...
剖析nsq消息隊列(二) 去中心化源碼解析
剖析nsq消息隊列-目錄 在上一篇帖子剖析nsq消息隊列(一) 簡介及去中心化實現原理中，我介紹了nsq的兩種使用方式，一種是直接連接，還有一種是通過nslookup來實現去中心化的方式使用，並大概說了一下實現原理，沒有什么難理解的東西，這篇帖子我把nsq實現去中心化的源碼和其中的業物邏輯展示 ...
nsq的消費者通過nsqlookup連接nsqd發生的timeout的錯誤
報錯如下： 要弄明白這個錯誤，我們就得知道它的原因 在nsq中，如果消費者通過nsqlookup去連接nsqd從而獲取消息中的數據，那個他的過程是如下的： 首先啟動一個nsqlookup節點，用來維護，管理，發現nsqd節點 然后啟動nsqd節點，nsqd節點啟動的時候需要 ...
springboot項目整合nsq，消費者直連nsqd
項目需要用到nsq，並且是單點的，網上看到的springboot整合nsq都是先連接lookup后，從lookup獲取nsqd的連接信息。由於本項目用到了docker，映射的端口都不是原始端口了。而lookup分發的連接nsqd還是默認的4150端口。所以是連不通的。這時候需要直連nsqd ...
go筆記 NSQ (6) ( nsqd如何創建消費者以及消費消息)
前面幾章中可以看到，nsq進行消息消費的時候主要使用tcpServer去處理，也就是如下的方法 func (p *tcpServer) Handle(clientConn net.Conn) { p.ctx.nsqd.logf(LOG_INFO, "TCP: new ...
NSQ源碼剖析(二)：golang客戶端源碼及性能和故障分析
目錄 使用示例 配置參數 生產者Producer 總結 Producer結構體 Producer發布消息的方法介紹 Produc ...
剖析nsq消息隊列目錄
剖析nsq消息隊列(一) 簡介及去中心化實現原理 剖析nsq消息隊列(二) 去中心化源碼解析 剖析nsq消息隊列(三) 消息傳輸的可靠性和持久化[一] 剖析nsq消息隊列(三) 消息傳輸的可靠性和持久化[二]diskqueue 剖析nsq消息隊列(四) 消息的負載處理 ...