이벤트 드리븐 아키텍처 — 이벤트 소싱과 CQRS의 설계 원리

// 전통 CRUD: 현재 잔액만 저장
계좌 잔액: 50,000원

// 질문: 이 잔액이 어떻게 만들어졌는지 알 수 있나요?
// → 별도의 이력 테이블을 만들지 않는 한 알 수 없음

// 이벤트 소싱: 모든 변화를 기록
1. AccountOpened  { amount: 0 }
2. MoneyDeposited { amount: 100,000 }
3. MoneyWithdrawn { amount: 30,000 }
4. MoneyWithdrawn { amount: 20,000 }
// → 현재 잔액: 50,000원 (이벤트를 순서대로 적용한 결과)

[커맨드] → [도메인 모델] → [이벤트 생성] → [이벤트 스토어에 저장]
                ↑                                    |
                |                                    ↓
           [이벤트 재생] ←──────────────── [이벤트 스토어]

// 이벤트 정의
public sealed interface AccountEvent {
    record AccountOpened(String accountId, BigDecimal initialBalance) implements AccountEvent {}
    record MoneyDeposited(String accountId, BigDecimal amount) implements AccountEvent {}
    record MoneyWithdrawn(String accountId, BigDecimal amount) implements AccountEvent {}
}

// 도메인 모델: 이벤트를 적용해서 상태를 만든다
public class Account {
    private String id;
    private BigDecimal balance = BigDecimal.ZERO;

    // 이벤트 재생으로 현재 상태 복원
    public static Account replay(List<AccountEvent> events) {
        Account account = new Account();
        events.forEach(account::apply);
        return account;
    }

    // 각 이벤트에 따라 상태 변경
    private void apply(AccountEvent event) {
        switch (event) {
            case AccountOpened e -> {
                this.id = e.accountId();
                this.balance = e.initialBalance();
            }
            case MoneyDeposited e -> this.balance = this.balance.add(e.amount());
            case MoneyWithdrawn e -> this.balance = this.balance.subtract(e.amount());
        }
    }

    // 비즈니스 규칙 검증 후 이벤트 생성
    public MoneyWithdrawn withdraw(BigDecimal amount) {
        if (this.balance.compareTo(amount) < 0) {
            throw new IllegalStateException("잔액 부족");
        }
        return new MoneyWithdrawn(this.id, amount);
    }
}

[클라이언트] ─── 쓰기 요청 ──→ [Command Model] ──→ [Write DB]
                                                        |
                                                   이벤트 발행
                                                        ↓
[클라이언트] ←── 읽기 응답 ─── [Query Model]  ←── [Read DB]

// 쓰기 측: 복잡한 비즈니스 로직
public class OrderCommandService {
    public void placeOrder(PlaceOrderCommand cmd) {
        // 재고 확인, 가격 검증, 쿠폰 적용 등 비즈니스 규칙
        Order order = Order.create(cmd);
        orderRepository.save(order);
        eventPublisher.publish(new OrderPlaced(order.getId(), order.getItems()));
    }
}

// 읽기 측: 조회에 최적화된 비정규화 모델
public class OrderQueryService {
    // 읽기용 DB에서 바로 조회 (조인 없이)
    public OrderSummaryDto getOrderSummary(String orderId) {
        return orderReadRepository.findSummaryById(orderId);
    }

    // 이벤트를 받아서 읽기 모델 업데이트
    @EventListener
    public void on(OrderPlaced event) {
        OrderSummary summary = new OrderSummary(
            event.orderId(),
            event.items(),
            calculateTotal(event.items())
        );
        orderReadRepository.save(summary);
    }
}

이벤트 1 → 이벤트 2 → ... → 이벤트 999 → [스냅샷 저장]
                                             ↓
새로운 조회 시: 스냅샷 + 이벤트 1000 ~ 현재만 재생

OrderPlaced → OrderCancelled  // 주문을 취소하는 게 아니라, 취소 이벤트를 추가