pika 中的 AsyncioConnection 和 SelectConnection 适配器有什么区别

Question

在我们当前的项目中，我们计划使用 rabbitMQ 和 pika 来实现队列。 谁能帮我解决以下问题。

1. 在 pika 中用于异步操作的最佳适配器是什么
2. 我们可以在队列中并行处理消息吗
3. pika 中的 AsyncioConnection 和 SelectConnection 适配器有什么区别

Answer 1

我是 Pika 的维护者之一。有一个mailing list 是询问有关 Pika 问题的最佳场所。

1. 使用SelectConnection，除非您在其他地方专门使用asyncio Python 功能。

2. 是的，你可以，但你必须记住 Pika 不是线程安全的。 example code 演示了如何在单独的线程中工作，然后正确地确认消息。

3. 您必须通过查看代码来做自己的功课，但基本上AsyncioConnection 使用this Python 3 功能。