83374290 2020-06-18
首先你需要有一个 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{})