我需要收听 RabbitMQ 消息，稍微处理每条消息，然后将其提交到另一个交换器。到目前为止，我看到的每个示例都包括以下内容：
reader_connection.ioloop.start()
或这个：
writer_connection.ioloop.start()
因为我需要接收和发送消息，我可能需要同时运行两个循环。有没有办法我可以做到这一点？
问问题
320 次
1 回答
-1
发布者和订阅者之间没有区别。您可以使用相同或不同的连接发布和订阅（然后您需要为它们启动 ioloop）您可以在此处找到一些示例：https://pika.readthedocs.org/en/0.10.0/examples/connecting_async。 html
于 2016-03-17T16:56:36.367 回答