Event Sourcing 완벽 가이드

이벤트 소싱은 애플리케이션의 상태 변화를 이벤트의 시퀀스로 저장하는 패턴입니다. 데이터의 모든 변경 이력을 추적하고, 과거 상태를 재구성할 수 있는 강력한 아키텍처 패턴을 학습합니다.

---

---

들어가며

이 글에서는 Event Sourcing 완벽 가이드에 대해 상세히 알아보겠습니다. 총 10가지 주요 개념을 다루며, 각각의 개념에 대한 설명과 실제 코드 예제를 함께 제공합니다.

목차

1. 기본_이벤트_정의
2. 이벤트_스토어_구현
3. 애그리게이트_루트_설계
4. 이벤트_재생_패턴
5. 스냅샷_최적화
6. 명령_핸들러_패턴
7. 이벤트_버전관리
8. 프로젝션_생성
9. 이벤트_발행_구독
10. 보상_이벤트_처리

---

1. 기본 이벤트 정의

개요

이벤트는 과거에 발생한 사실을 나타내는 불변 객체입니다. 이벤트 이름은 과거형으로 작성합니다.

코드 예제

interface Event {
  type: string;
  timestamp: Date;
  aggregateId: string;
}

interface UserCreatedEvent extends Event {
  type: 'USER_CREATED';
  email: string;
  name: string;
}

설명

이벤트는 시스템에서 발생한 중요한 사실을 기록합니다. 불변 객체로 설계하여 과거 데이터의 무결성을 보장합니다.

---

2. 이벤트 스토어 구현

개요

이벤트 스토어는 모든 이벤트를 순차적으로 저장하는 저장소입니다. 추가만 가능하고 수정/삭제는 불가능합니다.

코드 예제

class EventStore {
  private events: Event[] = [];

  append(event: Event): void {
    this.events.push(event);
  }

  getEvents(aggregateId: string): Event[] {
    return this.events.filter(e => e.aggregateId === aggregateId);
  }
}

설명

이벤트 스토어는 append-only 구조로 모든 변경 이력을 저장합니다. 특정 집합체의 이벤트를 조회할 수 있습니다.

---

3. 애그리게이트 루트 설계

개요

애그리게이트는 이벤트를 생성하고 자신의 상태를 관리하는 도메인 객체입니다. 이벤트를 통해서만 상태가 변경됩니다.

코드 예제

class User {
  private id: string;
  private email: string;
  private version: number = 0;

  static create(id: string, email: string): UserCreatedEvent {
    return { type: 'USER_CREATED', aggregateId: id,
             email, timestamp: new Date() };
  }

  apply(event: UserCreatedEvent): void {
    this.id = event.aggregateId;
    this.email = event.email;
    this.version++;
  }
}

설명

애그리게이트는 이벤트를 발행하고 apply 메서드로 자신의 상태를 업데이트합니다. 모든 상태 변경은 이벤트를 통해 이루어집니다.

---

4. 이벤트 재생 패턴

개요

과거 이벤트들을 순차적으로 재생하여 현재 상태를 재구성합니다. 타임머신처럼 과거 상태도 복원 가능합니다.

코드 예제

class User {
  static fromEvents(events: Event[]): User {
    const user = new User();
    events.forEach(event => {
      if (event.type === 'USER_CREATED') {
        user.apply(event as UserCreatedEvent);
      }
    });
    return user;
  }
}

const events = eventStore.getEvents(userId);
const user = User.fromEvents(events);

설명

저장된 모든 이벤트를 순서대로 적용하여 현재 상태를 재구성합니다. 이를 통해 언제든지 과거 상태를 복원할 수 있습니다.

---

5. 스냅샷 최적화

개요

이벤트가 많아지면 재생 시간이 오래 걸립니다. 스냅샷은 특정 시점의 상태를 저장하여 성능을 개선합니다.

코드 예제

class SnapshotStore {
  private snapshots = new Map<string, any>();

  save(aggregateId: string, state: any, version: number): void {
    this.snapshots.set(aggregateId, { state, version });
  }

