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

Question

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

Answer 1

RabbitMQ 团队会监控这个邮件列表，有时只会在 StackOverflow 上回答问题。

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

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

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