Я сейчас изучаю паттерн Саги. Большинство примеров, похоже, сосредоточено на сагах об оркестровке, где у нас есть одна центральная служба координатора выполнения саг, которая отправляет и принимает сообщения / события. К сожалению, информации о том, как реализовать саги о хореографии, кажется, немного не хватает.
В дизайне, управляемом предметной областью, в идеале у нас есть несколько ограниченных контекстов, где каждый ограниченный контекст является автономным микросервисом. Если микросервис A хочет взаимодействовать с другим микросервисом B, мы используем события интеграции. События интеграции публикуются и подписываются с использованием некоторой асинхронной связи - RabbitMQ, служебная шина Azure.
Предположим, мы хотим запустить какую-то сагу, например, где нам нужно выполнять транзакции в Службе заказов и Службе поддержки клиентов - как именно службы взаимодействуют друг с другом? Это просто обычные интеграционные события или что-то совсем другое?
Как я это вижу и как показано на рисунке ниже (исходный код), Saga будет выполнена так способ:
- Создан новый заказ. Статус имеет значение Pending, и генерируется событие домена OrderSubmittedDomainEvent.
- Обработчик событий домена получает событие домена OrderSubmittedDomainEvent, затем создает и отправляет событие интеграции ReserveCreditIntegrationEvent.
- Служба поддержки клиентов получает событие интеграции ReserveCreditIntegrationEvent.
- Он пытается зарезервировать кредит клиента.
- Если кредит успешно зарезервирован, генерируется событие домена CustomerCreditReservedDomainEvent.
- Обработчик событий домена получил событие домена CustomerCreditReservedDomainEvent, он создает и отправляет событие интеграции CreditReservedIntegrationEvent.
- Служба заказов получает событие интеграции CreditReservedIntegrationEvent и устанавливает для статуса заказа значение Подтверждено.
- сага завершена.
Это правильный подход?
