Saga управляет бизнес-транзакцией, охватывающей несколько сервисов, как последовательность локальных транзакций. Если шаг не выполняется, saga запускает компенсирующие транзакции для отката предыдущих шагов — отсутствует распределённый откат.
Двухфазный commit между сервисами медленный, блокирует ресурсы и создаёт связанность доступности. Sagas обеспечивают итоговую консистентность без распределённых блокировок.
Сервисы реагируют на события друг друга; нет центрального координатора.
Order ─OrderCreated→ Payment ─PaymentDone→ Inventory ─Reserved→ Shipping
◀───────── (on failure, each emits a compensating event) ─────────
Оркестратор говорит каждому сервису, что делать, и реагирует на результаты.
┌───────────── Saga Orchestrator ─────────────┐
▼ ▼ ▼ ▼
reservePayment reserveStock createShipment (on fail: compensate all)
| Аспект | Хореография | Оркестрация |
|---|---|---|
| Координация | Распределённая (события) | Централизованная |
| Связанность | Слабее | Координатор знает поток |
| Видимость | Сложно отследить | Легко отследить |
| Лучше всего для | Простые, несколько шагов | Сложные, много шагов |
Компенсирующие транзакции должны быть идемпотентными и обрабатывать случай, когда исходный шаг частично успешен. Проектируйте их внимательно.
Sagas — это способ поддерживать консистентность данных между сервисами без затрат и связанности распределённых транзакций.
Выбор между хореографией и оркестрацией — это компромисс между простотой и видимостью: события масштабируются слабо связанно, но становятся запутанными, в то время как оркестратор централизует сложную логику ценой одного дополнительного компонента.