在 Node.js 中，stream 是处理数据的重要部分。它提供了一种处理大量数据或文件的方法，使得 Node.js 可以处理更高效的 I/O 操作。在本文中，我们将深入了解 Node.js 中的 stream，并探讨如何使用 stream 处理各种数据。
Stream 是什么？
在计算机科学中，stream 是一种表示从数据源（如文件、网络连接、其他程序等）到程序的数据流的概念。Stream 可以读取、写入和操作数据，而不必将整个数据集加载到内存中。这使得 stream 成为一种非常高效并且节省内存的数据处理方式。
在 Node.js 中，stream 通过 stream 模块实现。stream 模块提供了一组功能，它们可以让我们读取、写入以及操作 stream 中的数据，这些数据可以是文件、网络连接等。Node.js 中有四种类型的 stream：
- 可读流：用于读取数据
- 可写流：用于写入数据
- 双向流：既可以读取数据，也可以写入数据
- 转换流：用于在读取和写入数据之间进行转换
可读流
可读流提供了一种从数据源中读取数据的方法。我们可以使用可读流来读取文件或从 HTTP request 对象中读取数据。以下是一个简单的实例：
-- -------------------- ---- ------- ----- -- - -------------- ----- ---------- - -------------------------------- --------------------- ------- -- - ------------------- --- -------------------- -- -- - ----------------- ------------- --- ---------------------- ----- -- - ----------------------- ---
在上面的示例中，我们创建了一个可读流 readStream，并使用它来读取名为 data.txt 的文件。当可读流读取数据时，它会触发 data 事件，我们可以通过监听 data 事件来处理每次读取的数据块。当可读流读取完成时，它会触发 end 事件。如果读取过程中出现错误，可读流会触发 error 事件。
可写流
可写流用于将数据写入目标，例如写入文件或通过 HTTP response 对象向客户端发送数据。以下是一个简单的示例：
-- -------------------- ---- ------- ----- -- - -------------- ----- ----------- - ----------------------------------- ------------------------- -------- -------- ------------------ ------------------------ -- -- - ------------------ ------------- --- ----------------------- ----- -- - ----------------------- ---
在上面的示例中，我们创建了一个可写流 writeStream，并使用它将字符串“Hello, world!”写入名为 output.txt 的文件。请注意，我们使用了 write 方法将数据写入流中，并使用 end 方法结束写入过程。当写入完成时，可写流会触发 finish 事件。如果写入过程中出现错误，可写流会触发 error 事件。
双向流
双向流可以读取数据，也可以写入数据，这使得它非常适合于处理网络套接字或管道等复杂的 I/O 操作。以下是一个简单的示例：
const net = require('net');
const server = net.createServer((socket) => {
socket.pipe(socket);
});
server.listen(1337, '127.0.0.1');在上面的示例中，我们创建了一个 TCP 服务器，并使用 pipe 方法来将数据从一个客户端套接字传输到另一个客户端套接字，实现双向通信。
转换流
转换流可以在读取和写入数据之间进行转换。这使得它非常适合于处理需要在读取和写入数据之间进行额外操作的数据。以下是一个简单的示例：
-- -------------------- ---- ------- ----- -- - -------------- ----- ---- - ---------------- ----- ---------- - -------------------------------- ----- ----------- - ------------------------------------ ----- ---- - ------------------ ---------------------------------------- ------------------------ -- -- - ------------------------ ------------- --- ----------------------- ----- -- - ----------------------- ---
在上面的示例中，我们使用 fs 模块创建了一个可读流 readStream 和一个可写流 writeStream，用于读取和写入数据。我们还创建了一个转换流 gzip，用于将读取的数据压缩为 gzip 格式。最后，我们将读取流 pipe 到 gzip 流中，再将 gzip 流 pipe 到写入流中，实现将原始数据压缩为 gzip 格式并写入文件的操作。
结论
在 Node.js 中，stream 是处理大量数据或文件的有效途径。本文介绍了 Node.js 中四种类型的 stream，并提供了相应的示例代码。希望这些内容对你有所帮助，并减少你在使用 stream 时可能遇到的问题。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6754f9a91b963fe9cc5154e5