Publish/Subscribe 使用鼠兔通过 RabbitMQ 发送 MQTT 消息(python 客户端)

Publish/Subscribe MQTT message over RabbitMQ using pika (python client)

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

RabbitMQ 团队监控 this mailing list 并且有时只在 Whosebug 上回答问题。

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

然后你说"I want to publish the same message to my own exchange"。如果您想使用自己的交易所而不是 amq.topic,请参阅 this document 的 "Custom Exchanges" 部分。您必须在 rabbitmq.config 文件中指定交换的名称,并在发布任何消息之前创建交换。请注意,此自定义交换 必须 是主题交换。

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