Брокер сообщений

Брокер сообщений — это программный компонент, который принимает сообщения от систем-отправителей, хранит их и передаёт системам-получателям в нужный момент. Брокер разрывает прямую связь между отправителем и получателем: отправитель не ждёт ответа и не знает, когда сообщение будет обработано.

Отправитель публикует сообщение в брокер и продолжает работу. Брокер сохраняет сообщение в очереди или топике. Получатель забирает сообщение тогда, когда готов его обработать. Если получатель временно недоступен — сообщение ждёт в брокере и не теряется. Популярные реализации: Apache Kafka, RabbitMQ, ActiveMQ, NATS.

Брокер управляет несколькими ключевыми аспектами: порядком доставки, количеством попыток при сбое, маршрутизацией по типу сообщения и хранением необработанных сообщений в специальной очереди (Dead Letter Queue).

Брокер сообщений критичен там, где системы работают с разной скоростью или имеют разную доступность. Интернет-магазин принимает тысячи заказов в минуту в пиковые периоды — брокер буферизует их и передаёт в складскую систему WMS с той скоростью, с которой та способна обрабатывать. Без брокера WMS либо перегружается и падает, либо часть заказов теряется.

Для финансовых операций, производственных заданий и логистических событий брокер обеспечивает гарантию того, что ни одно сообщение не будет потеряно даже при сбое одной из систем.

ESB — это полноценная интеграционная платформа с маршрутизацией, трансформацией, мониторингом и оркестрацией. Брокер сообщений — специализированный компонент только для надёжной передачи сообщений. ESB часто включает брокер как один из своих внутренних механизмов. Использовать брокер напрямую имеет смысл там, где нужна высокая пропускная способность и минимальная задержка — без сложной логики маршрутизации.