python - 如何使用 Pika 编写异步 RPC 客户端？

Question

我正在尝试使用 pika 编写异步 RPC 客户端，我的代码基于以下示例，

http://pika.readthedocs.io/en/latest/examples/asynchronous_publisher_example.html

问题是根据鼠兔的RPC blocking example ，RPC 调用不使用交换，但是每当我尝试使用打开交换时，

self._channel.exchange_declare(self.on_exchange_declareok,
                                   '',
                                   self.EXCHANGE_TYPE)

我断线了。此外，如果我尝试跳过 exchange_declare 函数并直接跳转到声明队列，我会得到相同的结果。处理这个问题的正确方法是什么？

Answer 1

您可以通过添加处理 RabbitMQ 连接的后台线程来实现异步 RPC 客户端。我有一个适用于鼠兔和 flask 的工作示例 here .

您还有一个更详细的示例，该示例基于我自己的可用库 here .

这些显然仍然基于阻塞连接，但至少它们提供了异步解决方案。