Streams trong Node.js là gì và khi nào nên dùng chúng?

Question

Accepted Answer

**Streams** xử lý dữ liệu **tăng dần, theo từng chunk**, thay vì nạp toàn bộ vào bộ nhớ một lúc. Điều này khiến chúng thiết yếu cho dữ liệu lớn (file lớn, truyền qua mạng) nơi việc buffer mọi thứ sẽ làm cạn kiệt bộ nhớ.

## Vấn đề mà streams giải quyết

```js
// ❌ nạp TOÀN BỘ file vào bộ nhớ — crash với file 10GB
const data = await fs.promises.readFile("huge.csv");
process(data);

// ✅ stream nó — bộ nhớ không đổi, xử lý từng chunk một
fs.createReadStream("huge.csv")
  .pipe(transform)
  .pipe(fs.createWriteStream("out.csv"));
```

Với streams, mức sử dụng bộ nhớ giữ ổn định bất kể kích thước file — bạn xử lý từng chunk một.

## Bốn loại stream

```text
Readable  → nguồn để bạn đọc TỪ (fs.createReadStream, http request)
Writable  → đích để bạn ghi VÀO (fs.createWriteStream, http response)
Duplex    → vừa readable vừa writable (TCP socket)
Transform → biến đổi dữ liệu khi nó đi qua (zlib gzip, mã hóa)
```

## pipe — kết nối các stream

```js
import { createReadStream, createWriteStream } from "fs";
import { createGzip } from "zlib";

// đọc → nén → ghi, tất cả đều streaming, bộ nhớ thấp
createReadStream("file.txt")
  .pipe(createGzip())            // Transform: nén trực tiếp khi đang chạy
  .pipe(createWriteStream("file.txt.gz"));
```

`pipe` nối một readable với một writable (với các transform ở giữa), tự động quản lý luồng dữ liệu — cách idiomatic để kết hợp các stream.

## pipeline — pipe với xử lý lỗi đúng cách

```js
import { pipeline } from "stream/promises";

await pipeline(
  createReadStream("in.txt"),
  createGzip(),
  createWriteStream("out.gz")
); // ✅ dọn dẹp mọi stream khi có lỗi/hoàn tất (chỉ dùng pipe sẽ rò rỉ khi lỗi)
```

`pipeline` được ưu tiên hơn so với chuỗi `.pipe()` vì nó lan truyền lỗi và dọn dẹp mọi stream đúng cách.

## Streams xuất hiện ở đâu

```text
✓ Body của HTTP request/response (req và res CHÍNH LÀ stream)
✓ Đọc/ghi file, upload/download file
✓ Nén (zlib), mã hóa (crypto)
✓ Database cursor, kết quả truy vấn lớn
✓ Xử lý dữ liệu thời gian thực, video streaming
```

## Khi nào KHÔNG cần bận tâm

```text
Dữ liệu nhỏ vừa thoải mái trong bộ nhớ → readFile/buffer đơn giản sẽ gọn hơn.
Streams thêm độ phức tạp; dùng chúng cho dữ liệu LỚN hoặc liên tục.
```

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

Streams là một tính năng đặc trưng của Node để xử lý dữ liệu lớn hoặc liên tục một cách **tiết kiệm bộ nhớ** — sự khác biệt giữa một ứng dụng crash khi có upload lớn và một ứng dụng xử lý mọi kích thước với bộ nhớ ổn định.

Hiểu bốn loại stream, cách kết hợp bằng `pipe`/`pipeline` (và vì sao `pipeline` an toàn hơn), và rằng HTTP request/response bản thân chúng là stream là điều thiết yếu để xây dựng các dịch vụ xử lý file, xử lý dữ liệu và proxy có khả năng mở rộng trong Node.