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

Question

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

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

Answer 1

我是 Pika 的维护者之一。有一个mailing list这是询问有关皮卡问题的最佳地点。

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

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

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