Что означает transactional consistency в паттерне Outbox?

Что означает transactional consistency в паттерне Outbox?

• Outbox — паттерн, обеспечивающий гарантированную доставку сообщений
• transactional consistency — согласованность данных и событий, сохраняемых в рамках одной транзакции
• основная бизнес-сущность и запись события фиксируются одновременно
• исключает рассогласование между данными и событиями при возникновении сбоев
• после этого события можно асинхронно отправлять из outbox
• имеет важное значение для надежного взаимодействия микросервисов
• используется для построения надежных интеграций в event-driven архитектуре

Развёрнутый ответ

Краткий ответ

Transactional consistency в рамках Outbox pattern означает гарантию того, что изменение в основной базе данных и создание связанного сообщения в Outbox выполняются как единая атомарная транзакция. Это основа надежной интеграции между микросервисами и отдельными компонентами: изменение состояния и публикация события согласованы и либо происходят вместе, либо не выполняются вовсе.

Основные аспекты

• В распределённых системах при публикации события, например через Kafka или RabbitMQ, возможна рассинхронизация: запись в БД уже изменена, но событие не отправлено, либо происходит обратная ситуация.
• Outbox pattern решает эту задачу: в пределах одной транзакции сохраняются и бизнес-данные, и событие в отдельной таблице Outbox. Благодаря этому транзакция БД получает гарантии ACID.
• Затем специальный процесс — poller или CDC — асинхронно извлекает записи из этой таблицы и публикует события во внешние системы. Поскольку запись в Outbox создана одновременно с изменением данных, сохраняются их порядок и согласованность.
• Такой подход повышает надежность межсервисного обмена и делает обработку сбоев проще, обеспечивая eventual consistency с надежными гарантиями.

Пример из практики

В проектах на PostgreSQL 14+ часто применяют Outbox, а публикацию реализуют с помощью Debezium или custom poller. Это гарантирует согласованность изменения заказа с событием для downstream сервисов, что особенно важно для финансовых транзакций и систем заказов, где требуется доставка exactly-once.