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

Реализация Saga в Java обычно включает:

Определение последовательности шагов (локальных транзакций).
Для каждого шага — реализация основного действия и компенсирующего (отменяющего) действия.
Оркестратор или хореограф, который управляет выполнением шагов и в случае ошибки запускает компенсирующие действия в обратном порядке.

Пример упрощённой реализации с использованием интерфейса:

public interface SagaStep {
    void execute() throws Exception;
    void compensate();
}

public class Saga {
    private List<SagaStep> steps = new ArrayList<>();

    public void addStep(SagaStep step) {
        steps.add(step);
    }

    public void execute() {
        List<SagaStep> executedSteps = new ArrayList<>();
        try {
            for (SagaStep step : steps) {
                step.execute();
                executedSteps.add(step);
            }
        } catch (Exception e) {
            // компенсируем выполненные шаги в обратном порядке
            for (int i = executedSteps.size() - 1; i >= 0; i--) {
                executedSteps.get(i).compensate();
            }
            throw new RuntimeException("Saga failed and was compensated", e);
        }
    }
}

В реальных системах часто используют фреймворки или брокеры сообщений для реализации асинхронных и распределённых саг.

Как реализовать Saga? Как это делать?