Всем привет, мы снова встретились, я ваш друг Цюаньчжаньцзюнь.

Краткое введение в модель публикации-подписки MQTT

MQTT основан на Публикация/подписка режим связи и обмена данными, с HTTP из Запрос/Ответ шаблоны существенно различны.

подписчик Пойду в Сервер сообщений (брокер) Подпишитесь на Тема . После успешной подписки сервер сообщений будет пересылать сообщения по этой теме всем подписчикам.

Темак ‘/’ Различайте разные уровни разделителей. Содержит подстановочные знаки ‘+’ или ‘#’ изтема, также известная как Тематический фильтр (Тема Filters）,Без подстановочного знака называется Название темы (Тема Names） . Например:

sensor/1/temperature

sensor/1/#

sensor/+/temperature

Введение в MQTT-брокер

Определение MQTT Broker и его роль

MQTT Broker также известный как MQTT Сервер сообщений, который может работать MQTT Программное обеспечение сервера сообщений представляет собой сервер и кластер серверов. MQTT Broker Ответственный за получение отклиентизсетевое соединение,И обрабатывать запросы клиентов на подписку/отписку (подписаться/отписаться), пресс-релиз (публиковать),В то же время сообщение клиента также будет перенаправлено другим абонентам.

MQTT Broker широко используется в электроэнергетике, новой энергетике, умных городах, умных домах, интеллектуальных показаниях счетчиков, Интернете транспортных средств, финансах и платежах, операторах и других отраслях.

Распространенный MQTT-брокер с открытым исходным кодом

• EMQ X – EMQ X на основе Erlang/OTP Разработка платформы Открытый исходный Самый популярный из в сообществе кодов MQTT Сервер сообщений. Кроме MQTT Вне соглашения EMQ X Также поддерживает MQTT-SN、CoAP、LwM2M、STOMP Ждем согласования. В настоящее время EMQ X Уже на мировом рынке 5000+ Корпоративные пользователи, 20+ Партнеры из списка Fortune 500.
• Eclipse Mosquitto – Mosquitto 是Открытый исходный код Время стало раньшеиз MQTT Брокер, который содержит C/C ++изклиент-библиотека для публикации и подписки mosquitto_pub、mosquitto_sub Клиент командной строки. Комар Относительно легкий, подходит для использования на всех устройствах: от маломощных одноплатных компьютеров до полноценных серверов.
• VerneMQ – VerneMQ на основе Erlang/OTP Разработка платформы высокопроизводительна и распределена. MQTT брокер сообщений。它可к在硬件上水平ивертикальное расширение,Для поддержки больших объемов параллелизма,При этом сохраняется низкая задержка и отказоустойчивость.
• HiveMQ CE – HiveMQ CE основан на Java из Открытый исходный код MQTT сервер сообщений, который полностью поддерживает MQTT 3.x и MQTT 5, да HiveMQ Платформа подключения для обмена сообщениями корпоративной версии: основы.

Основные функции, реализованные MQTT Broker

Доступ к протоколу

• Полный MQTT V3.1/V3.1.1 и V5.0 Поддержка спецификации протокола;
• MQTT-SN 、CoAP、lwM2M и т.д.Интернет вещей Доступ к протоколуподдерживать。

Развертывание кластера

Многосерверный кластер узлов,И поддерживает автоматическое обнаружение узлов. Относительно одного сервера,Кластеры могут дать следующие преимущества благодаря сотрудничеству между несколькими серверами:

• Высокая доступность. Отказ одного сервера или небольшого количества серверов не приведет к прекращению работы всей службы обмена сообщениями.,Остальные узлы, работающие нормально, могут продолжать предоставлять услуги;
• балансировка нагрузки. Благодаря механизму балансировки нагрузки кластер может равномерно распределять нагрузку по каждому узлу;
• Более высокая общая производительность. По сравнению с развертыванием на одной машине кластеры с несколькими узлами могут экспоненциально улучшить возможности подключения и обработки сообщений всей системы;
• Масштабируемость. Расширение может быть осуществлено без простоев путем добавления новых узлов в кластер.

