我有一个带有单个队列的 RabbitMQ 交换。我希望创建一个运行多个线程并尽快通过该队列工作的守护进程。
“工作”涉及与外部服务的通信，因此每个消费者内部都会发生相当多的阻塞。因此，我希望有多个线程都处理来自同一队列的消息。
我可以通过在主线程上使用队列，然后将传入的工作分流到其他线程池来实现此目的，但是有没有办法启动多个使用者，每个使用者都在自己的线程上下文中？
看一眼celery http://celeryproject.org/- 它旨在对来自 AMPQ 代理的任务进行排队和处理（但也可与其他排队后端配合使用）。它处理多进程或多线程并发，并使创建和使用任务变得非常容易。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
