RabbitMQ简易教程 - 并发调度 | 飞污熊博客

[yidao620c]

https://www.xncoding.com/middleware/mq/rabbitmq-tutorial08.html

RabbitMQ任务调度默认是阻塞的，使用pika中的channel.start_consuming()的时候， 每次收到一条消息后会顺序执行完回调函数，发送ACK的确认消息，然后再执行下一条消息。 虽然说可同时接受多条消息，但是并不能同时处理这多条消息，那么需要自己在代码里面实现任务的并发调度。 在Python里面实现并发方式多种多样，有多线程、多进程、多协程方式，我演示下如何实现。