小编San*_*eep的帖子

我正在创建NATS go lang Queue Subscriber客户端，如下所示：

nc.QueueSubscribe("foo", "my_queue", func(msg *nats.Msg) {
        log.Printf("Message :%s", string(msg.Data))
})

因此，每当我向“ foo”主题发布任何消息时，有时就会收到消息，而有时则不会。

例如，假设我向“ foo”主题发送了10条消息，那么它将最多收到2或3条消息。

我的要求如下

• 应该有队列订阅。
• 所有输入事件都应处理。
• 如何在并发模式下实现队列订阅。

任何帮助表示赞赏。