标签:快速 序列 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
标签:快速 序列 lin upd 定义 com dha 节点 handler
原文地址:https://www.cnblogs.com/farwish/p/13155411.html