我正在尝试使用pika编写异步RPC客户端,我的代码基于以下示例,
http://pika.readthedocs.io/en/latest/examples/asynchronous_publisher_example.html
问题是……
您可以通过添加处理RabbitMQ连接的后台线程来实现Async RPC客户端。我有一个适用于鼠兔和烧瓶的工作实例 这里 。
您还有一个更精细的示例,它基于我自己的库 这里 。
这些显然仍然基于阻塞连接,但至少它们提供了异步解决方案。