MQTT не имеет понятия очередей или обменов ... просто иерархическая структура темы.Плагин публикует сообщения MQTT в обмене темами (amq.topic
по умолчанию), а затем потребители Rabbit читают сообщения из очередей, связанных с обменом.Обратите внимание, что плагин преобразует разделитель тем * MQTT /
с разделителем .
Кролика.
Другой вариант для рассмотрения (полный дискурс, я работаю для них): Solace PubSub + брокер сообщений поддерживает MQTT изначально без каких-либо плагинов (как для соединений TCP и WebSockets), так и AMQP 1.0 изначально.У Solace также есть интерфейс обмена сообщениями REST (например, POST REST, использование в качестве сообщения WebSockets), а также набор «корпоративных» API (например, отправка сообщения MQTT, использование с использованием темы JMS), поэтому мой браузер и серверный сервер обмениваются приложениями.сообщения напрямую.И это бесплатно, со встроенным полным HA и DR. Проверьте это на dev.solace.com
.