Node的stream数据流你了解吗

当我们面对大数据时，如何有效地处理数据是一个至关重要的问题。而stream数据流可以帮助我们有效地处理数据。Node.js提供了一个非常强大的模块——stream模块，它可以帮助我们实现流式数据的读写操作，可以极大地提高数据处理的效率，减少内存占用。下面让我们来一起了解一下Node.js的stream数据流。

一、stream的概念

stream（流）是一组有序的、有起点和终点的字节数据传输手段，可以对数据进行流式处理，可以读取、写入和转换数据等。在Node.js中，stream是将数据读写过程抽象出来的一种方式，Node.js中的stream是EventEmitter的实例，可以监听多个事件，比如data事件、end事件、error事件等。

二、stream的类型

Node.js中的stream有四种类型：

• Readable：表示可以读取数据的流，例如读取文件中的数据；

• Writable：表示可以写入数据的流，例如向文件中写入数据；

• Duplex：表示既能读取又能写入数据的流，例如WebSocket数据传输；

• Transform：表示读写过程中可以对数据进行额外转换，并返回转换后的数据流。

三、简单示例

创建一个文件input.txt，内容为：

hello world!

1. 读取一个文件的数据并打印

const fs = require('fs');
const rs = fs.createReadStream('./input.txt', 'utf-8');

rs.on('data', function(chunk) {
  console.log(chunk);
});

rs.on('end', function() {
  console.log('没有更多的数据了！');
});

首先我们引入fs模块，然后使用它的createReadStream方法创建一个可读流rs，并指定了编码格式，接着监听它的data事件，当有数据到来时就会触发这个事件，我们打印出这个数据，然后当文件读取完成时就会触发end事件。

1. 边读边写

const fs = require('fs');
const rs = fs.createReadStream('./input.txt');
const ws = fs.createWriteStream('./output.txt');

rs.on('data', function(chunk) {
  ws.write(chunk);
});

rs.on('end', function() {
  console.log('文件读取完成！');
  ws.end();
});

这个示例中，我们除了创建一个可读流rs外，还创建了一个可写流ws，并使用on方法监听rs的data事件，当有数据到来时就会触发这个事件，我们就可以把数据写入ws流中，当文件读取完成时就会触发end事件，我们需要调用ws的end方法来结束写入操作。

综上所述，stream数据流是Node.js中非常强大的一个模块，它可以帮助我们在处理大数据的时候提高效率和减少内存占用，学会使用它对我们的工作效率也有很大的提升。