CQRS là gì? Triển khai CQRS "chuẩn chỉnh" với NestJS!

Lê Lân

05/07/2025

CQRS Trong NestJS: Cách Tổ Chức Logic Ứng Dụng Hiệu Quả và Dễ Duy Trì

Mở Đầu

Khi ứng dụng của bạn ngày càng phát triển phức tạp, việc tổ chức logic nghiệp vụ sao cho dễ dàng hiểu, bảo trì và mở rộng trở thành một thách thức lớn. Một trong những mẫu kiến trúc được ưa chuộng giúp giải quyết vấn đề này là CQRS (Command Query Responsibility Segregation).

Chỉ với việc phân tách rõ ràng giữa phần thao tác thay đổi dữ liệu và phần truy vấn dữ liệu, CQRS giúp tăng khả năng mở rộng, đơn giản hóa kiến trúc và cải thiện chất lượng mã nguồn. Trong bài viết này, bạn sẽ được tìm hiểu CQRS là gì, hoạt động như thế nào, khi nào nên sử dụng hoặc tránh dùng CQRS, và cuối cùng là cách triển khai CQRS trong ứng dụng NestJS với module @nestjs/cqrs qua ví dụ thực tế về một task manager.

CQRS Là Gì?

Khái Niệm CQRS

CQRS là viết tắt của Command Query Responsibility Segregation, nghĩa là phân tách trách nhiệm xử lý lệnh (command) và truy vấn (query). Cụ thể:

Commands: Các hành động thay đổi trạng thái hệ thống như tạo, cập nhật, xóa dữ liệu.

Queries: Các hành động đọc dữ liệu mà không sửa đổi trạng thái.

Khác với mô hình CRUD truyền thống, nơi cả đọc và ghi thường được xử lý bởi cùng controller hay service, CQRS tách biệt hoàn toàn hai luồng này.

Lợi Ích Khi Sử Dụng CQRS

Tách biệt trách nhiệm: Giúp code rõ ràng, dễ hiểu khi luồng đọc và viết tách bạch.

Khả năng mở rộng độc lập: Bạn có thể mở rộng riêng luồng đọc hoặc luồng viết tùy theo nhu cầu.

Linh hoạt trong mô hình dữ liệu: Cho phép dùng các mô hình dữ liệu khác nhau cho đọc và ghi, ví dụ sử dụng dạng dữ liệu phi chuẩn hóa cho truy vấn nhanh.

Hỗ trợ audit và event-driven: Các lệnh có thể được ghi lại hoặc xử lý không đồng bộ thông qua event.

Khi Nào Nên Dùng CQRS?

Ứng dụng có logic nghiệp vụ phức tạp, đòi hỏi phân tách rõ ràng.

Khi đọc và ghi có nhu cầu mở rộng hệ thống khác nhau.

Muốn tích hợp event sourcing hoặc các luồng công việc bất đồng bộ.

Xây dựng hệ thống microservices với nhiều thành phần tách biệt.

CQRS không phải lúc nào cũng cần thiết, đặc biệt với các ứng dụng đơn giản, quy mô nhỏ. Việc áp dụng CQRS sẽ làm tăng độ phức tạp nếu chưa thực sự cần thiết.

Triển Khai CQRS Trong NestJS

Tại Sao Lựa Chọn NestJS?

NestJS là framework Node.js chuẩn hóa, hỗ trợ mô hình kiến trúc rõ ràng với decorators, Dependency Injection (DI) và event-driven design – rất phù hợp để áp dụng CQRS. Package @nestjs/cqrs giúp bạn dễ dàng định nghĩa các Commands, Queries, Event và Handlers đi kèm.

Các Thành Phần Chính Trong
nestjs/cqrs

Command & CommandHandler: Xử lý các lệnh thay đổi dữ liệu.

Query & QueryHandler: Xử lý các truy vấn dữ liệu.

Event & EventHandler: Hỗ trợ xử lý sự kiện và event-driven.

Sagas, CommandBus, EventBus: Quản lý luồng xử lý và liên kết các hành vi.

