Распределенная in‑memory система очередей сообщений. Позволяет создавать очереди с различной архитектурой в зависимости от потребностей бизнеса
С помощью очереди сообщений различные компоненты системы могут обмениваться информацией. Компонент‑источник добавляет сообщение в очередь, как в буфер. Очередь гарантирует, что сообщение не будет утеряно, и осуществляет доставку до компонента‑получателя.
Очереди нужны для управления потоком запросов и задач в системах, чтобы обеспечить порядок их выполнения и избежать перегрузки.
Очереди повышают отказоустойчивость и масштабируемость всей системы, позволяют выполнять асинхронные операции, упрощают процесс интеграции сервисов и приложений.
Технологический стек чрезмерно разрастается, когда вы используете очереди и хранилища данных от разных вендоров
Open‑Source технологии требуют большого ресурса на разработку
Большинство существующих решений хранят данные на диске, ресурсы которого ограничены
Классическая очередь с возможностью отправки отложенных сообщений и настройкой приоритетов.
SQ идеально подходит для обработки асинхронных задач и в тех случаях, когда необходимо приоритезировать некоторые задачи.
Примеры кейсов:
Брокер, гарантирующий строгий порядок обработки сообщений.
Потребители получают только те сообщения, на которые подписаны. Это уменьшает ненужный трафик данных и повышает эффективность обработки. Данная архитектура гарантирует максимально высокую пропускную способность.
Архитектура MQ, в сравнении с SQ,
FIFO: первый элемент, добавленный в очередь, обрабатывается первым
Очередь с приоритетами: извлекает элементы согласно приоритету
Отложенные сообщения
Подписка на сообщения с функцией фильтрации
Дедупликация при публикации
Создание индексов по сообщениям
Поддержка шардирования
Поддержка синхронной и асинхронной репликации
Тип взаимодействия
Put/
Publish/
Протокол взаимодействия
IPROTO
gRPC/
Способ роутинга запросов
Роутер (инстанс Tarantool)
gRPC-сервер
Расскажите о ваших задачах, и мы соберем
для вас решение на Tarantool