python-3.x - 如何使用 pika 和 RabbitMQ 重新发布消息

Question

我需要收听 RabbitMQ 消息，稍微处理每条消息，然后将其提交到另一个交换器。到目前为止，我看到的每个示例都包括以下内容：

reader_connection.ioloop.start()

或这个：

writer_connection.ioloop.start()

因为我需要接收和发送消息，我可能需要同时运行两个循环。有没有办法我可以做到这一点？

Answer 1

发布者和订阅者之间没有区别。您可以使用相同或不同的连接发布和订阅（然后您需要为它们启动 ioloop）您可以在此处找到一些示例：https://pika.readthedocs.org/en/0.10.0/examples/connecting_async。 html