摘要
Stream是一个抽象接口，Node中有很多对象实现了这个接口。例如，对http服务器发送请求的request对象就是一个Stream。
Stream
Stream有四种流类型：
- Readable：可读操作。
- Writable：可写操作。
- Duplex：可读写操作。
- Transform：操作被写入数据，然后读出结果。
所有Stream对象都是EventEmitter的实例，常用的事件：
- data:当有数据可读时触发。
- end：没有更多的数据可读时触发。
- error：在接收和写入过程中发生错误时触发。
- finish：所有数据已被写入到底层系统时触发。
读取
Hello Stream world......
fs=require("fs"
data=''
readerStream=fs.createReadStream("stream.txt"
readerStream.setEncoding("UTF8"data,end,error
readerStream.on('data',+="end","error","程序执行Over");
执行
写
创建write.js
fs=require("fs" data="hello my stream world."文件output.txt中
writeStream=fs.createWriteStream("output.txt"文件
writeStream.write(data,"UTF8"标记文件末尾
writeStream.on("finish","写入完成""error","程序执行完毕");
执行
这时，在output.txt中就可以看到内容了。
管道流
管道提供了一个输出流到输入流的机制。通常用于从一个流中获取数据并将数据传递到另外一个流中。
一个例子
fs=require("fs"
readerStream=fs.createReadStream("stream.txt"
writeStream=fs.createWriteStream("output.txt"文件内容，并将内容写入到output.txt文件中。
"程序执行完毕");
链式流
链式是通过连接输出流到另外一个流并创建多个对个流操作链的机制。链式流一般用于管道操作。
一个例子
用管道和链式拉i压缩和解压缩文件
创建compress.js
fs=require("fs" zlib=require("zlib"文件 stream.txt.gz
fs.createReadStream("stream.txt").pipe(zlib.createGzip()).pipe(fs.createWriteStream("stream.txt.gz""文件压缩完成");
学习资料
