Node.js Stream(流)（三）

• 管道流

  管道提供了一个数据从输出流到输入流的机制。

  我们使用管道可以从一个流中获取数据并将数据传递到另外一个流中。

  举例：复制文件

  我们把文件比作装水的桶，而水就是文件里的内容，我们用一根管子(pipe)连接两个桶使得水从一个桶流入另一个桶，这样就慢慢的实现了大文件的复制过程。

  xxxxxxxxxx
  var fs = require("fs");
  
  // 创建一个可读流
  var readerStream = fs.createReadStream('input.txt');
  
  // 创建一个可写流
  var writerStream = fs.createWriteStream('output.txt');
  
  // 管道读写操作
  // 读取 input.txt 文件内容，并将内容写入到 output.txt 文件中
  readerStream.pipe(writerStream);
  

• 链式流

  链式是通过连接输出流到另外一个流并创建多个流操作链的机制。

  pipe() 方法的返回值是目标流。

  xxxxxxxxxx
  var fs = require("fs");
  var zlib = require('zlib');
  
  // 压缩 input.txt 文件为 input.txt.gz
  fs.createReadStream('input.txt')
    .pipe(zlib.createGzip())
    .pipe(fs.createWriteStream('input.txt.gz'));
  

  xxxxxxxxxx
  var fs = require("fs");
  var zlib = require('zlib');
  
  // 解压 input.txt.gz 文件为 input.txt
  fs.createReadStream('input.txt.gz')
    .pipe(zlib.createGunzip())
    .pipe(fs.createWriteStream('input.txt'));
  

实时效果反馈

1.下列描述错误的是：

A pipe()是流出流跟流入流之间的管道

B pipe()返回目标流

C pipe()可以链式操作

D pipe()返回原始输出流

答案

1=>D