RMQTT Broker

RMQTT broker — это полностью открытый, масштабируемый и высокодоступный распределённый брокер обмена сообщениями MQTT для IoT, M2M и мобильных приложений, который может обрабатывать миллионы одновременных подключений на одном сервисном узле.

Особенности

• 100% безопасный код Rust;
• Основан на tokio, ntex и ntex-mqtt;
• Поддержка протоколов MQTT v3.1, v3.1.1 и v5.0;
  • Поддержка сообщений QoS0, QoS1, QoS2;
  • Поддержка автономных сообщений;
  • Поддержка сохранённых сообщений;
  • Поддержка последнего сообщения;
• Встроенная аутентификация AUTH/ACL;
• HTTP AUTH/ACL;
• JWT AUTH/ACL;
• WebHook;
• $SYS системные темы;
• Сохранение информации о сеансе;
• Хранение сообщений с неистёкшим сроком действия;
• Мостовые соединения MQTT — режим входящего трафика
• Мостовые соединения MQTT — исходящий трафик
• Мостовые соединения Apache Kafka — исходящий трафик
• Мостовые соединения Apache Pulsar — исходящий трафик
• Мостовые соединения NATS — исходящий трафик
• Мостовые соединения Reductstore — исходящий трафик
• Перезапись тем
• Автоматическая подписка
• Общая подписка ($share/{Group}/{TopicFilter});
• Эксклюзивная подписка ($exclusive/{TopicFilter});
• Ограниченная подписка ($limit/{LimitQuantity}/{TopicFilter});
• Отложенная публикация ($delayed/{DelayInterval}/{TopicName});
• Распределённый кластер;
• Перехватчики;
• Поддержка TLS;
• Поддержка WebSocket;
• Поддержка WebSocket-TLS;
• Встроенные расширяемые компоненты;
• Расширяемая поддержка плагинов;
• Метрики и статистика;
• Лимит скорости;
• Очередь и обработка в реальном времени;
• Повторная отправка сообщений;

Полный список новых функций см. в примечаниях к выпуску RMQTT.

Установка

Брокер RMQTT является кроссплатформенным и поддерживает Linux, Unix, macOS и Windows. Это означает, что RMQTT можно развернуть на серверах с архитектурой x86_64 и устройствах ARM, таких как Raspberry Pi.

Запуск RMQTT с помощью Docker

• Один узел

mkdir -p /app/log/rmqtt
docker run -d --name rmqtt -p 1883:1883 -p 8883:8883 -p 11883:11883 -p 6060:6060 -v /app/log/rmqtt:/var/log/rmqtt  rmqtt/rmqtt:latest

• Несколько узлов

  docker run -d --name rmqtt1 -p 1884:1883 -p 8884:8883 -p 11884:11883 -p 6064:6060 -v /app/log/rmqtt/1:/var/log/rmqtt  rmqtt/rmqtt:latest --id 1 --plugins-default-startups "rmqtt-cluster-raft" --node-grpc-addrs "1@172.17.0.3:5363" "2@172.17.0.4:5363" "3@172.17.0.5:5363" --raft-peer-addrs "1@172.17.0.3:6003" "2@172.17.0.4:6003" "3@172.17.0.5:6003"   

  docker run -d --name rmqtt2 -p 1885:1883 -p 8885:8883 -p 11885:11883 -p 6065:6060 -v /app/log/rmqtt/2:/var/log/rmqtt  rmqtt/rmqtt:latest --id 2 --plugins-default-startups "rmqtt-cluster-raft" --node-grpc-addrs "1@172.17.0.3:5363" "2@172.17.0.4:5363" "3@172.17.0.5:5363" --raft-peer-addrs "1@172.17.0.3:6003" "2@172.17.0.4:6003" "3@172.17.0.5:6003"   

  docker run -d --name rmqtt3 -p 1886:1883 -p 8886:8883 -p 11886:11883 -p 6066:6060 -v /app/log/rmqtt/3:/var/log/rmqtt  rmqtt/rmqtt:latest --id 3 --plugins-default-startups "rmqtt-cluster-raft" --node-grpc-addrs "1@172.17.0.3:5363" "2@172.17.0.4:5363" "3@172.17.0.5:5363" --raft-peer-addrs "1@172.17.0.3:6003" "2@172.17.0.4:6003" "3@172.17.0.5:6003"

Узлы: 1, 2, 3; IP-адреса узлов: 172.17.0.3, 172.17.0.4, 172.17.0.5