РЕАЛІЗАЦІЯ SAGA З ВИКОРИСТАННЯМ ШАБЛОНУ OUTBOX

Анотація

Мікросервісна архітектура надає ряд переваг, до яких можна віднести гнучкість, стійкість до відмов, можливість повторного використання функціональності. Але розподілений характер таких систем призводить до складності управління взаємодією та узгодженістю даних між різними сервісами. В додатках необхідно виконувати транзакції, які охоплюють кілька сервісів, кожен з яких має власну базу даних і є ізольованим. Для управління транзакціями в системах з мікросервісною архітектурою використовується шаблон проєктування Saga, який розподілену транзакцію представляє як послідовність локальних транзакцій. Зазвичай локальна транзакція оновлює базу даних сервісу та публікує повідомлення, щоб ініціювати наступну локальну транзакцію у сазі. Оновлення бази даних та публікація повідомлення повинні виконуватися атомарно, інакше система може перейти у неузгоджений стан. Це може статися, якщо, наприклад, після фіксації змін у базі даних повідомлення не буде надіслано через збій в мережі. Для забезпечення узгодженості даних можна використовувати шаблони Transitional Outbox або Event Sourcing. Стаття присвячена дослідженню особливостей застосування цих шаблонів при реалізації розподілених транзакцій за допомогою Saga, виявленню переваг та недоліків кожного з підходів. Event Sourcing дозволяє зберігати історію зміни стану об’єкта, відтворювати події для відновлення його стану на певний момент часу. Недоліком цього шаблону є те, що він складний у вивченні. У разі використання складних запитів до бази даних у поєднанні з Event Sourcing слід використовувати патерн CQRS. В роботі представлена архітектура додатку на основі мікросервісів, побудована з використанням шаблонів проєктування Saga та Outbox. Сервіси взаємодіють між собою асинхронно за допомогою Apache Kafka та конекторів Debezium, які відстежують зміни в базах даних та надсилають повідомлення в брокер. Сервіси отримують повідомлення з брокеру відразу після публікації.