사가(Saga) 패턴

Java code

import java.util.*;

public class SagaPattern {
    // 사가 단계 정의
    interface SagaStep {
        void execute() throws Exception;
        void compensate(); // 보상 트랜잭션
    }

    // 사가 오케스트레이터
    static class SagaOrchestrator {
        private final List<SagaStep> steps = new ArrayList<>();
        private final Deque<SagaStep> completed = new ArrayDeque<>();

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

        void execute() {
            for (SagaStep step : steps) {
                try {
                    step.execute();
                    completed.push(step);
                } catch (Exception e) {
                    System.out.println("실패! 보상 시작: " + e.getMessage());
                    rollback();
                    throw new RuntimeException("사가 실패", e);
                }
            }
            System.out.println("사가 성공!");
        }

        private void rollback() {
            while (!completed.isEmpty()) {
                SagaStep step = completed.pop();
                try {
                    step.compensate();
                } catch (Exception e) {
                    System.err.println("보상 실패: " + e.getMessage());
                }
            }
        }
    }

    public static void main(String[] args) {
        SagaOrchestrator saga = new SagaOrchestrator();
        saga.addStep(new SagaStep() {
            public void execute() { System.out.println("1. 재고 차감"); }
            public void compensate() { System.out.println("1. 재고 복구"); }
        });
        saga.addStep(new SagaStep() {
            public void execute() { System.out.println("2. 결제 처리"); }
            public void compensate() { System.out.println("2. 결제 취소"); }
        });
        saga.addStep(new SagaStep() {
            public void execute() throws Exception {
                System.out.println("3. 배송 요청");
                throw new Exception("배송 서비스 장애");
            }
            public void compensate() { System.out.println("3. 배송 취소"); }
        });

        try { saga.execute(); } catch (Exception e) {
            System.out.println("최종: " + e.getMessage());
        }
    }
}