Node.js Streams通过流式处理避免内存溢出，支持Readable、Writable、Duplex和Transform四种类型，常用pipe方法连接流实现高效数据处理，结合Transform可实时转换数据，保持低内存占用，适用于大文件读写与日志处理。
处理大规模数据时，如果一次性将所有数据加载到内存中，很容易导致内存溢出。Node.js 的 Streams 提供了一种高效、低内存消耗的方式来处理大量数据。通过流式读取和写入，你可以逐块处理数据，而不是一次性加载全部内容。
理解 Node.js Streams 的基本类型
Streams 是 Node.js 中处理数据的核心模块，主要分为四种类型：
- Readable：可读流，用于读取数据（如文件读取、HTTP 请求体）
- Writable：可写流，用于写入数据（如文件写入、HTTP 响应）
- Duplex：双工流，既可读又可写（如 TCP 套接字）
- Transform：转换流，对数据进行处理后再输出（如压缩、加密）
在处理大规模数据时，最常用的是 Readable 流配合 Transform 或 Writable 流进行管道操作。
使用管道（pipe）避免内存堆积
pipe() 方法是连接流的最安全方式，它自动处理背压（backpressure），确保读取速度与写入速度协调，防止内存溢出。
示例：读取大文件并写入新文件
const fs = require('fs');
const readStream = fs.createReadStream('large-file.txt');
const writeStream = fs.createWriteStream('output.txt');
readStream.pipe(writeStream);
这段代码不会将整个文件加载进内存，而是每次读取一个数据块（默认 64KB），然后写入目标文件。
通过 Transform 流处理数据
当你需要对数据进行转换（如过滤、解析、压缩），可以使用 Transform 流。它在数据流动过程中实时处理，保持低内存占用。
const fs = require('fs');
const { Transform } = require('stream');
const lineProcessor = new Transform({
transform(chunk, encoding, callback) {
const lines = chunk.toString().trim().split('\\n');
lines.forEach(line => {
try {
const data = JSON.parse(line);
if (data.active) {
this.push(JSON.stringify(data) + '\\n');
}
} catch (err) {
// 忽略无效行
}
});
callback();
}
});
fs.createReadStream('huge-data.jsonl')
.pipe(lineProcessor)
.pipe(fs.createWriteStream('filtered.jsonl'));
这种方式即使面对 GB 级别的日志文件，也能稳定运行，内存占用几乎恒定。
监听事件以精确控制流程
除了 pipe，你也可以手动监听流事件来实现更精细的控制。
const stream = fs.createReadStream('big-file.csv');
let chunkCount = 0;
stream.on('data', (chunk) => {
chunkCount++;
// 处理 chunk，例如解析 CSV 行
console.log(`处理第 ${chunkCount} 个数据块`);
});
stream.on('end', () => {
console.log('数据读取完成');
});
stream.on('error', (err) => {
console.error('读取失败:', err);
});
注意：手动处理 'data' 事件时要小心背压问题，建议优先使用 pipe 或 async iterators。
基本上就这些。只要合理使用流的管道机制和 Transform 处理，Node.js 完全能胜任大规模数据处理任务，而不会耗尽内存。关键在于“边读边处理”，避免中间结果堆积。不复杂但容易忽略。
