1

我有一个 php 生产者,它将消息生成到队列中。消费者收到 3 条消息后才冻结到 $queue->consume(); 方法。如果我运行另一个消费者,它也只会收到以下 3 条消息并冻结。

知道为什么会这样吗?

谢谢。

4

1 回答 1

0

消息在没有被确认的情况下被保存在内存中。您需要使用 ack 或 nack 释放它们。一旦发生这种情况,您将提取下一批消息。

编辑:没有看到你的评论,对不起。

于 2017-07-10T18:07:14.700 回答