Безопасность доступа

• SSL、WSS Зашифрованное соединение и поддержка одно-/двусторонней безопасности. аутентификации;
• клиент ID、IP Адрес, имя пользователя и пароль, LDAP и браузер Cookie Поддержка аутентификации;
• на основеID клиента, IP-адреса, имени пользователя из Access Control (ACL);
• Скорость сообщений, ограничение скорости соединения.

Сохранение данных

Сохранение Основные сценарии использования данных включают в себя операции записи, такие как онлайн- и оффлайн-статус клиента, подписку на тематическую информацию, содержимое сообщения и отправку квитанций о сообщении после его прибытия. Redis、MySQL、PostgreSQL、MongoDB、Cassandra и другие базы данных.

Другие функции

• HTTP поддержка интерфейса пресс-релиза, облегчающая прохождение приложений верхнего уровня REST API Отправьте сообщение на устройство;
• MQTT Broker Мост, поддерживает разные MQTT Broker Или Мост сообщений между различными кластерами. Мост может быть очень удобен для передачи сообщений в облачные сервисы, потоковые сервисы и т. д. MQTT Сервер сообщений. С помощью мостов можно выполнить некоторые функции, которые невозможно выполнить простым использованием кластеров: VPC Развертывание, поддержка гетерогенных узлов и увеличение лимита обслуживания одного приложения;
• Поддерживает общие подписки. Совместная подписка — это механизм, который позволяет равномерно распределять группу подписки из рассылки сообщений между подписавшимися членами группы. В общей подписке клиенты, подписавшиеся на одну и ту же тему, по очереди получают сообщения по этой теме. Одно и то же сообщение не будет отправлено клиентам с несколькими подписками, что позволяет выполнить балансировку клиентов с несколькими подписками. нагрузки；
• Поддержка механизма правил,Используется для настройки потоков сообщений и событий устройства.изиметь дело с、правила ответа。Правила описываютОткуда берутся данные?、Как фильтровать и обрабатывать данные、Куда идут результаты обработки?три конфигурации,То есть доступное правило содержит три элемента: триггерное событие (срабатывает при выполнении определенного условия), Правила. обработки (фильтрация и обработка данных из контекстной информации)、Ответные действия (например, сохранение в базе данных)、Повторно опубликовать обработанное сообщение、пересылать сообщения в очереди сообщений и т. д.).

Использование MQTT-брокера

Для облегчения тестирования мы используем EMQ Предоставьте онлайн-версию Брокер, Broker версия содержит EMQ X Enterprise из Все функции.

Адрес брокера： broker.emqx.io Брокерский порт： 1883、8883（SSL）、8083（Websocket）、8084（WSS）

Для подключения клиента мы используем EMQ Предоставьте онлайн-версию Websocket инструмент：http://tools.emqx.io。

Подключение MQTT-брокера

Откройте адрес с помощью браузера http://tools.emqx.io,Нажмите на левый нижний уголиз New Connection кнопку и заполните информацию о ссылке в правом поле, заполните необходимые поля и нажмите Connect кнопка, чтобы создать ссылку и подключиться к Broker。

пресс-релиз

После успешного подключения нажмите на правый нижний угол из Write a message Появится окно пресс-релиза, заполните его. Topic и Payload Затем щелкните значок отправки, чтобы опубликовать сообщение.

Подписка на тему

• Подпишитесь на общие темы в середине Subscriptions В модуле подпишитесь hello тема. Дай в это время hello Когда тема отправит сообщение, оно будет получено в списке сообщений (получено сообщение слева).

• Подпишитесь на темы с подстановочными знаками Подпишитесь на темы с подстановочными знаками testtopic/#,и дать testtopic/1 Тема отправляет сообщение, и сообщение будет получено в списке сообщений.

Издатель: Лидер стека программистов полного стека, укажите источник для перепечатки: https://javaforall.cn/141808.html Исходная ссылка: https://javaforall.c