CQRS trong NestJS (@nestjs/cqrs): Command, Query, Event và khi nào nên dùng?

export class CreateOrderCommand { constructor(public readonly userId: number) {} }

@CommandHandler(CreateOrderCommand)
export class CreateOrderHandler implements ICommandHandler<CreateOrderCommand> {
  constructor(private repo: OrderRepo, private events: EventBus) {}
  async execute(cmd: CreateOrderCommand) {
    const order = await this.repo.create(cmd.userId);
    this.events.publish(new OrderCreatedEvent(order.id));
    return order.id;
  }
}

@QueryHandler(GetOrderQuery)
export class GetOrderHandler implements IQueryHandler<GetOrderQuery> {
  execute(q: GetOrderQuery) { return this.readModel.find(q.id); }
}

// controller: this.commandBus.execute(new CreateOrderCommand(1))

	Command	Query	Event
Ý nghĩa	Ý định thay đổi	Câu hỏi	Điều đã xảy ra
Handler	Đúng 1	Đúng 1	0..N (@EventsHandler)
Trả về	Tối thiểu (id)	Dữ liệu	Không

• Saga (RxJS) điều phối quy trình dài: bắt event rồi phát command tiếp theo.
• Có thể tách read model (denormalized, cache, Elasticsearch) khỏi write model, đạt eventual consistency.
• EventBus trong process không bền: crash là mất event; cần outbox + message broker nếu yêu cầu đảm bảo.