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消息队列(四) 消息的负载处理 ...