python - RabbitMQ 消费者停止接收消息

Question

我有一个关于 RabbitMQ 的严重问题。在接收到一定数量的消息后，消费者就停止接收消息。他们仍然保持连接，但不再接收消息。我找到了有关此问题的其他帖子，但都没有有效的答案。

这是我使用的连接包装器:http://pastebin.com/XVY3HNGq .我使用 stormed-amqp，它是 python 的异步 amqp 库。

我尝试过不使用 ack 或使用 ack 且 qos 预取计数为 100 来使用消息(如对此类问题的多个响应所示)。

当我执行“rabbitmqctl list_queues name messages_ready messages_unacknowledged”时，我有很多就绪消息和使用 ack 时未确认消息的“预取计数”(100) 值。

我真的不知道发生了什么!感谢您的回答。

Answer 1

在谷歌搜索这个问题时，我发现这个谷歌讨论听起来很像你的问题。

https://groups.google.com/forum/#!topic/rabbitmq-discuss/DyJvFDnaVJ4