Что такое паттерн Outbox? Для чего он используется?

В современных приложениях часто нужно обновить базу данных и отправить сообщение о этом событии (например, «заказ создан») в очередь (например, Kafka или RabbitMQ). Проблема в том, что эти две операции — запись в БД и отправка сообщения — независимы и могут завершиться с ошибкой одна без другой.

Проблема, которую решает Outbox:
Что, если база данных обновилась, но приложение упало до отправки сообщения? Сообщение будет потеряно, и другие сервисы не узнают о событии. И наоборот, сообщение может быть отправлено, а транзакция — откатиться.

Как работает паттерн Outbox:

1. В рамках одной транзакции приложение выполняет два действия:

   • Изменяет бизнес-данные в основной таблице БД.

   • Добавляет запись о событии, которое нужно отправить, в специальную таблицу outbox в той же самой базе данных.

2. Если транзакция фиксируется (commit), то обе записи (бизнес-данные и событие) сохраняются атомарно — либо вместе, либо не сохраняются вообще.

3. Отдельный процесс-релеектор (например, фоновый джоб) периодически опрашивает таблицу outbox на наличие новых записей.

   • Для каждой найденной записи он отправляет сообщение в брокер (Kafka).

   • После успешной отправки запись удаляется из таблицы outbox (или помечается как отправленная).

Пример псевдокода внутри сервиса:

@Transactional
public void createOrder(Order order) {
    // 1. Сохраняем бизнес-объект в основной таблице
    orderRepository.save(order);

    // 2. В той же транзакции сохраняем событие в Outbox
    OutboxEvent event = new OutboxEvent();
    event.setAggregateId(order.getId());
    event.setType("OrderCreated");
    event.setPayload(...); // данные о заказе
    outboxRepository.save(event);
}
// Транзакция фиксируется. Теперь и заказ, и событие гарантированно сохранены.

Для чего используется:

• Гарантированная доставка сообщений в асинхронных системах.

• Реализация механизма транзакционных исходящих сообщений.

• Построение надежного Event-Driven-архитектуры.

Вывод: Паттерн Outbox — это надежное решение для согласованной публикации событий при работе с базой данных. Его стоит применять всегда, когда важно гарантировать, что сообщение о событии будет отправлено ровно один раз после успешного сохранения данных.