Решение проблемы «двойной записи» в микросервисах с использованием шаблона транзакционных исходящих сообщений (Spring Bo ⇐ JAVA

[Anonymous]

Одна из самых больших проблем в распределенных системах — обеспечение согласованности данных, когда вам нужно обновить базу данных и одновременно уведомить другую службу (через Kafka/RabbitMQ). Если фиксация базы данных прошла успешно, но сообщение не было отправлено, ваша система теперь несовместима.
Чтобы решить эту проблему, я провел глубокое исследование шаблона транзакционных исходящих сообщений.
Сценарий, который я использовал: система заказов в Pizza Shop. Служба заказов сохраняет заказ, но если сообщение в Службу инвентаризации потеряно, у вас есть голодный клиент и испорченный запас на складе.
Что рассматривается в реализации:
Ловушка «двойной записи»: почему u/Transactional недостаточно, когда задействованы внешние брокеры.
Таблица исходящих: как рассматривать бизнес-логику и публикацию событий как одно неразрывное целое
Служба опроса: настройка службы запланированной ретрансляции для запроса и публикации необработанных событий.
Альтернативы: краткое упоминание CDC (Debezium) и шаблона Saga для более тяжелых требований.
Технический стек:
Java 21
Spring Boot 3.x
Kafka & Docker Рабочий стол
PostgreSQL
Я включил полную демонстрацию, показывающую как сценарий успеха (согласованность в конечном итоге), так и сценарий сбоя/отката (имитирующий ошибку 10/0, чтобы показать, как папка «Исходящие» предотвращает появление ложных сообщений).
Полное видео: https://youtu.be/HK4tH17lljM
Репозиторий GitHub: https://github.com/abchatterjee7
Мне хотелось бы услышать, как вы, ребята, обрабатываете распределенные транзакции, вы работаете в команде Outbox или предпочитаете для этого CDC/Debezium?

Подробнее здесь: https://stackoverflow.com/questions/798 ... nal-outbox