Node的stream数据流你了解吗

const fs = require('fs');
let str_data = '';
//创建读数据的流
let readerStream = fs.createReadStream('./test.txt');
//设置流的编码格式
readerStream.setEncoding('utf8');
//给流绑定事件
readerStream.on('data',function (chunk) {
    str_data += chunk
})
readerStream.on('end',function (){
    console.log("读取的数据是：",str_data)
})
readerStream.on('error',function (err){
    console.log(err.stack)
})
console.log('-----End-----')
//    读取的数据是： 离离原上草,
//    一岁一枯荣;
//    野火烧不尽,
//    春风吹又生。

const fs = require('fs');
//创建一个读数据的流
let readerStream = fs.createReadStream('./test.txt')
//创建一个写数据的流
let writerStream = fs.createWriteStream('./out.txt')
//创建管道流
readerStream.pipe(writerStream)
console.log('----End----')
//可以完成复制，将test文件中的内容复制到out文件中

const fs = require('fs');
const zlib = require('zlib');
//创建一个读数据的流
let readerStream = fs.createReadStream('./test.txt')
                     .pipe(zlib.createGzip())
                     .pipe(fs.createWriteStream('./text.zip'))
readerStream.on('error',function (err) {
    console.log(err.stack)
})
console.log('----End----')
//创建一个名为text.zip的压缩包

const fs = require('fs');
const zlib = require('zlib');
fs.createReadStream('./test.zip')
  .pipe(zlib.createGunzip())
  .pipe(fs.createWriteStream('./db.txt'))
//解压名为test.zip的压缩包，并将其中的内容复制到db.txt当中