我期待用RabbitMQ实现优先级队列.邮件列表recommends使用多个队列,每个队列代表不同的优先级.

我的问题是,如何使用pika(或可能是其他一些python库)以某些优先顺序轮询多个队列？

解决方法:

我不认为有一种方法可以在消费者层面上用鼠兔天真地做到这一点,因为默认情况下所有消费者具有相同的优先权.

我可以做的解决问题的方法是在邮件列表中建立两个队列,每个队列都有自己的消费者.在每个消费者的消费者回调中,而不是直接处理消息,我会将其放入优先级队列,然后调用从队列中读取最高优先级消息并处理它的函数.

Another question有类似的回应.