Создание систем на базе обмена сообщениями стало распространенным архитектурным решением. С помощью брокера сообщений Digital Q.MessageBroker вы сможете объединить управление обменом сообщениями по всем используемым каналам, обеспечивая высокую производительность и надежность решения.
Задача построения инфраструктуры обмена сообщениями решается с использованием универсального инструмента, такого как Digital Q.MessageBroker, обеспечивающего поддержку множества протоколов и интеграций с различными системами.
Знакомые задачи, решаемые при организации обмена сообщениями
- НЕ ВСЕ СООБЩЕНИЯ ДОСТАВЛЯЮТСЯ ПОДПИСЧИКАМ
- ПРИ ПОВЫШЕНИИ НАГРУЗКИ СНИЖАЕТСЯ ПРОИЗВОДИТЕЛЬНОСТЬ
- НЕТ ГАРАНТИИ ДОСТАВКИ СООБЩЕНИЙ В ТРЕБУЕМОЙ ПОСЛЕДОВАТЕЛЬНОСТИ
Используемый брокер сообщений периодически не доставляет часть сообщений подписчикам.
С увеличением нагрузки на систему обмена сообщениями увеличивается время их доставки подписчикам. Автоматизация распараллеливания обмена сообщениями не эффективна и требует доработки прикладного решения.
Порядок доставки сообщений не гарантирует требуемой последовательности, что влияет на корректность настроенных бизнес-процессов.
Есть решение для построения простой системы обмена сообщениями!
Можно легко организовать процесс обмена сообщениями. Построение систем на базе обмена сообщениями является эффективным архитектурным решением, которое стало одним из самых распространенных. Используя брокер сообщений Digital Q.MessageBroker, вы легко настраиваете систему обмена сообщениями между компонентами ваших программных продуктов. Digital Q.MessageBroker – универсальный инструмент, который обеспечит надежность, производительность и масштабирование процесса обмена сообщениями между компонентами решения.
Какие задачи помогает решить Q.MESSAGEBROKER?
- Гарантия доставки — система не теряет сообщения;
- Управление масштабированием — система позволяет гибко настраивать масштабирование;
- Последовательность доставки — сообщения доставляются в требуемой последовательности.
Только цифры
До 2 млн сообщений в секунду — скорость обмена, которую обеспечивает Digital Q.MessageBroker, что на порядок выше, чем у альтернативных решений;
Более 7000 организаций в банковском секторе используют Kafka для решения своих задач уже сейчас;
0 остановок брокера сообщений при работе системы в кластерной конфигурации.
PBC платформы DIGITAL Q.MESSAGEBROKER
ТЕМА (TOPIC)
Тема – это категория или название канала, в котором хранятся и публикуются сообщения. Тема состоит из разделов (partitions). Темы в Digital Q.MessageBroker всегда многопользовательские, то есть тема может иметь ноль, одного или нескольких потребителей, которые подписываются на записанные в нее данные. Для каждой темы кластер Digital Q.MessageBroker поддерживает секционированный журнал, разбитый на разделы.
ИЗДАТЕЛЬ (PRODUCER)
Издатель – система, которая пишет сообщения для публикации. Издатели публикуют данные в темах по своему выбору. Издатель несет ответственность за выбор записи, которую следует назначить тому или иному разделу в теме. Это может быть сделано в циклическом режиме, просто чтобы сбалансировать нагрузку. Это может быть сделано и в соответствии с некоторой семантической функцией разделения публикуемых данных (скажем, на основе некоторого ключа в записи).
ПОДПИСЧИК (CONSUMER)
Подписчик – обработчик сообщений, который читает опубликованные сообщения. Подписчики помечают себя именем группы потребителей, и каждая запись, опубликованная в теме, доставляется одному экземпляру потребителя в каждой группе подписчиков. Экземпляры подписчиков могут находиться в отдельных процессах или на отдельных машинах. Если все экземпляры подписчиков имеют одну и ту же группу потребителей, записи будут сбалансированы по нагрузке и распределены по экземплярам потребителей. Если все экземпляры подписчиков имеют разные группы потребителей, то каждая запись будет транслироваться всем процессам потребителей.
РАЗДЕЛ (PARTITION)
Раздел – логическая сущность, которая основана на разделении каждой темы на одну, две и более частей. Каждое сообщение, находящееся в любом из разделов, имеет так называемое смещение (offset). Смещение – порядковый номер сообщения в разделе. Каждый раздел представляет собой упорядоченную, неизменную последовательность записей, к которой постоянно добавляются новые – это структурированный журнал. Каждой записи в разделах присваивается последовательный идентификационный номер, называемый смещением, который однозначно идентифицирует каждую запись в разделе. Кластер Digital Q.MessageBroker длительно сохраняет все опубликованные записи (в независимости от того, были они обработаны или нет), настраивая срок хранения. Например, если политика хранения установлена на два дня, то в течение двух дней после публикации запись будет доступна для использования. После этого она будет удалена для освобождения места. Производительность Digital Q.MessageBroker, фактически, постоянна в отношении размера данных, поэтому хранение данных в течение длительного времени не является проблемой.
