我对 RabbitMQ 有一个严重的问题。收到一定数量的消息后,消费者只是停止接收消息。他们仍然连接,但不再接收消息。我找到了关于这个问题的其他帖子,但没有一个有工作的答案。
这是我使用的连接包装器:http : //pastebin.com/XVY3HNGq。我使用stormed-amqp,它是一个用于python 的异步amqp 库。
我曾尝试在没有 ack 或 ack 的情况下使用消息,并且 qos 预取计数为 100(如对此类问题的几个响应所示)。
当我做“rabbitmqctl list_queues name messages_ready messages_unacknowledged”时,我有很多准备好的消息和使用ack时未确认消息的“预取计数”(100)值。
真不知道怎么回事!谢谢您的回答。