我有点困惑BlockingConnection
和AsyncoreConnection
.我想从Django应用程序向RabbitMQ队列发送一些消息.使用全局BlockingConnection
对象可以吗?
谢谢.
BlockingConnection
每个线程需要一个对象,如pika FAQ中所述:
Pika在代码中没有任何线程概念.如果要将Pika与线程一起使用,请确保在该线程中创建每个线程的Pika连接.跨线程共享一个Pika连接是不安全的.
所以,答案取决于你如何部署Django.如果您在多线程部署中使用Django,则无法使用全局BlockingConnection
; 你需要创建一个每个线程.如果您不使用多线程,则可以使用全局BlockingConnection
对象.