  load(aggregateId: string): any {
    return this.snapshots.get(aggregateId);
  }
}

설명

일정 주기마다 현재 상태를 스냅샷으로 저장합니다. 이후 이벤트는 스냅샷부터 재생하여 성능을 크게 향상시킵니다.

---

6. 명령 핸들러 패턴

개요

명령(Command)은 상태를 변경하려는 의도이고, 이벤트는 그 결과입니다. 명령 핸들러가 유효성을 검증합니다.

코드 예제

interface CreateUserCommand {
  userId: string;
  email: string;
}

class UserCommandHandler {
  handle(cmd: CreateUserCommand): Event[] {
    if (!cmd.email.includes('@')) {
      throw new Error('Invalid email');
    }
    return [User.create(cmd.userId, cmd.email)];
  }
}

설명

명령 핸들러는 비즈니스 규칙을 검증하고 유효한 경우 이벤트를 생성합니다. 명령은 실패할 수 있지만 이벤트는 항상 성공한 사실입니다.

---

7. 이벤트 버전관리

개요

시스템이 진화하면서 이벤트 구조가 변경될 수 있습니다. 버전 관리로 하위 호환성을 유지합니다.

코드 예제

interface EventV2 extends Event {
  version: number;
}

class EventUpgrader {
  upgrade(event: Event): EventV2 {
    if (!('version' in event)) {
      return { ...event, version: 1 };
    }
    return event as EventV2;
  }
}

설명

이벤트에 버전 정보를 추가하고 업그레이더로 구버전을 신버전으로 변환합니다. 과거 이벤트도 새로운 시스템에서 사용 가능합니다.

---

8. 프로젝션 생성

개요

프로젝션은 이벤트 스트림을 읽기 최적화된 뷰 모델로 변환합니다. CQRS 패턴과 함께 사용됩니다.

코드 예제

class UserListProjection {
  private users: Map<string, any> = new Map();

  project(event: Event): void {
    if (event.type === 'USER_CREATED') {
      const e = event as UserCreatedEvent;
      this.users.set(e.aggregateId, { email: e.email });
    }
  }

  getAll(): any[] {
    return Array.from(this.users.values());
  }
}

설명

프로젝션은 이벤트를 구독하여 읽기에 최적화된 데이터 구조를 생성합니다. 복잡한 쿼리를 빠르게 처리할 수 있습니다.

---

9. 이벤트 발행 구독

개요

이벤트가 저장되면 구독자들에게 알림을 보냅니다. 마이크로서비스 간 통신에 유용합니다.

코드 예제

class EventBus {
  private subscribers: ((event: Event) => void)[] = [];

  subscribe(handler: (event: Event) => void): void {
    this.subscribers.push(handler);
  }

  publish(event: Event): void {
    this.subscribers.forEach(handler => handler(event));
  }
}

설명

이벤트 버스를 통해 발행-구독 패턴을 구현합니다. 여러 시스템이 동일한 이벤트에 반응하여 독립적으로 동작할 수 있습니다.

---

10. 보상 이벤트 처리

개요

이벤트는 삭제할 수 없으므로 잘못된 동작을 취소하려면 보상 이벤트를 발행합니다.

코드 예제

interface UserDeletedEvent extends Event {
  type: 'USER_DELETED';
  reason: string;
}

class User {
  delete(reason: string): UserDeletedEvent {
    return {
      type: 'USER_DELETED',
      aggregateId: this.id,
      reason,
      timestamp: new Date()
    };
  }
}

설명

삭제나 취소는 새로운 이벤트로 표현합니다. 모든 이력이 보존되어 감사 추적과 디버깅이 용이합니다.

---

마치며

이번 글에서는 Event Sourcing 완벽 가이드에 대해 알아보았습니다. 총 10가지 개념을 다루었으며, 각각의 사용법과 예제를 살펴보았습니다.

관련 태그

#EventSourcing #DomainEvents #CQRS #EventStore #Aggregates