我们可以把很多个 pipe 链接到一块儿用 ... 比如我现在要压缩一下 data.json 文件,然后再输出它 .. 先导入 nodejs 的 zlib 这个模块,它可以压缩或者解压文件 ..
const zlib = require('zlib');
修改一下输出的文件的名字 .. data.json.gz ..
在这个 fileReadStream 这里,再添加一个 pipe 方法 .. 在它里面,用一下 zlib.createGzip() 去处理一下读取过来的文件流 ..
后面再用一下 pipe ,把数据写入到一个文件 ...
在写入流上面会有一个 pipe 事件 .. 我们可以去订阅一下 ... 名字是 pipe .. source 表示的是源流 ... 把它输出到控制台上 ..
执行一下 .. 你会看到这里,会出现一个 data.json.gz 的压缩文件 ...
在控制台上会输出源流的相关信息 ...