Как реализовать гарантированную доставку сообщений между микросервисами (паттерны Outbox, Saga)?

Question

Основные паттерны:Outbox: Сохранение сообщений в БД в рамках транзакции перед отправкойSaga: Оркестрация распределённой транзакции через последовательность событий с компенсациями

YeaHub · Accepted Answer

1. Паттерн Outbox:Шаги реализации:Приложение сохраняет данные и сообщение в одной транзакцииОтдельный процесс сканирует таблицу outboxОтправляет сообщения в брокерПомечает сообщение как отправленноеПример схемы БД:CREATE TABLE outbox ( id UUID PRIMARY KEY, aggregate_type TEXT NOT NULL, aggregate_id TEXT NOT NULL, event_type TEXT NOT NULL, payload JSONB NOT NULL, created_at TIMESTAMPTZ DEFAULT NOW() );2. Паттерн Saga:Типы реализации:Хореография: Сервисы обмениваются событиямиОркестрация: Центральный координатор управляет процессомПример оркестрируемой саги:public class OrderSaga : Saga, IAmStartedBy, IHandleMessage, IHandleMessage { public async Task Handle(PlaceOrder message) { await _paymentService.ProcessPayment(); } public async Task Handle(PaymentCompleted message) { await _shippingService.ScheduleDelivery(); MarkAsComplete(); } public async Task Handle(PaymentFailed message) { await _compensationService.CancelOrder(); MarkAsComplete(); } }Компенсационные действия:Для каждого этапа саги определяется обратное действиеПример: CancelReservation() при отмене заказа