Node.js通过pipe()方法实现流的高效传输，核心是分块处理数据以降低内存占用。可读流与可写流通过pipe()连接，自动完成数据分发、背压控制和错误传播，无需手动管理。例如读取大文件时，fs.createReadStream()将数据分块推送到HTTP响应，系统自动调节流速，防止内存溢出。支持链式调用如readable.pipe(transform).pipe(writable)，适用于大文件、网络传输等场景，实现边读边写、高吞吐低开销的数据流动。
在 Node.js 中，流处理通过管道机制（pipe）实现大数据的高效传输，核心在于避免将整个数据加载到内存中，而是以小块（chunk）的方式逐步处理。这种方式特别适合处理大文件、网络请求或大量数据传输场景。
流的基本类型与数据流动方式
Node.js 提供了四种流类型：可读流（Readable）、可写流（Writable）、双工流（Duplex）和转换流（Transform）。其中，可读流用于读取数据，可写流用于写入数据。管道机制通常连接可读流和可写流。
当使用 pipe() 方法时，可读流会自动分批读取数据块，并推送给可写流，无需等待全部数据加载完成。这种“拉取-推送”结合的机制减少了内存占用，同时保持较高的吞吐量。
- 可读流触发 data 事件，每次传递一个数据块
- 可写流通过 write() 接收并处理每个块
- 背压机制（backpressure）自动调节数据流动速度，防止内存溢出
pipe() 方法如何简化高效传输
pipe() 是流对象上的一个方法，语法为 readable.pipe(writable)，它自动处理监听事件、数据写入和错误传播，开发者无需手动管理数据块的流转。
例如，在读取一个 1GB 的日志文件并写入网络响应时：
const fs = require('fs');
const server = require('http').createServer();
server.on('request', (req, res) => {
const stream = fs.createReadStream('large.log');
stream.pipe(res); // 数据分块传输，不占满内存
});
server.listen(3000);
此时，文件内容被切成多个小块，逐个发送到客户端。即使并发用户增多，内存使用依然可控。
背压与流量控制保障稳定性
管道机制内置了流量控制逻辑。当可写流处理速度慢于可读流输出速度时，write() 返回 false，可读流会暂停 data 事件，直到可写流发出 drain 信号。这个过程称为背压处理，是高效且稳定传输的关键。
使用 pipe() 时，这些细节由 Node.js 自动管理，开发者不必手动监听事件或控制暂停/恢复。
- 调用 pause() 和 resume() 由系统内部完成
- 错误会通过 unpipe 和 error 事件传递
- 可链式调用，如 readable.pipe(transform).pipe(writable)
