nsq-适配器
一个小的适配器库,可以更轻松地使用令人敬畏的 nsq-service。
它提供了围绕 bitly 的 nsq-services 的瘦包装器,以简化 nsq 的异步消息队列在中型项目中的使用。
基本上,您定义一个新的 nsq-adapter 结构并调用以下方法:
Subscribe() 订阅特定主题并处理传入消息
Publish() 向特定主题发送消息
Request() 向特定主题发送请求并等待响应
RespondTo() 向请求发送响应消息
请查看测试目录中的示例和示例,以了解包的用法。
用法
package main
import (
"github.com/tikiatua/nsq-adapter"
)
const (
nsqlookupdAddress string = "192.168.99.100:4161"
)
func main () {
//
2021-06-07 16:04:02
16KB
Go
1