Node.js (Streams) 在 Node.js 中，“”（Streams）是一种处理输入和输出的机制，特别适用于处理大量数据。它们是 Node.js 核心模块之一，用于建立有效的数据传输管道。在很多地方都有用，如文件操作、网络通信和处理 HTTP 请求等。

什么是？ 一种抽象接口，用于处理输入和输出。Node.js 提供了四种基本类型的流：

Readable Streams（可读流）： 用于从源（如文件、网络或标准输入）读取数据的流。

Writable Streams（可写流）： 用于将数据写入目标（如文件、网络连接或标准输出）的流。

Duplex Streams（双工流）： 可读可写的流，例如一个网络套接字。

Transform Streams（转换流）： 读取数据，对其进行处理，然后将处理后的数据写出的流。

流的作用 流的主要目的是提高内存使用效率和响应速度。它们适用于以下情况：

大数据处理： 当需要处理大文件或网络数据时，读取整个数据到内存中可能会导致内存不足。使用流可以逐块地处理数据，而不是一次性加载全部数据。

快速响应： 流使得数据在输入可用时立即开始处理，而不需要等待所有数据加载完成。

异步处理： 事件驱动的，可以轻松与异步代码集成。

链式处理： 可以将多个流串联起来，以构建复杂的数据处理管道。

常用流的示例 以下是一些使用 Node.js 流的示例：

可读流 const fs = require('fs');

const readableStream = fs.createReadStream('input.txt'); readableStream.on('data', (chunk) => { console.log(chunk.toString()); }); 1 2 3 4 5 6 在此示例中，我们从名为 input.txt 的文件创建了一个可读流，并监听其 data 事件。当流读取数据块时，我们将数据块打印到控制台。

可写流 const fs = require('fs');

const writableStream = fs.createWriteStream('output.txt'); writableStream.write('Hello, World!', 'utf8', () => { console.log('Data has been written.'); }); 1 2 3 4 5 6 这个示例中，我们创建了一个可写流并将字符串 “Hello, World!” 写入名为 output.txt 的文件。

转换流 const fs = require('fs'); const zlib = require('zlib');

const readableStream = fs.createReadStream('input.txt'); const writeableStream = fs.createWriteStream('input.txt.gz'); const gzip = zlib.createGzip();

readableStream.pipe(gzip).pipe(writeableStream); 1 2 3 4 5 6 7 8 在这里，我们将数据从一个可读流传输到一个转换流，然后再传输到一个可写流。这允许我们在传输过程中对数据进行压缩。

Node.j一个强大的工具，可以用于各种场景，从文件操作到网络通信。通过使用流，你可以提高应用程序的性能和效率，特别是在需要处理大量数据时。