• 목록

✅ PHP에서 CQRS + 이벤트 소싱 통합 적용하기

**CQRS(Command Query Responsibility Segregation)**는 "쓰기와 읽기를 분리"하는 아키텍처이고,
Event Sourcing은 "상태가 아닌 이벤트를 저장"하는 방식입니다.
이 두 개를 함께 사용하면 복잡한 도메인에서도 명확한 책임 분리와 유연한 확장이 가능합니다.

🧠 CQRS + Event Sourcing 조합 구조

Command → CommandHandler → Aggregate → DomainEvent → EventStore
                                                ↓
                                           Projector → Query Model

• Command: 클라이언트가 요청하는 작업

• Aggregate: 비즈니스 로직과 상태 변경 담당

• DomainEvent: 상태 변경을 기술

• EventStore: 이벤트 저장소 (DB 또는 파일, Redis 등)

• Projector: 이벤트 기반 View 모델 갱신

• Query: 읽기 전용, 최적화된 DB/모델 구조 사용

📦 1. Command 정의

[code=php]
class RegisterUserCommand {
    public function __construct(
        public string $id,
        public string $email,
        public string $name
    ) {}
}
[/code]

🧰 2. CommandHandler → Aggregate → 이벤트 발행

[code=php]
class RegisterUserHandler {
    private EventStore $store;

    public function __construct(EventStore $store) {
        $this->store = $store;
    }

    public function handle(RegisterUserCommand $command): void {
        $user = User::register($command->id, $command->email, $command->name);

        foreach ($user->pullEvents() as $event) {
            $this->store->append($event);
        }
    }
}
[/code]

🧱 3. Aggregate (이벤트 소싱 기반)

[code=php]
class User {
    private array $events = [];

    public static function register(string $id, string $email, string $name): self {
        $self = new self();
        $self->apply(new UserRegistered($id, $email, $name));
        return $self;
    }

    private function apply(DomainEvent $event): void {
        $this->events[] = $event;
    }

    public function pullEvents(): array {
        $evts = $this->events;
        $this->events = [];
        return $evts;
    }
}
[/code]

🔄 4. Projector → 읽기 모델 구축

[code=php]
class UserProjector {
    private array $users = [];

    public function apply(UserRegistered $event): void {
        $this->users[$event->aggregateId] = [
            'email' => $event->email,
            'name' => $event->name,
        ];
    }

    public function getUser(string $id): ?array {
        return $this->users[$id] ?? null;
    }
}
[/code]

📤 5. Query 모델 분리

[code=php]
$query = new GetUserQuery('user-1');
$user = $projector->getUser($query->id);
[/code]

• 조회는 별도 모델에서, 최적화된 형태로 수행

• SQL + NoSQL 병행도 가능

✅ 장점 요약

⚠️ 실무 적용 시 주의점

• 쿼리 모델 동기화 전략 필요 (동기/비동기, Eventually Consistent)

• 이벤트 마이그레이션/버전 관리 필요

• 적절한 케이스에서만 사용 (단순 CRUD에 과하면 유지보수 비용 증가)

🧠 요약

• CQRS는 책임 분리, Event Sourcing은 변화 기록

• PHP에서도 두 구조를 충분히 통합 구현 가능

• 읽기와 쓰기를 명확히 분리하면, 테스트/확장/복구가 쉬운 구조 완성