Streams在Node.js核心API中可用作允许数据以连续方式读取或写入的对象。基本上，与缓冲区相比，流以块的形式执行该操作，逐位执行，从而使其成为一个缓慢的过程。

有四种类型的流可用：

可读（从中读取数据的流）
可写（写入数据的流）
双工（可读和可写的流）
转换（可在读取和写入时修改数据的双工流）

每种可用类型都有几种相关的方法。一些常见的是：

数据（这在数据可用时运行）
结束（当没有数据可供读取时触发）
错误（当接收或写入数据时出错）

管

在编程中， pipe的概念并不新鲜。自20世纪70年代以来，基于Unix的系统一直在实用。管道做什么？ pipe通常连接源和目的地。它将一个函数的输出作为另一个函数的输入传递。

在Node.js中， pipe以相同的方式使用，以配对不同操作的输入和输出。 pipe()作为一个函数可用，它接受可读的源流并将输出附加到目标流。一般语法可以表示为：

src.pipe(dest);

多个pipe()函数也可以链接在一起。

a.pipe(b).pipe(c);

 // which is equivalent to

 a.pipe(b);
 b.pipe(c);

可读流

生成可作为输入附加到可写流的数据的流称为可读流。要创建可读流：

const { Readable } = require('stream');

 const readable = new Readable();

 readable.on('data', chunk => {
  console.log(`Received ${chunk.length} bytes of data.`);
 });
 readable.on('end', () => {
  console.log('There will be no more data.');
 });

可写流

这是一种流的类型，您可以将数据从可读源pipe()传输pipe() 。要创建可写流，我们有一个构造函数方法。我们从中创建一个对象并传递许多选项。该方法有三个参数：

块：一个缓冲区
编码：将数据转换为人类可读的形式
callback：从块中完成数据处理时调用的函数

const { Writable } = require('stream');
 const writable = new Writable({
  write(chunk, encoding, callback) {
    console.log(chunk.toString());
    callback();
  }
 });

 process.stdin.pipe(writable);

双工流

双工流帮助我们同时实现可读和可写流。

const { Duplex } = require('stream');

 const inoutStream = new Duplex({
  write(chunk, encoding, callback) {
    console.log(chunk.toString());
    callback();
  },

  read(size) {
    this.push(String.fromCharCode(this.currentCharCode++));
    if (this.currentCharCode > 90) {
      this.push(null);
    }
  }
 });

 inoutStream.currentCharCode = 65;
 process.stdin.pipe(inoutStream).pipe(process.stdout);

stdin流将可读数据管道传输到双工流中。 stdout帮助我们查看数据。双工流的可读和可写部分完全独立地操作。

变换流

这种类型的流更多是双工流的高级版本。

const { Transform } = require('stream');

 const upperCaseTr = new Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
 });

 process.stdin.pipe(upperCaseTr).pipe(process.stdout);

我们消耗的数据与前面的双工流示例相同。这里需要注意的是transform()不需要实现read或write方法。它结合了两种方法本身。

为什么要使用Streams？

由于Node.js是异步的，因此通过将回调传递给具有磁盘和网络的函数来进行交互。下面给出的示例从磁盘上的文件读取数据，并通过来自客户端的网络请求对其进行响应。

const http = require('http');
 const fs = require('fs');

 const server = http.createServer((req, res) => {
  fs.readFile('data.txt', (err, data) => {
    res.end(data);
  });
 });
 server.listen(8000);

上面的代码片段将起作用，但在将结果写回客户端请求之前，文件中的所有数据将首先进入每个请求的内存。如果我们正在读取的文件太大，这可能会成为一个非常繁重且昂贵的服务器调用，因为它将消耗大量内存以使进程前进。客户端的用户体验也会受到延迟的影响。

在这种情况下，如果我们使用流，则数据一旦从磁盘接收就会一次作为一个块发送到客户端请求。

const http = require('http');
 const fs = require('fs');

 const server = http.createServer((req, res) => {
  const stream = fs.createReadStream('data.txt');
  stream.pipe(res);
 });
 server.listen(8000);

pipe()在这里负责写入或在我们的情况下，使用响应对象发送数据，并且一旦从文件读取所有数据，就关闭连接。

注意： process.stdin和process.stdout是在Node.js API提供的全局process对象的流中构建的。

Node.js流

管

可读流

可写流

双工流

变换流

为什么要使用Streams？

更多Node.js教程