NSQ源码剖析之nsqd
NSQ简介 NSQ 是实时的分布式消息处理平台，其设计的目的是用来大规模地处理每天数以十亿计级别的消息。NSQ 具有分布式和去中心化拓扑结构，该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征，是一个成熟的、已在大规模生成环境下应用的产品。 NSQ 由 3 个守护进程 ...
原文：nsq源码阅读笔记之nsqd（四）——Channel
与Channel相关的代码主要位于nsqd channel.go,nsqd nsqd.go中。 Channel与Topic的关系 Channel是消费者订阅特定Topic的一种抽象。对于发往Topic的消息，nsqd向该Topic下的所有Channel投递消息，而同一个Channel只投递一次，Channel下如果存在多个消费者，则随机选择一个消费者做投递。这种投递方式可以被用作消费者负载均衡。 ...
2017-08-31 10:44 0 1084 推荐指数：
相关推荐
go笔记 NSQ (6) ( nsqd如何创建消费者以及消费消息)
前面几章中可以看到，nsq进行消息消费的时候主要使用tcpServer去处理，也就是如下的方法 func (p *tcpServer) Handle(clientConn net.Conn) { p.ctx.nsqd.logf(LOG_INFO, "TCP: new ...
golang channel源码阅读
(年初的时候go语言的学习提上了日程，前一篇sync.pool阅读之后，阅读代码进度本该更快些，奈何身体被掏空，所以这篇文章断断续续一个月终于攒起来了。) 目录 简介 数据部分 hchan 参数意义 ...
NSQ源码剖析(一)：NSQD主要结构方法和消息生产消费过程
目录 1 概述 2 主要结构体及方法 2.1 NSQD 2.2 tcpServer 2.3 protocolV2 2.4 clientV2 2.5 Topic 2.6 channel 3 启动 ...
go笔记 NSQ (5) ( nsqd如何监听生产者的消息，select关键字使用)
本节主要来探究nsq如何监听生产者的消息。 通过上节我们得知nsq接收消息发送主要是靠下面这个http处理器 当然了也可以通过原生tcp的方式进行消息发送，由于具体处理流程类似，所以文末会有提到。 router.Handle("POST", "/pub ...
nsq topic和channel的区别
topic:一个可供订阅的话题。channel:属于topic的下一级，一个topic可以有多个channel。二者关系可以再参考下面两文章：http://www.cnblogs.com/forrestsun/p/3892710.htmlhttp://www.linuxeden.com/html ...
[阅读笔记]fsnotify源码阅读
fsnotify的github地址是 https://github.com/howeyc/fsnotify fsnotify是一个文件夹监控应用。可以使用创建一个w ...
nsq的消费者通过nsqlookup连接nsqd发生的timeout的错误
报错如下： 要弄明白这个错误，我们就得知道它的原因 在nsq中，如果消费者通过nsqlookup去连接nsqd从而获取消息中的数据，那个他的过程是如下的： 首先启动一个nsqlookup节点，用来维护，管理，发现nsqd节点 然后启动nsqd节点，nsqd节点启动的时候需要 ...