悟空不同提供者的惯用队列。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()

有关更多信息,请阅读相关文档。