Streams ใน Node.js คืออะไร และคุณควรใช้มันเมื่อไร?

Question

Accepted Answer

**Streams** ประมวลผลข้อมูล **ทีละน้อย ในรูปแบบของ chunks** แทนที่จะโหลดทั้งหมดลงในหน่วยความจำในครั้งเดียว สิ่งนี้ทำให้จำเป็นสำหรับข้อมูลขนาดใหญ่ (ไฟล์ขนาดใหญ่ การส่งข้อมูลผ่านเครือข่าย) เมื่อการ buffer ทุกอย่างจะใช้หน่วยความจำหมด

## ปัญหาที่ Streams แก้ไข

```js
// ❌ loads the ENTIRE file into memory — crashes on a 10GB file
const data = await fs.promises.readFile("huge.csv");
process(data);

// ✅ stream it — constant memory, processes chunk by chunk
fs.createReadStream("huge.csv")
  .pipe(transform)
  .pipe(fs.createWriteStream("out.csv"));
```

ด้วย Streams การใช้หน่วยความจำจะคงที่ไม่ว่าขนาดไฟล์เท่าใด — คุณจัดการ chunk หนึ่งในแต่ละครั้ง

## ประเภท Stream สี่แบบ

```text
Readable  → source you read FROM (fs.createReadStream, http request)
Writable  → destination you write TO (fs.createWriteStream, http response)
Duplex    → both readable & writable (TCP socket)
Transform → modify data as it passes through (zlib gzip, encryption)
```

## pipe — เชื่อมต่อ Streams

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

// read → compress → write, all streaming, low memory
createReadStream("file.txt")
  .pipe(createGzip())            // Transform: compress on the fly
  .pipe(createWriteStream("file.txt.gz"));
```

`pipe` เชื่อมต่อ readable ไปยัง writable (พร้อม transforms ตรงกลาง) โดยจัดการการไหลของข้อมูลโดยอัตโนมัติ — วิธีการเขียน Streams แบบดั้งเดิม

## pipeline — pipe พร้อมการจัดการข้อผิดพลาดที่เหมาะสม

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

await pipeline(
  createReadStream("in.txt"),
  createGzip(),
  createWriteStream("out.gz")
); // ✅ cleans up all streams on error/completion (pipe alone leaks on errors)
```

`pipeline` ได้รับการนิยมมากกว่า chained `.pipe()` เพราะว่ามันแพร่กระจายข้อผิดพลาดและทำความสะอาด stream ทุกตัวอย่างเหมาะสม

## Streams ปรากฏตัวที่ใด

```text
✓ HTTP request/response bodies (req and res ARE streams)
✓ File reading/writing, file uploads/downloads
✓ Compression (zlib), encryption (crypto)
✓ Database cursors, large query results
✓ Real-time data processing, video streaming
```

## เมื่อไม่ต้องกังวล

```text
Small data that fits comfortably in memory → readFile/simple buffering is simpler.
Streams add complexity; use them for LARGE or continuous data.
```

## ทำไมจึงมีความสำคัญ

Streams เป็นคุณลักษณะที่กำหนดของ Node สำหรับการจัดการข้อมูลขนาดใหญ่หรือต่อเนื่องที่ **ประหยัดหน่วยความจำ** — ความแตกต่างระหว่างแอปที่ขัดข้องจากการอัพโหลดขนาดใหญ่กับแอปที่จัดการขนาดใดก็ตามด้วยหน่วยความจำคงที่

การทำความเข้าใจประเภท Streams สี่แบบ `pipe`/`pipeline` composition (และเหตุใด `pipeline` จึงปลอดภัยกว่า) และคำขอ/การตอบสนอง HTTP ที่เป็น Streams นั้นเองถือเป็นสิ่งจำเป็นสำหรับการสร้างบริการ file-handling data-processing และ proxying ที่ขยายได้ใน Node