上次好像想过用 celery，但是好像因为 Python 版本问题最后没用它。
所以我是在 AppConfig 里抛几个 Thread 出来去监听 MQ 队列，这样 Thread 池的大小可以自定义，我开了 10 个。
request 有任务需求的时候，通过发消息到 MQ 去，Thread 消费消息开始任务，做完了，按照消息里约定的 routing key 发布消息去 MQ，前端通过 mqtt 或者 websocket 消费消息。

这样基本上就是一个 MQ Server 就够

Python 的 MQ 客户端之前用 pika，连的 RabbitMQ 后来发现稳定性很不好，现在用 amqpstorm，稳定性还可以。