NSQ的golang客户端简单使用
时间:2022-05-05
本文章向大家介绍NSQ的golang客户端简单使用,主要内容包括获取客户端、简单的消费者和生产者使用、基本概念、基础应用、原理机制和需要注意的事项等,并结合实例形式分析了其使用技巧,希望通过本文能帮助到大家理解应用这部分内容。
NSQ 是由国外的一个短链服务商bitly使用golang开发的一个消息队列系统,正好使用到了这个东西,在这里简单的记录下。
获取客户端
nsq的golang客户端是官方版本的
go get github.com/nsqio/go-nsq
即可
简单的消费者和生产者使用
该客户端有原始的command函数用于一些基础操作,也有consumer和producer的封装,我这里是直接使用了封装了。
- consumer
消费者比较简单,只要监听队列消息,并处理就可以了,下面是一个简单的例子。
type NSQHandler struct {
}
func (this *NSQHandler) HandleMessage(message *nsq.Message) error {
log.Println("recv:", string(message.Body))
return nil
}
func testNSQ() {
waiter := sync.WaitGroup{}
waiter.Add(1)
go func() {
defer waiter.Done()
consumer, err := nsq.NewConsumer("test", "ch1", nsq.NewConfig())
if nil != err {
log.Println(err)
return
}
consumer.AddHandler(&NSQHandler{})
err = consumer.ConnectToNSQD("10.100.156.207:4150")
if nil != err {
log.Println(err)
return
}
select {}
}()
waiter.Wait()
}
创建好consumer后,只需要自己创建一个struct并实现HandleMessage方法即可,当有消息时候,再去处理消息。
需要注意的是,AddHandler的回调是在别的routine中执行的,并且可以添加多个handler用于处理消息,这里可能需要注意下线程的同步问题。
- producer
生产者也和消费者差不多,首先需要创建一个producer
func (this *MsgQueue) Init(addr string) error {
var err error
this.addr = addr
// try to connect
cfg := nsq.NewConfig()
this.producer, err = nsq.NewProducer(addr, cfg)
if nil != err {
return err
}
// try to ping
err = this.producer.Ping()
if nil != err {
this.producer.Stop()
this.producer = nil
return err
}
return nil
}
producer封装了较多的方法,分为同步和异步两种。带Async后缀的,都是异步的。
同步是收到了nsq的回应后再返回的函数,所以可能会堵塞,而异步的操作,则调用方需要传入一个chan用于接收结果,当有结果返回或者是超时的情况下,相应的内容会写到该chan中。
在这里我用了同步的api,毕竟消息队列假如出了什么问题,那么整个服务就不可用了,而且同步改异步也不会太麻烦,以后可以做下修改。
publish的方法也很简单,提供一个topic和数据就行了。
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- SpringBoot日志功能
- JavaWeb使用response的中文乱码问题
- 《机器学习》-- 第六章 支持向量机
- Java并发编程的艺术[1]
- Java并发编程的艺术[2]
- Spark UDF实现demo
- Spring boot 开发中热部署配置(只需两步)
- 纯Java搭建SpringMVC项目
- 整理一下Spring整合Junit4单元测试方法
- spring 到底注入接口还是实现类?
- 韩松团队新作 | MCUNet | IoT设备+微型机器学习时代已经到来了
- SpringMVC在web.xml中的配置(引入springmvc)
- springmvc使用DELETE|PUT请求
- Mybatis缓存相关的知识
- 「2020最新」Spring最易学习教程—第一个Spring程序