NSQ学习之生产者和消费者demo

前提条件是NSQ服务已经启动并且正常运行

下面是代码:

代码下载地址

代码截图:

QQ截图20150811164301

NSQ中有topic和channel的概念,生产者生产topic,消费者消费的时候,两个消费者连接同一个topic和channel只有一个消费者会获得物料,同一个topic不同的channel两个消费者都会获得物料,NSQ通过这样的机制可以实现多播和分发。

NSQ 的安装和配置文件启动

一、安装

NSQ 的安装有多种方式:

  1. 下载官方的二进制包,下载地址(支持Linux和Darwin),最新的版本是0.3.5。
  2. 下载源代码后自己编译,可以安装gpm帮助下载依赖包,详细请看安装指导

主要文件有:

  • nsqadmin(提供web页面供查看信息)
  • nsqd  (接收,传送和发送消息)
  • nsqlookupd  (管理拓扑信息)
  • nsq_pubsub  (this和以下都是工具类)
  • nsq_stat
  • nsq_tail
  • nsq_to_file
  • nsq_to_http
  • nsq_to_nsq
  • to_nsq

二、配置

配置文件百度云盘下载解压后有两个目录,bin和conf目录,关注conf文件夹下面的三个配置文件:

  • nsqd.cfg
  • nsqlookupd.cfg
  • nsqadmin.cfg

命令:**** -config=***.cfg 就可以通过配置文件的方式启动NSQ的相关服务。

如果nsqlookupd有多个服务,nsqd.cfg的配置可以如下修改:

nsqlookupd_tcp_addresses = [

“127.0.0.1:4160”,

“192.168.1.*:4160”,

….

]

下面这种拓扑结构,可以修改配置文件实现。

tumblr_inline_mf8sfr2sp41qj3yp2