Node.js中你不可不精的Stream（流）

Node.js中你不可不精的Stream（流）攻略

什么是流？

流（Stream）是Node.js中处理流式数据的抽象接口。流可以像文件一样被读取和写入，但它们是基于事件的、异步的，并且可以进行实时（即时）数据处理。

常见的流分为可读流、可写流和双工流。可读流用于从文件、网络端口和其他数据源读取数据，可写流用于将数据写入文件、网络端口和其他数据存储，而双工流则是同时具有读写能力的流。

首先，我们如何使用流？

使用流主要有两种方式：可读流和可写流

可读流

我们可以使用fs模块中的createReadStream()方法创建可读流，如下所示：

const fs = require('fs');

const readableStream = fs.createReadStream('input.txt');

readableStream.on('data', (chunk) => {
  console.log(chunk.toString());
});

readableStream.on('end', () => {
  console.log('读取完成');
});

readableStream.on('error', (error) => {
  console.log(error);
});

上述代码中，我们使用createReadStream()方法创建了一个可读流对象readableStream，并将input.txt作为读取数据的源文件。然后使用on()方法绑定了data事件、end事件和error事件。

当input.txt中有数据可读时，会触发data事件进行读取，将读取到的数据输出到控制台中。当读取完毕，会触发end事件，输出“读取完成”。如果在读取数据时出现错误，则会触发error事件，将错误信息输出到控制台中。

可写流

我们可以使用fs模块中的createWriteStream方法创建可写流，如下所示：

const fs = require('fs');

const writeableStream = fs.createWriteStream('output.txt');

writeableStream.write('使用可写流写入数据到output.txt文件');

writeableStream.end();

writeableStream.on('finish', () => {
  console.log('写入完成');
});

writeableStream.on('error', (error) => {
  console.log(error);
});

上述代码中，我们使用createWriteStream()方法创建了一个可写流对象writeableStream，并将写入的数据输出到output.txt中。然后使用end()方法表示数据写入完毕，绑定了finish事件和error事件。

当写入完毕，会触发finish事件，输出“写入完成”。如果在写入数据时出现错误，则会触发error事件，将错误信息输出到控制台中。

其次，可读流和可写流的组合：管道流

管道流（pipe）是将可读流的数据直接传输到可写流的过程。Node.js通过pipe()方法提供了方便的管道功能。

我们可以使用createReadStream()方法创建一个可读流对象，使用createWriteStream()方法创建一个可写流对象，然后将它们进行连接，连接使用管道流进行数据传输。

const fs = require('fs');

const readableStream = fs.createReadStream('input.txt');
const writeableStream = fs.createWriteStream('output.txt');

readableStream.pipe(writeableStream);

writeableStream.on('finish', () => {
  console.log('写入完成');
});

writeableStream.on('error', (error) => {
  console.log(error);
});

上述代码中，我们创建了一个可读流对象readableStream，其源是input.txt，创建了一个可写流对象writeableStream，其写入数据的目标是output.txt。然后使用pipe()方法将可读流数据传输到可写流中。由于pipe()方法返回可写流对象，所以可以直接监听writeableStream的finish事件和error事件。

当数据传输完成，即数据成功写入output.txt文件中，就会触发finish事件，输出“写入完成”。如果在传输数据时出现错误，则会触发error事件，将错误信息输出到控制台中。

总结

使用Node.js中的流可以有效地降低内存使用，提高程序运行效率。通过可读流和可写流的组合，可以方便地进行读写数据，并以简单的管道方式进行数据的传输和处理。