Bạn xây dựng các tính năng real-time với WebSocket gateway như thế nào?

Question

Accepted Answer

NestJS hỗ trợ **giao tiếp real-time, hai chiều** qua **WebSocket gateway** — các class được trang trí bằng `@WebSocketGateway()` xử lý các kết nối và message WebSocket (thường qua Socket.IO). Chúng cho phép các tính năng như chat, thông báo trực tiếp, và dashboard trực tiếp, dùng cùng cấu trúc NestJS (DI, decorator).

## Định nghĩa một gateway

```ts
import { WebSocketGateway, SubscribeMessage, MessageBody, WebSocketServer } from "@nestjs/websockets";
import { Server } from "socket.io";

@WebSocketGateway({ cors: true })
export class ChatGateway {
  @WebSocketServer()
  server: Server;                        // instance Socket.IO server

// xử lý một event 'message' từ một client
  @SubscribeMessage("message")
  handleMessage(@MessageBody() data: { text: string }) {
    // BROADCAST tới tất cả client đang kết nối
    this.server.emit("message", data);   // mọi người nhận message
  }
}
```

Một gateway dùng `@SubscribeMessage("event")` để xử lý các event đến (tương tự `@Post` cho HTTP) và `server` được inject để **emit** các event trở lại client — `server.emit` broadcast tới mọi người.

## Các hook vòng đời kết nối

```ts
export class ChatGateway implements OnGatewayConnection, OnGatewayDisconnect {
  handleConnection(client: Socket) {
    console.log(`Client connected: ${client.id}`);   // một user tham gia
  }
  handleDisconnect(client: Socket) {
    console.log(`Client disconnected: ${client.id}`); // một user rời đi — dọn dẹp
  }
}
```

Gateway có thể phản ứng với các client kết nối và ngắt kết nối — hữu ích cho theo dõi sự hiện diện (presence) và dọn dẹp.

## Nhắm tới các client cụ thể và room

```ts
@SubscribeMessage("joinRoom")
handleJoin(@ConnectedSocket() client: Socket, @MessageBody() room: string) {
  client.join(room);                              // thêm client vào một room
}

@SubscribeMessage("roomMessage")
sendToRoom(@MessageBody() data: { room: string; text: string }) {
  this.server.to(data.room).emit("message", data.text);   // emit chỉ tới room đó
  // client.emit(...) → chỉ client đó; server.emit(...) → mọi người
}
```

**Room** nhóm các client (vd. một phòng chat, các cộng tác viên của một tài liệu), cho phép bạn broadcast tới các tập con cụ thể thay vì mọi người — thiết yếu cho các tính năng real-time có phạm vi.

## Gateway tái sử dụng các tính năng NestJS

```text
Gateway là provider → chúng hỗ trợ dependency injection (inject service),
và có thể dùng guard, pipe, interceptor, và filter — giống như HTTP controller.
→ Cùng cấu trúc/pattern áp dụng cho real-time như cho REST.
```

## Scale WebSocket

```text
⚠️ Các kết nối WebSocket có TRẠNG THÁI và sống trên MỘT server instance.
Để scale qua nhiều instance, dùng một Redis adapter (socket.io-redis) để
broadcast/room hoạt động qua tất cả instance. (Như session, đừng giữ trạng thái trong
bộ nhớ của một process khi scale ngang.)
```

## Tại sao điều này quan trọng

WebSocket gateway là cách NestJS hỗ trợ các **tính năng real-time, hai chiều** — chat, thông báo trực tiếp, presence, soạn thảo cộng tác, dashboard trực tiếp, tương tác multiplayer — mà mô hình request-response của REST không thể cung cấp (server có thể đẩy tới client, không chỉ phản hồi request).

Hiểu chúng là kiến thức cấp senior giá trị để xây dựng các ứng dụng tương tác hiện đại.

Điểm mạnh then chốt là gateway phù hợp với cấu trúc quen thuộc của NestJS: chúng là provider hỗ trợ **dependency injection** và có thể dùng **guard, pipe, interceptor, và filter** giống như HTTP controller, nên cùng pattern và tổ chức code áp dụng cho real-time như cho REST.

Biết cách xử lý event (`@SubscribeMessage`), broadcast tới client (`server.emit`), dùng **room** để giới hạn broadcast tới các tập con liên quan (phòng chat, cộng tác viên tài liệu), và quản lý vòng đời kết nối (presence, dọn dẹp) bao quát bộ công cụ real-time thực tế.

Quan trọng then chốt là **cân nhắc về scaling**: các kết nối WebSocket có trạng thái và gắn với một server instance duy nhất, nên scale ngang yêu cầu một **Redis adapter** để điều phối broadcast/room qua các instance (một cạm bẫy phổ biến — như session, trạng thái real-time không thể sống trong bộ nhớ của một process khi chạy nhiều instance).

Đây là một khả năng quan trọng, ngày càng liên quan để xây dựng các trải nghiệm real-time, tương tác mà người dùng hiện đại mong đợi, và tích hợp gọn gàng của NestJS làm cho nó dễ tiếp cận trong khi tái sử dụng cấu trúc của framework.