Публикация / подписка MQTT-сообщения через RabbitMQ с использованием pika (клиент Python)
У меня есть существующий сервер RabittMQ, и мы включили плагин MQTT для публикации / подписки сообщений mqtt. У нас есть клиент pika для обработки существующих сообщений очереди. Сейчас мы хотим использовать тот же обработчик pika on_message() для обработки сообщения mqtt. Я могу опубликовать и подписаться на mqtt-сообщение через клиент eclipse paho. Мы хотим использовать существующий клиент RabittMQ (pika). Плагин MQTT по умолчанию публикуется в amq.topic exchange . Я хочу опубликовать это же сообщение в своем обмене. Пожалуйста, дайте мне знать, как это получить.
1 ответ
Команда RabbitMQ отслеживает этот список рассылки и только иногда отвечает на вопросы по Stackru.
Если вы хотите, чтобы потребитель, использующий библиотеку Pika, получал сообщения MQTT, он должен подписаться на соответствующую очередь, в которой публикуются сообщения MQTT. Полная документация о том, как MQTT и AMQP могут взаимодействовать, доступна здесь.
Затем вы говорите: "Я хочу опубликовать то же сообщение в моем собственном обмене". Если вы хотите использовать свой собственный обмен вместо amq.topicсм. раздел "Пользовательские обмены" этого документа. Вы должны указать название биржи в rabbitmq.config файл и создать обмен до публикации каких-либо сообщений. Обратите внимание, что этот пользовательский обмен должен быть темой обмена.
Документация RabbitMQ - хороший ресурс, и я предлагаю поискать там, когда у вас есть вопросы.