[Go] go-nsq 使用指南

首先你需要有一个 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

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