Stream是一个抽象接口，Node中很多对象实现了这个接口，例如：http服务器发起请求的request对象就是一个Stream，还有stdout(标准输出)。
Node.js，Stream有四种流类型：
Readable-可读操作 Writable-可写操作 Duplex-可读可写操作 Transform-操作被写入数据，然后读出结果。
所有的Stream对象都是EventEmitter的实例。常用的事件有：
data-当有数据可读时触发 end-没有更多的数据可读时触发 error-在接收和写入过程中发生错误时触发 finish-所有数据已被写入到底层系统时触发。
从流中读取数据
var fs = require("fs");var data = ‘‘;//创建可读流var readerStream = fs.createReadStream(‘input.txt‘);//设置编码为utf8readerStream.setEncoding(‘UTF8‘);//处理流事件 -->data, end , and errorreaderStream.on(‘data‘, function(chunk) { ??data += chunk; })readerStream.on(‘end‘, function(){ ??console.log(data); })readerStream.on(‘error‘, function(err) { ??console.log(err.stack); })console.log("程序执行完毕");写入流
创建main.js文件，代码如下：
var fs = require("fs");var data = ‘菜鸟教程官网地址：www.runoob.com‘;//创建一个可以写入的流，写入到文件output.txt中var writerStream = fs.createWriteStream(‘output.txt‘);//使用utf8编码写入数据。writerStream.write(data, ‘UTF8‘);//标记文件末尾writerStream.end();//处理流事件 -->data, end ,and errorwriterStream.on(‘finish‘, function() { ???console.log("写入完成。"); ???});writerSteam.on(‘error‘, function(err) { ???console.log(err.stack); ???});console.log("程序执行完毕");创建main.js文件，代码如下：var fs = require("fs");//创建一个可读流var readerStream = fs.createReadStream(‘intput.txt‘);//创建一个可写流var writerStream = fs.createrWriteStream(‘output.txt‘);//管道读写操作//读取input.txt内容，并将内容写入到output.txt文件中。readerSteam.pipe(writerStream);console.log("程序执行完毕");链式流
链式是通过连接输出流到另一个流并创建多个操作链的机制，链式流一般用于管道操作。
接下来我们就是用管道和链式来压缩和解压文件。
创建compress.js文件，代码如下：
var fs = require("fs");var zlib = require("zlib");//压缩input.txt文件为input.txt.gzfs.createReadStream(‘input.txt‘) ??.pipe(zlib.createGizp()) ??.pipe(fs.createWriteStream(‘input.txt.gz‘));console.log("文件压缩完成。");var fs = require("fs");var zlib = require(‘zlib‘);//解压input.txt.gz文件为inpu.txtfs.createReadStream(‘input.txt.gz‘) ??.pipe(zlib.createGunzip()) ??.pipe(fs.createWriteStream(‘input.txt‘));console.log("文件解压完成");Node.js Stream
原文地址：https://www.cnblogs.com/lilinzhiyu/p/8495431.html