Введение

В мире распределенных систем и микросервисов управление сложными бизнес-транзакциями, охватывающими несколько сервисов, может оказаться непростой задачей. Одним из популярных решений этой проблемы является шаблон Saga. Шаблон Saga позволяет обеспечить согласованность и надежность данных в распределенных системах путем координации серии локальных транзакций, также известных как шаги саги. В этой статье мы рассмотрим различные методы реализации шаблона Saga, а также приведем примеры кода, которые помогут вам освоить этот мощный архитектурный шаблон.

1. Сага на основе хореографии

Подход Saga на основе хореографии основан на управляемой событиями связи между сервисами для координации и управления этапами Saga. Каждая служба публикует события после завершения локальной транзакции, а другие службы подписываются на эти события для выполнения соответствующих задач. Вот пример на Python с использованием шины событий:

def place_order(order):
    # Perform order placement logic
    event_bus.publish("OrderPlacedEvent", order_id=order.id)
@event_handler("OrderPlacedEvent")
def handle_order_placed(event):
    # Perform inventory update logic
    event_bus.publish("InventoryUpdatedEvent", order_id=event.order_id)

2. Сага на основе оркестровки

В подходе Saga, основанном на оркестрации, для управления этапами саги используется центральный координатор, часто называемый оркестратором саги. Оркестратор отвечает за координацию выполнения каждого шага и выполнение компенсирующих действий в случае возникновения сбоев. Вот пример на Java с использованием конечного автомата:

@Saga
public class OrderSaga {
    @StartSaga
    public void placeOrder(Order order) {
        // Perform order placement logic
        order.setStatus("PLACED");
        orderRepository.save(order);
        orchestrateNextStep(order.getId());
    }
    @SagaEventHandler(associationProperty = "orderId")
    public void handleOrderPlaced(OrderPlacedEvent event) {
        // Perform inventory update logic
        order.setStatus("INVENTORY_UPDATED");
        orderRepository.save(order);
        orchestrateNextStep(order.getId());
    }
// Other saga steps and compensating actions
}

3. Сага о вознаграждении

Подход Saga, основанный на компенсации, ориентирован на компенсационные действия, а не на явный откат транзакций. Он включает в себя выполнение компенсирующих действий в обратном порядке, чтобы отменить последствия завершенных шагов саги. Вот пример в Node.js с использованием функции компенсатора:

async function placeOrder(order) {
    // Perform order placement logic
    await orderService.placeOrder(order);
    await compensationRegistry.registerCompensator(compensatePlaceOrder, order.id);
}
async function compensatePlaceOrder(orderId) {
    // Compensating logic to undo order placement
    await orderService.cancelOrder(orderId);
}

Заключение

Шаблон Saga предлагает мощное решение для управления сложными распределенными транзакциями в архитектурах микросервисов. Следуя подходу, основанному на хореографии, оркестрации или компенсации, вы можете обеспечить согласованность и надежность данных в нескольких службах. В зависимости от вашего конкретного варианта использования и требований вы можете выбрать наиболее подходящий метод реализации шаблона Saga. Освоение этого шаблона позволит вам создавать надежные и масштабируемые системы, которые эффективно обрабатывают сложные бизнес-транзакции.