go-nsq使用简述

一 环境依赖:

  golang 开发环境(version >= 1.2) 下源码,配置环境变量,执行安装脚本

  gpm 依赖包管理器 ubantu: sudo apt-get intall gpm

二 NSQ安装:

  1. git获取源码: mkdir -p $GOPATH/src/github.com/nsqio;cd $GOPATH/src/github.com/nsqio;git clone https://github.com/nsqio/nsq.git;cd nsq
  2. 安装依赖包: gpm install
  3. 安装NSQ: go install ./...

三 开启NSQ:

  1. nsqd节点维护进程:nsqlookupd &
  2. nsqd节点进程:nsqd --lookupd-tcp-address=127.0.0.1:4160 &
  3. 消息产看进程:nsqadmin --lookupd-http-address=127.0.0.1:4161 &

ps:nsqlookupd与nsqadmin为辅助进程,可不使用直接用nsqd也可正常工作.

这里开启的进程均用默认的端口

四 工具测试:

  • curl -d 'hello world 1' 'http://127.0.0.1:4151/put?topic=test' // 产生一个topic为“test” 消息内容为“hello world”的消息
  • nsq_to_file --topic=test --output-dir=./tmp --lookupd-http-address=127.0.0.1:4161 // 将topic为“test”的消息写到./tmp目录下的一个文件中

五 代码测试:

package main
import (
    "fmt"
    "time"
    "github.com/nsqio/go-nsq"
)
// nsq发布消息
func Producer() {
    p, err := nsq.NewProducer("127.0.0.1:4150", nsq.NewConfig())                // 新建生产者
    if err != nil {
        panic(err)
    }   
    if err := p.Publish("test", []byte("hello NSQ!!!")); err != nil {           // 发布消息
        panic(err)
    }   
}
// nsq订阅消息
type ConsumerT struct{}
func (*ConsumerT) HandleMessage(msg *nsq.Message) error {
    fmt.Println(string(msg.Body))
    return nil 
}
func Consumer() {
    c, err := nsq.NewConsumer("test", "test-channel", nsq.NewConfig())   // 新建一个消费者
    if err != nil {
        panic(err)
    }   
    c.AddHandler(&ConsumerT{})                                           // 添加消息处理
    if err := c.ConnectToNSQD("127.0.0.1:4150"); err != nil {            // 建立连接
        panic(err)
    }   
}
// 主函数
func main() {
    Producer()
    Consumer()
    time.Sleep(time.Second * 3)
}
// 运行将会打印: hello NSQ!!!

六 使用总结:

  单机使用条件,同步发布消息速度也非常快(10w/s),发布消息端基本无需再做缓存封装。接收端的消息处理应耗时尽量的短,避免消息积累,当消息积累到NSQ的缓存的数量会将多余的消息写到文件,此时也会减缓发送端的发送速度,

  因此,对接收端可使用channel和go routine做简单封装处理。若某topic消息产生太快太多也可将其单独使用一个nsqd处理,避免消息积累影响其它消息投递与接收。

原文发布于微信公众号 - Golang语言社区(Golangweb)

原文发表时间:2016-09-08

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏散尽浮华

Centos6.X 下安装并使用VNC的操作记录

VNC是一个的"远程桌面"工具。,通常用于“图形界面”的方式登录服务器,可视化操作。废话不多说了,操作记录如下: 1)安装桌面环境 [root@vm01 ~]#...

3377
来自专栏Golang语言社区

go-nsq使用简述

一 环境依赖:   golang 开发环境(version >= 1.2) 下源码,配置环境变量,执行安装脚本   gpm 依赖包管理...

47810
来自专栏小狼的世界

Kubernetes基础:编排调度的那些Controllers

Kubernetes提供了很多Controller资源来管理、调度Pod,包括Replication Controller、ReplicaSet、Deploym...

1482
来自专栏zhisheng

SpringBoot RabbitMQ 整合使用

前提 上次写了篇文章,《SpringBoot Kafka 整合使用》,阅读量还挺高的,于是想想还是把其他几种 MQ 也和 SpringBoot 整合使用下。 下...

3159
来自专栏程序员同行者

14-使用glusterfs做持久化存储

1462
来自专栏何俊林

手把手图文并茂教你用Android Studio编译FFmpeg库并移植

之前曾写过一篇《FFmpeg在Linux下安装编译过程》,今天有空就用Android Studio编译FFmpeg库并移植,并附上调用ffmpeg简单示例,看下...

3656
来自专栏Flutter入门

偶遇FFmpeg(三)——Android集成

其实这部分,不比多言了。虽然在网上可以找到很多类似的经验,但其实第一次使用还是要花费不少的时间。

5345
来自专栏阿杜的世界

RocketMQ学习-消息发布和订阅

前面一篇文章分析了broker的启动过程,浏览了broker的基本功能。接下来的几篇文章,准备按照十分钟入门RocketMQ一文中提到的一系列特性,依次进行学习...

4462
来自专栏主机笔记

笔记本电脑安装linux桌面版

手里一个旧的笔记本配置比较低,装windows很卡,于是就决定装一个windows,今天记录下笔记本安装ubuntu桌面版的过程,主要2件事,做系统盘和装系统,...

1.5K7
来自专栏一个默默无闻的工程师的日常

OpenStack Queens Cinder Multi-Attach 功能

2754

扫码关注云+社区