Ví Dụ Thực Tế: Xây Dựng Ứng Dụng Quản Lý Task Với CQRS

Chúng ta sẽ xây dựng một ứng dụng đơn giản gồm 2 chức năng: tạo task và lấy tất cả tasks.

1. Cài Đặt Package

npm install @nestjs/cqrs

2. Định Nghĩa Domain Model

export interface Task {
  id: string;
  title: string;
  description: string;
  status: 'open' | 'in-progress' | 'done';
}

3. Tạo Command: `CreateTaskCommand`

export class CreateTaskCommand {
  constructor(
    public readonly title: string,
    public readonly description: string
  ) {}
}

4. Tạo Command Handler: `CreateTaskHandler`

import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';

@CommandHandler(CreateTaskCommand)
export class CreateTaskHandler implements ICommandHandler<CreateTaskCommand> {
  constructor(private readonly taskRepository: TaskRepository) {}

  async execute(command: CreateTaskCommand) {
    const { title, description } = command;
    const task = {
      id: crypto.randomUUID(),
      title,
      description,
      status: 'open',
    };
    await this.taskRepository.create(task);
    return task;
  }
}

5. Tạo Query: `GetAllTasksQuery`

export class GetAllTasksQuery {}

6. Tạo Query Handler: `GetAllTasksHandler`

import { IQueryHandler, QueryHandler } from '@nestjs/cqrs';

@QueryHandler(GetAllTasksQuery)
export class GetAllTasksHandler implements IQueryHandler<GetAllTasksQuery> {
  constructor(private readonly taskRepository: TaskRepository) {}

  async execute(query: GetAllTasksQuery) {
    return this.taskRepository.findAll();
  }
}

7. Tạo Task Repository (Bảng nhớ trong bộ nhớ)

import { Injectable } from '@nestjs/common';

@Injectable()
export class TaskRepository {
  private tasks: Task[] = [];

  async create(task: Task) {
    this.tasks.push(task);
    return task;
  }

  async findAll(): Promise<Task[]> {
    return this.tasks;
  }
}

8. Đăng Ký Trong Module

import { Module } from '@nestjs/common';
import { CqrsModule } from '@nestjs/cqrs';

@Module({
  imports: [CqrsModule],
  providers: [
    TaskRepository,
    CreateTaskHandler,
    GetAllTasksHandler,
  ],
})
export class TasksModule {}

9. Sử Dụng Trong Controller

import { Controller, Post, Get, Body } from '@nestjs/common';
import { CommandBus, QueryBus } from '@nestjs/cqrs';

@Controller('tasks')
export class TasksController {
  constructor(
    private readonly commandBus: CommandBus,
    private readonly queryBus: QueryBus,
  ) {}

  @Post()
  async createTask(@Body() dto: { title: string; description: string }) {
    return this.commandBus.execute(new CreateTaskCommand(dto.title, dto.description));
  }

  @Get()
  async getAllTasks() {
    return this.queryBus.execute(new GetAllTasksQuery());
  }
}

Tổng Kết

CQRS là một phương pháp hiệu quả để tổ chức, phân tách và quản lý logic nghiệp vụ trong các ứng dụng NestJS phức tạp. Khi sử dụng đúng ngữ cảnh – đặc biệt trong các hệ thống có nhu cầu mở rộng cao, tách bạch read/write rõ ràng hay dùng kết hợp event sourcing – CQRS sẽ giúp tăng khả năng duy trì, mở rộng và thể hiện kiến trúc ứng dụng rõ ràng hơn.

Đừng quên bắt đầu thử nghiệm CQRS với các mô hình nhỏ, và cân nhắc hệ quả về độ phức tạp trước khi áp dụng quy mô lớn.

Chúc bạn thành công và hân hoan khi áp dụng CQRS cùng NestJS!

Tham Khảo

Microsoft Docs. CQRS Pattern

NestJS Official Documentation. CQRS Module

Vaughn Vernon. Implementing Domain-Driven Design

Martin Fowler. Patterns of Enterprise Application Architecture

Blog bài viết về CQRS và event sourcing trên nestjs.com và các khoá học Udemy liên quan.