使用 pika（python 客户端）通过 RabbitMQ 发布/订阅 MQTT 消息答案

【问题标题】：Publish/Subscribe MQTT message over RabbitMQ using pika (python client)使用 pika（python 客户端）通过 RabbitMQ 发布/订阅 MQTT 消息
【发布时间】：2017-11-08 12:59:09
【问题描述】：

我有现有的 RabittMQ 服务器设置，我们启用了 MQTT 插件来发布/订阅 mqtt 消息。我们有 pika 客户端来处理现有的队列消息。现在，我们想使用相同的 pika on_message() 处理程序来处理 mqtt 消息。我能够通过 eclipse paho 客户端发布和订阅 mqtt 消息。我们想使用现有的 RabittMQ 客户端（pika）。 MQTT 插件默认发布到 amq.topic exchange 。我想将相同的消息发布到我自己的交易所。请告诉我，如何获得这个。

【问题讨论】：

标签： rabbitmq paho pika python-pika

【解决方案1】：

RabbitMQ 团队会监控 this mailing list，但有时只会在 StackOverflow 上回答问题。

如果您希望使用 Pika 库的消费者接收 MQTT 消息，该消费者必须订阅相应的队列，MQTT 消息将发布到该队列。 here 提供了有关 MQTT 和 AMQP 如何互操作的综合文档。

然后您说“我想将相同的消息发布到我自己的交易所”。如果您希望使用自己的交换而不是amq.topic，请参阅this document 的“自定义交换”部分。您必须在rabbitmq.config 文件中指定交换的名称，并在发布任何消息之前创建交换。请注意，此自定义交换必须是主题交换。

RabbitMQ 文档是一个很好的资源，我建议您在有问题时搜索那里。

【讨论】：

谢谢卢克。我成功地从 mqtt 客户端发布消息并在 RabbitMQ 中接收它。我在配置文件中设置了自定义交换。
太好了，感谢您告诉我。如果您不介意，请将我的回复标记为已接受的答案。谢谢。