码迷,mamicode.com
首页 > 其他好文 > 详细

[Go] go-nsq 使用指南

时间:2020-06-18 01:28:37      阅读:102      评论:0      收藏:0      [点我收藏+]

标签:快速   序列   lin   upd   定义   com   dha   节点   handler   

 

首先你需要有一个 nsq 的服务端,nsq 由三部分构成:nsqd、nsqlookupd、nsqadmin。

快速启动 nsq 一个节点看这里:https://github.com/farwish/nsq-launcher

 

go-nsq 是众多客户端中的一个,使用 golang 编写,我们在逻辑代码中写 Producer 和 Comsumer。

 

producer,把数据序列化之后,通过 producer.Publish 发送到队列,producer.Publish(topicName, messageBody)

 

comsumer 通过添加 handler 来自定义处理逻辑,consumer.AddHandler(&myMessageHandler{})

 

Ref:https://godoc.org/github.com/nsqio/go-nsq

Link:https://www.cnblogs.com/farwish/p/13155411.html

[Go] go-nsq 使用指南

标签:快速   序列   lin   upd   定义   com   dha   节点   handler   

原文地址:https://www.cnblogs.com/farwish/p/13155411.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!