python - RabbitMQ 序列化来自多个消费者队列的消息

Question

我遇到了一个问题，我在共享模式下设置了一个队列，并且绑定(bind)了多个消费者。问题是 rabbitmq 似乎正在序列化消息，也就是说，一次只能运行一个消费者。我需要它是并行的，但是，我似乎无法弄清楚如何。

每个消费者都在自己的进程中运行。队列中有很多消息。我正在使用 py-amqplib 与 RabbitMQ 交互。

有什么想法吗？

Answer 1

预取 (QOS) 怎么样？在 small queueus 上，我通过声明队列、获取当前可用消息的数量、附加消费者、使用消息然后在消息数量被使用后关闭它来表现出并行性。在不确认消息的情况下关闭 channel 可以使消息可供其他消费者使用，足够快地轮询队列，您可以获得一个类似并行的解决方案。