Skip to main content
 首页 » 编程设计

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

2025年05月04日19del

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

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

有什么想法吗?

请您参考如下方法:

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