Digital Q.MessageBroker предназначен для организации обмена сообщениями между приложениями в микросервисных и гибридных архитектурах с использованием технологий Kafka и Artemis.
Решение централизует взаимодействие между компонентами, обеспечивая контроль очередности обработки сообщений и стабильную передачу данных при высокой нагрузке.
Краткое описание
Digital Q.MessageBroker объединяет управление всеми каналами обмена и позволяет использовать различные подходы в зависимости от архитектуры: Kafka применяется для высокопроизводительных сценариев между микросервисами, а Artemis — для интеграции в гибридных средах с поддержкой протоколов и гарантированной доставкой сообщений.
Kafka — это распределенная платформа потоковой обработки данных, ориентированная на высокую пропускную способность, горизонтальное масштабирование и работу с потоками событий в реальном времени.
Artemis — это брокер сообщений с поддержкой стандартных протоколов обмена, обеспечивающий надежную доставку сообщений, очереди и работу в корпоративных интеграционных сценариях.
Apache Kafka технологически входит в состав Digital Q.MessageBroker, а также используется в Digital Q.Integration для организации взаимодействия между различными информационными системами. Это позволяет применять единый подход к обмену сообщениями как внутри микросервисной архитектуры, так и при интеграции разнородных решений.
Ключевые характеристики
2 млн сообщений в секунду — уровень производительности, достигаемый при организации обмена данными в распределенной среде с использованием потоковой обработки.
7000+ организаций банковского сектора применяют решения на основе Kafka для построения высоконагруженных систем обмена сообщениями и событийной архитектуры.
0 остановок обеспечивается при работе брокера в кластерной конфигурации за счет отказоустойчивости и распределенной архитектуры.
Преимущества
Функционально брокеры сообщений, по данным вендоров, примерно идентичны. Разница для крупного бизнеса заключается в экспертизе вендора, опыте проектов, поддержке и намерении развивать продукт с учетом бэклога заказчика. Именно такой подход и является одним из ключевых преимуществ компании Диасофт.
Digital Q.MessageBroker отличается высокой гибкостью настройки и широкими возможностями для конфигурирования и отладки. В отличие от ряда конкурентных решений, которые поставляются по принципу «как есть» и требуют доработок силами заказчика, подход Диасофт предполагает внедрение под ключ с учетом особенностей конкретной архитектуры и бизнес-процессов.
При этом на практике возникают задачи не только по настройке самого брокера, но и по адаптации бизнес-приложений, использующих его для обмена данными. В результате особое значение приобретает комплексный подход к сопровождению, включающий поддержку как инфраструктурного уровня, так и прикладных систем.
Дополнительно на рынке ожидается появление коробочного решения на базе Digital Q.MessageBroker, которое позволит упростить внедрение и сократить сроки запуска для типовых сценариев использования.
Решаемые задачи (примеры)
Публикация событий из мастер-системы
В сценариях интеграции внешним системам требуется получать события от мастер-системы по мере их возникновения, например при изменении состояния продукта или клиента. Для этого используются адаптеры, которые формируют сообщения и публикуют их в брокер.
Digital Q.MessageBroker обеспечивает асинхронную доставку сообщений микросервисам-потребителям, что позволяет разгрузить мастер-систему и обеспечить масштабируемость. Архитектура включает мастер-систему, адаптер публикации, брокер сообщений и набор сервисов-потребителей.
Хореография бизнес-процессов на основе Camunda
В распределенных системах бизнес-процессы могут выполняться без центрального координатора, где каждый сервис отвечает за свою часть логики. Такой подход требует надежного механизма обмена сообщениями между участниками процесса.
Digital Q.MessageBroker обеспечивает асинхронное взаимодействие между сервисами, поддерживая выполнение распределенного процесса с использованием Camunda в embedded-режиме. Сервисы обмениваются событиями через брокер, формируя согласованное выполнение бизнес-логики.
Инфраструктура
Инфраструктура решения включает несколько уровней, обеспечивающих развертывание и эксплуатацию микросервисной архитектуры. На уровне микросервисов используются компоненты, отвечающие за оркестрацию контейнеров, управление сервисами и обмен сообщениями между ними.
Операционные системы обеспечивают базовый уровень управления вычислительными ресурсами и запуск прикладного программного обеспечения, при этом акцент делается на импортонезависимые решения. Системы виртуализации позволяют создавать изолированные среды выполнения и эффективно использовать физические ресурсы серверов.
Архитектура решения
Брокер сообщений располагается между издателями и потребителями, обеспечивая передачу сообщений через очереди и темы. Каждое сообщение относится к определенной теме, что позволяет логически разделять потоки данных.
Чтение сообщений может выполняться параллельно на уровне тем, при этом внутри одной партиции сохраняется строгий порядок обработки. Для повышения производительности применяется партиционирование, при котором большие сообщения разбиваются на части и обрабатываются распределенно.
Протоколы
Digital Q.MessageBroker поддерживает различные протоколы обмена сообщениями, что позволяет интегрировать его с широким спектром систем и приложений.
AMQP — протокол прикладного уровня для обмена сообщениями с поддержкой очередей, маршрутизации и гарантированной доставки.
OpenWire — бинарный протокол, используемый в экосистеме ActiveMQ для высокопроизводительного обмена сообщениями.
MQTT — легковесный протокол для передачи сообщений в условиях ограниченных ресурсов, широко применяется в IoT.
STOMP — текстовый протокол обмена сообщениями, ориентированный на простоту интеграции и совместимость с различными платформами.
HornetQ — протокол и система обмена сообщениями, обеспечивающая высокую производительность и надежность в корпоративных системах.
Центр мониторинга
В системе предусмотрены инструменты мониторинга, позволяющие отслеживать состояние брокера сообщений, включая доступность компонентов, загрузку серверов и скорость обработки сообщений.
Отображаются очереди, задержки и показатели потребления, что позволяет оперативно выявлять узкие места. Для Kafka и Artemis реализованы отдельные центры управления, обеспечивающие контроль и администрирование соответствующих компонентов.
Заключение
Digital Q.MessageBroker представляет собой инфраструктурный компонент для организации обмена сообщениями в распределенных системах. Решение обеспечивает асинхронное взаимодействие между сервисами, поддержку различных протоколов и возможность работы в высоконагруженных сценариях.
Использование брокера позволяет разделить компоненты системы, повысить устойчивость архитектуры и обеспечить контролируемую обработку сообщений в микросервисной и гибридной среде.