我们如何在不为RabbitMQ运行单独文件的情况下连续侦听?

Question

在python Django微服务中，我们使用rabbitMQ进行内部通信，现在我必须为一个服务运行两个终端

1. 运行jobs
2. 运行receive.py消费

我们如何将这些结合起来听和运行项目。

我在看这个文档https://www.rabbitmq.com/tutorials/tutorial-one-python.html

Answer 1

你可以尝试在consumer中作为后台线程启动。

而不是启动消费者指令，该指令停止执行并等待接收到新消息

channel.start_consuming()

你可以生成一个新的线程，并将这个函数关联到它。

import threading
#channel.start_consuming()

thread = threading.Thread(name='t', target=channel.start_consuming, args=())
thread.setDaemon(True)
thread.start()

，然后按照生产商的说明继续。