我有一个关于 RabbitMQ 的严重问题。在接收到一定数量的消息后,消费者就停止接收消息。他们仍然保持连接,但不再接收消息。我找到了有关此问题的其他帖子,但都没有有效的答案。
这是我使用的连接包装器:http://pastebin.com/XVY3HNGq . 我使用 stormed-amqp,它是 python 的异步 amqp 库。
我尝试过不使用 ack 或使用 ack 且 qos 预取计数为 100 来使用消息(如对此类问题的多个响应所示)。
当我执行“rabbitmqctl list_queues name messages_ready messages_unacknowledged”时,我有很多就绪消息和使用 ack 时未确认消息的“预取计数”(100) 值。
我真的不知道发生了什么! 感谢您的回答。
请您参考如下方法:
在谷歌搜索这个问题时,我发现这个谷歌讨论听起来很像你的问题。
https://groups.google.com/forum/#!topic/rabbitmq-discuss/DyJvFDnaVJ4
