悟空不同提供者的惯用队列。Goku 尝试通过使用通道来统一队列交互(目前仅支持 SQS)。
用法
首先,您需要初始化库,指定一个提供程序,在本例中 sqs_provider 是一个实例:
q := goku.NewQueue(tgoku.Reader(sqs_provider), tgoku.Writer(sqs_provider))
Goku.Queue 将公开两个通道,一个用于读取消息 Sender() ,另一个用于写入消息 Receiver() 。
之后,您应该能够与队列交换消息,如下所示:
q.Receiver() <- \"Message\"
msg := <- q.Sender()
有关更多信息,请阅读相关文档。
暂无评论