Компания EMQ объявила о выпуске платформы EMQX Enterprise 6.2 — значимое развитие MQTT-брокера для задач промышленной автоматизации и промышленного интернета вещей (IIoT). Новая версия добавляет фундаментальные возможности для координации автономных агентов, управления устройствами и обеспечения согласованности данных на уровне брокера.
Ключевые нововведения
🤖 Agent-to-Agent (A2A) Registry
Впервые автономные AI-агенты могут открывать друг друга через нативный MQTT-механизм:
- Агенты регистрируются через топики $a2a/v1/discovery/{org_id}/{unit_id}/{agent_id}
- Поддержка emerging-спецификаций A2A протокола
- Event-driven открытие без традиционного polling
- Live presence awareness на основе MQTT session state
«EMQX 6.2 расширяет MQTT за пределы передачи данных в нативную координацию между агентами» — отметил Бенниу Джи, VP of Product в EMQ Technologies.
🏭 Unified Namespace Governance
Новый плагин обеспечивает:
- Валидацию схем данных на уровне брокера
- Предотвращение дрейфа топик-структур в промышленных системах
- Fail-fast подход для блокирования невалидных данных до распространения
🔄 Динамическое управление устройствами
Критичная функция для управления парками промышленного оборудования:
- Топик $SETOPTS/mqtt/keepalive — изменение keepalive интервалов в runtime
- Топик $SETOPTS/mqtt/keepalive-bulk — массовые обновления флота устройств
Производитель электромобилей с парком 100 000+ единиц может корректировать работу устройств без разрывов сессий.
🔍 Фильтрация подписок — новая возможность для IIoT
Особое внимание в EMQX 6.2 уделяется возможности фильтрации данных на уровне брокера. Это решает одну из самых болезненных проблем промышленных систем — избыточная нагрузка на edge-устройства.
Как это работает:
Теперь можно подписываться на топики с условиями фильтрации через MQTT 5.0 User Properties. Клиент получает только те сообщения, которые соответствуют заданным критериям, а остальная нагрузка отфильтровывается сервером.
Пример на практике:
bash
# Обычная подписка на все данные о температуре
sensor/+/temperature
# Новая подписка с фильтрацией
sensor/+/temperature?location=roomA&valuealue>25
sensor/+/temperature
# Новая подписка с фильтрацией
sensor/+/temperature?location=roomA&valuealue>25
При подписке клиент получает сообщения только с топиками, соответствующими критериям:
- Клиент подписывается на топики: sensor/roomA/temperature, sensor/roomB/temperature, sensor/roomC/temperature
- Но получает только те сообщения, где location = roomA и value > 25
Преимущества:
- Снижение нагрузки на edge-устройства — edge-контроллеры не обрабатывают лишние данные, экономия процессорного времени и памяти
- Экономия трафика — клиент получает только релевантные данные, снижение потребления bandwidth в высокоскоростных промышленных сетях
- Релевантность данных — клиенты подписываются на специфичные подмножества данных, например: sensor/+/pressure?unit=kpa&status=active
Реальный кейс:
При 1000 сенсорах в различных помещениях:
Без фильтрации:
- 500+ сообщений в секунду на клиент
- Edge-контроллер обрабатывает все данные
- 100 Мбит/с на сети
С фильтрацией:
- 1-5 сообщений в секунду на клиент
- Фильтрация на брокере
- 5-10 Мбит/с на сетях
Это критично для промышленных систем с ограниченной производительностью edge-устройств.
Технические характеристики
- Максимальное число подключений в кластере: 100 миллионов+
- Задержка доставки сообщений: менее 1 миллисекунды
- Throughput на узел: миллионы сообщений в секунду
- Протокол: MQTT 5.0 и 3.x
- Расширенные протоколы: MQTT over QUIC, CoAP, LwM2M
Целевые применения в промышленности
Автомобилестроение — управление парком EV, OTA-обновления, диагностика
Производство — predictive maintenance, OEE-мониторинг, контроль качества в реальном времени
Энергетика — подключение 10 миллионов+ точек, балансировка сети, обнаружение утечек
Логистика — мониторинг грузов, V2X-коммуникация, управление автопарком
Доступность и ресурсы
- Готовность: EMQX Enterprise 6.2 доступна немедленно
- Release notes: https://github.com/emqx/emqx/releases/tag/6.2.0
- Документация: https://docs.emqx.com/en/emqx/v6.2/
- Демонстрация: https://www.emqx.com/en
Значение дляавтоматизации
Новый релиз закрывает критичный пробел в промышленных системах:
- Согласованность данных — валидация на уровне брокера снижает количество ошибок на downstream-системах
- Масштабируемость — поддержка миллионов устройств в единой инфраструктуре
- Автономность — координация AI-агентов без централизованного управления
- Оперативность — динамическая конфигурация без перезагрузок
#EMQX #IndustrialAutomation #IIoT #MQTT #Industry40 #Engineers #IoT #Automation #OTITConvergence #PredictiveMaintenance #SmartManufacturing
Подготовлено на основе официального пресс-релиза EMQ Technologies