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

看看代码，我看不出有什么问题。将 no-ack 设置为 True 并将预取计数设置为 0 应该可以正常工作。您确定您的应用程序没有因为某些异常而崩溃吗？结冰的那一刻有什么特别的吗？

您可能还想尝试在RabbitMQ Discuss邮件列表上提问。开发人员通常会回答所有提出的问题，其中一些人熟悉 Python AMQP 客户端。