使用具有多个线程的rabbitmq消息队列（Python Kombu）

Question

我有一个带有单个队列的 RabbitMQ 交换。我希望创建一个运行多个线程并尽快通过该队列工作的守护进程。

“工作”涉及与外部服务的通信，因此每个消费者内部都会发生相当多的阻塞。因此，我希望多个线程都处理来自同一个队列的消息。

我可以通过使用主线程上的队列，然后将传入的工作分配给其他线程池来实现这一点，但是有没有办法启动多个消费者，每个消费者都在自己的线程上下文中？

Answer 1

查看celery - 它旨在对来自 AMPQ 代理的任务进行排队和处理（但也适用于其他排队后端）。它处理多进程或多线程并发，并使得创建和使用任务变得非常容易。