Streams, backpressure và Buffer trong Node.js

import { createReadStream, createWriteStream } from "node:fs";
import { pipeline } from "node:stream/promises";
import { createGzip } from "node:zlib";

await pipeline(
  createReadStream("big.log"),
  createGzip(),
  createWriteStream("big.log.gz")
); // tự xử lý backpressure, đóng stream khi lỗi

Backpressure thủ công: if (!writable.write(chunk)) await once(writable, "drain"). Ngưỡng là highWaterMark (mặc định 16 KiB với byte stream, 16 object với object mode). pipe() cũng xử lý backpressure nhưng không tự dọn khi lỗi.

Buffer:

• Buffer.from("xin chào", "utf8"), buf.toString("base64"), Buffer.concat([a, b]).
• Buffer.alloc(n) được xóa về 0; Buffer.allocUnsafe(n) nhanh hơn nhưng có thể chứa dữ liệu cũ trong bộ nhớ, chỉ dùng khi sẽ ghi đè hết.
• buf.length là số byte, không phải số ký tự.