python - 可以在网络应用程序中使用 Pika BlockingConnection 吗？

Question

我对 BlockingConnection 和 AsyncoreConnection 有点困惑。我想从 Django 应用程序向 RabbitMQ 队列发送一些消息。使用全局 BlockingConnection 对象可以做到这一点吗？

谢谢。

Answer 1

每个线程都需要有一个 BlockingConnection 对象，如 pika FAQ 中所述:

Pika does not have any notion of threading in the code. If you want to use Pika with threading, make sure you have a Pika connection per thread, created in that thread. It is not safe to share one Pika connection across threads.

因此，答案取决于您部署 Django 的方式。如果您在多线程部署中使用 Django，则不能使用全局 BlockingConnection；您需要为每个线程创建一个。如果您不使用多线程，则可以使用全局 BlockingConnection 对象。