我已经设置了 RabittMQ 服务器,我们启用了 MQTT 插件来发布/订阅 mqtt 消息。我们有 pika 客户端来处理现有的队列消息。现在,我们希望使用相同的pika on_message()处理程序来处理mqtt消息。我能够通过 eclipse paho 客户端发布和订阅 mqtt 消息。我们想使用现有的 RabittMQ 客户端(pika)。MQTT 插件默认发布到 amq.topic 交换 .我想将相同的消息发布到我自己的交易所。请让我知道,如何获得这个。
RabbitMQ 团队监控此邮件列表,并且只偶尔回答 StackOverflow 上的问题。
如果您希望使用 Pika 库的使用者接收 MQTT 消息,则该使用者必须订阅要将 MQTT 消息发布到的相应队列。有关 MQTT 和 AMQP 如何互操作的全面文档,请参见此处。
然后你说"我想在我自己的交易所发布相同的消息"。如果您希望使用自己的交易所而不是amq.topic
,请参阅本文档的"自定义交易所"部分。您必须在rabbitmq.config
文件中指定交换的名称,并在发布任何消息之前创建交换。请注意,此自定义交换必须是主题交换。
RabbitMQ 文档是一个很好的资源,我建议在有问题时在那里搜索。