MMQ broker

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

MMQ broker полностью поддерживает MQTT V3.1 и V3.1.1. Открытый бесплатный сервер, который одновременно поддерживает распределённую архитектуру, сохранение данных, механизм правил, ACL и другие функции MQTT broker. В версии 1.1.4 добавлены новые функции плагинов, которые позволяют реализовать больше настраиваемых функций.

Особенности

• Распределённый MQTT сервис.
• Сотни тысяч одновременных подключений (3 сервера Huawei Cloud 1 ядро 2G 1 Мбит/с).
• Поддержка MQTT V3.1 и V3.1.1.
• Поддержка мостов (MySQL, PostgreSQL, SQL Server, Kafka, TDengine, MQTT Broker, Influxdb).
• Механизм правил на основе SQL для пересылки правил.
• API управления для управления интерфейсом MMQ BROKER.
• Аутентификация и авторизация: управление логином и аутентификацией.
• Публикация и подписка ACL.
• Плагины.
• Управление кластером: онлайн-конфигурация и управление кластером (функция в разработке).

Установка

MMQ broker является кроссплатформенным и поддерживает Linux, Unix, macOS и Windows. Это означает, что MMQ broker можно развернуть на сервере с архитектурой x86_64. Из-за использования алгоритма согласованности raft требуется развёртывание кластера из трёх узлов или более.

Способ загрузки исходного кода с GitHub

git clone https://github.com/MrHKing/mmq.git
cd mmq
mvn -Prelease-mmq -Dmaven.test.skip=true clean install -U

Прямая установка Вы можете загрузить пакет mmq-server-$version.zip с последней стабильной версией.

unzip mmq-server-$version.zip или tar -xvf mmq-server-$version.tar.gz
cd mmq/bin

Установка Docker

docker run -d --name mmq -p 2883:2883 -p 1883:3883 -p 8888:8888 paperman/mmq:v1.0.8

Установка Kubernetes

Быстрый старт

Запуск в одиночном режиме

cd mmq\bin
#windows start
startup.cmd -m standalone

cd mmq/bin
#linux start
sh startup.sh -m standalone
#linux shutdown
sh shutdown.sh

Запуск кластера

cd mmq/config
#конфигурационный файл кластера
cp cluster.conf.example cluster.conf

#каждому узлу необходимо настроить адреса других узлов следующим образом:
#пример
192.168.31.9:7777
192.168.31.9:8848
192.168.31.9:8888

cd mmq\bin
#windows start
startup.cmd

cd mmq/bin
#linux start
sh startup.sh
#linux shutdown
sh shutdown.sh

Конфигурационные файлы

Порт TCP по умолчанию для MQTT: 3883

Порт WebSocket для MQTT: 2883

#*************** Spring Boot Related Configurations ***************#
### Default web context path:
server.servlet.contextPath=/
### Default web server port:
server.port=8888

#*************** mqtt broker Configurations ***************#
mmq.broker.websocketPort=2883
mmq.broker.port=3883
mmq.broker.ssl.password=mmq
mmq.broker.ssl.certPath=cert/mmq.pfx
mmq.broker.ssl.port=17733
mmq.broker.ssl.websocketPort=36633
mmq.broker.default.user=admin
mmq.broker.default.password=admin@mmq
mmq.broker.default.anonymous=true

Dashboard — демонстрация в одиночном режиме

После запуска перейдите по адресу http://101.43.4.211:8888/.

По умолчанию учётная запись: mmq

Пароль по умолчанию: aaaaaa

Порт TCP MQTT по умолчанию: 1883

Порт WebSocket MQTT: 2883

Документация

Для получения дополнительной информации см. wiki.

MQTT стандарт

Вы можете узнать о MQTT, обратившись к следующим ссылкам:

MQTT Version 3.1.1

Лицензия с открытым исходным кодом

Apache License 2.0, см. LICENSE.

Номер группы

QQ группа: 1016132679