使用具有多个线程的rabbitmq消息队列(Python Kombu)
我有一个单一队列的RabbitMQ交换机。 我希望创建一个运行多个线程并尽快通过此队列的守护进程。
“工作”涉及与外部服务的沟通,所以每个消费者内部都会有相当数量的阻塞。 因此,我想要有多个线程处理来自同一队列的消息。
我可以通过消耗主线程上的队列来实现此目的,然后将传入的工作归入其他线程池,但是有没有办法启动多个使用者,每个使用者都在自己的线程环境中?
看一下芹菜 - 它是为排队和处理来自AMPQ经纪人的任务而设计的(但也适用于其他排队后端)。 它处理多进程或多线程并发,并使创建和使用任务变得非常简单。
链接地址: http://www.djcxy.com/p/8101.html上一篇: Consuming a rabbitmq message queue with multiple threads (Python Kombu)