Как организовать взаимодействие сервисов через брокер сообщений?

Question

Через брокер сервисы могут общаться асинхронно: отправитель публикует сообщение, получатель потребляет его из очереди или подписывается на события. Важно выбрать модель (команды или события), определить гарантии доставки (обычно at-least-once), настроить подтверждения, ретраи и очередь “мертвых писем” (DLQ). Также нужно продумать идемпотентность обработчиков и версионирование формата сообщения.

YeaHub · Accepted Answer

Брокер сообщений решает две задачи: снижает связность сервисов и дает буфер между производителем и потребителем.Определение: Брокер сообщений — инфраструктурный компонент, который принимает сообщения от продюсеров и доставляет их консюмерам по заданным правилам (очереди, маршрутизация, подписки).1) Выбор модели: команды vs событияКоманда (command)“Сделай X” (адресно, ожидается обработка конкретным сервисом).Пример: GenerateReport.Событие (event)“X произошло” (может заинтересовать много подписчиков).Пример: UserRegistered.Практическое правило:Команды — когда нужен конкретный исполнитель.События — когда важен факт и возможны несколько реакций.2) Гарантии доставки и последствияAt-most-once: быстро, но возможны потери.At-least-once: сообщений не теряем, но возможны дубликаты.Exactly-once: дорого и сложно, часто достигается комбинацией идемпотентности + транзакционных паттернов.В реальных системах чаще выбирают at-least-once и делают обработчики идемпотентными.3) Ошибки, ретраи и DLQAck/Nack (подтверждения)Консюмер подтверждает успешную обработку (ack), иначе брокер/клиент решает, что делать дальше.Retry policyОграничение попыток, задержки (backoff), джиттер.DLQ (dead-letter queue)Сообщения, которые не удалось обработать после N попыток, уходят в отдельную очередь для разборов.4) Идемпотентность (чтобы дубликаты были безопасны)Способы:Дедупликация по message_id в хранилище.Upsert-логика по бизнес-ключу.“Состояния” обработки задачи (pending → done), чтобы повтор не ломал систему.Мини-пример (идея дедупликации):# Воркер: если message_id уже обработан — выходим
if processed_store.exists(message_id):
    return
# ... обработка ...
processed_store.save(message_id)
ВыводНормальная схема через брокер — это не только “отправили и забыли”: она включает контракты (command/event), ack, ретраи, DLQ и идемпотентность, иначе при сбоях появятся потери, дубликаты и хаос.