如何使用 pika 和 RabbitMQ 重新发布消息

【问题标题】：How to republish messages with pika and RabbitMQ如何使用 pika 和 RabbitMQ 重新发布消息
【发布时间】：2016-03-14 17:37:43
【问题描述】：

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

reader_connection.ioloop.start()

或者这个：

writer_connection.ioloop.start()

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

【问题讨论】：

【解决方案1】：

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

【讨论】：