首先你需要有一个 nsq 的服务端，nsq 由三部分构成：nsqd、nsqlookupd、nsqadmin。go-nsq 是众多客户端中的一个，使用 golang 编写，我们在逻辑代码中写 Producer 和 Comsumer。producer，把数据序

我们可以将原本耦合、同步执行的程序 解耦成 生产端+ 消息队列+消费端模型的异步程序，加上分布式的生产者和消费者架构就可以在一定程度上支撑大并发。NSQ是go语言开发的消息队列，所以对nsqd进行水平扩展时它的部署、配置也会相对简单。如果熟悉golang的

这篇文章，我将会添加一个队列的功能。使用nsq需要知道以下几个概念：。nsqadmin：nsq的web管理组件；产生消息，需要指定该消息属于哪个topic的；nsq消费者与nsqd或者nsqlookupd建立一个channel，并监听channel中的消息

同一个topic下 不同channel分多个项目的时候,如果一个项目引用了别的项目包,那么被引用的项目就需要手动初始化mq,不能使用Init,因为会导致mq初始化两次,在一个channel下链接了两个消费者导致mq进行了负载均衡.

NSQ 消息队列实现消息落地使用的是 FIFO 队列。在NSQ 中， diskqueue 是一个实例化的 BackendQueue, 用于保存在内存放不下的消息 。是一个比较经典的队列的实现，值得学习。diskqueue 是 BackendQueue 的

注意其中tcp端口是给nsqd节点连接使用的,http则是给一些输出文件使用,比如数据经过节点会发送请求之类的。-address 表示lookupd的服务器ip地址在哪 端口号是lookupd 启动时开启的端口。// 除了第一个开启的节点只带lookupd

上两篇帖子主要说了一下nsq的拓扑结构，如何进行故障处理和横向扩展,保证了客户端和服务端的长连接，连接保持了，就要传输数据了，nsq如何保证消息被订阅者消费，如何保证消息不丢失，就是今天要阐述的内容。消息处理的大概流程:当一个消息被nsq接收后，传给相应的

介绍NSQ是一个实时的分布式消息平台。它的设计目标是为在多台计算机上运行的松散服务提供一个现代化的基础设施骨架。可以说， 如果不是因为我们在bitly使用go语言，NSQ就不会存在。这里既会讲NSQ的功能也会涉及语言提供的特征。当然，语言会影响思维，这次也

我是想把nsq系统完完整整的看一遍，从而对他形成一个更整体的认识。对message queue来说他的client端就是生产者和消费者，生产者负责想nsq中投递消息，消费者负责从lookupd中获取到指定nsqd之后，从nsqd中获取消息。// Publi

看完了nsqlookupd我们继续往下看, nsqd才是他的核心. 里面大量的使用到了go channel, 相信看完之后对你学习go有很大的帮助.相较于lookupd部分无论在代码逻辑和实现上都要复杂很多. 不过基本的代码结构基本上都是一样的, 进程使用

为什么选择nsq之前一直在用erlang做电信产品的开发，对erlang的一些生态也比较了解，和erlang相关的产品在互联网公司使用最多的应该就是rabbitmq了，也许很多人听说过erlang就是因为他们公司在使用rabbitmq。在之前也看过一点ra

在系列文章前面几篇中，介绍了 NSQ 改造的过程和几个基础特性，本文中我们继续介绍几个高级特性及其使用场景，这些都是结合有赞业务场景总结提炼出来的重要功能。相比较于 Kafka 等消息中间件，NSQ 的消息格式在内容和数量上较为简单。一条消息除了基本的元数

NSQ是Go语言编写的，开源的分布式消息队列中间件，其设计的目的是用来大规模地处理每天数以十亿计级别的消息。NSQ 具有分布式和去中心化拓扑结构，该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征，是一个成熟的、已在大规模生成环境下应

nsq源码学习简介nsq 是用go语言实现的分布式队列。阅读源码对go语言的chanel，分布式有着更好的理解。nsqd is the daemon that receives, queues, and delivers messages to clien

引言我们在这个系列第一篇文章中提到过，如果需要消息落地而对存储子系统的选择上，从速度上来说 文件系统>分布式KV（持久化）>分布式文件系统>数据库。而NSQ选择了文件系统作为存储子系统。这篇文章将重点介绍nsq 对于文件的操作。在内存的m

NSQ是由知名短链接服务商bitly用Go语言开发的实时消息处理系统，具有高性能、高可靠、无视单点故障等优点，是一个非常不错的新兴的消息队列解决方案。相关概念提到消息队列，我们先看一下消息队列的相关概念。以下主要参考 消息队列设计精要，我提取一些我认为重要

最近在研究一些消息中间件，常用的MQ如RabbitMQ,ActiveMQ,Kafka等。NSQ是一个基于Go语言的分布式实时消息平台，它基于MIT开源协议发布，由bitly公司开源出来的一款简单易用的消息中间件。NSQ提供了分布式的，去中心化，且没有单点故