摘要
Stream是一个抽象接口,Node中有很多对象实现了这个接口。例如,对http服务器发送请求的request对象就是一个Stream。
Stream
Stream有四种流类型:
- Readable:可读操作。
- Writable:可写操作。
- Duplex:可读写操作。
- Transform:操作被写入数据,然后读出结果。
所有Stream对象都是EventEmitter的实例,常用的事件:
- data:当有数据可读时触发。
- end:没有更多的数据可读时触发。
- error:在接收和写入过程中发生错误时触发。
- finish:所有数据已被写入到底层系统时触发。
读取
创建stream.txt文件,内容如下:
Hello Stream world......
创建stream.js文件,代码如下:
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."
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"
"程序执行完毕");
链式流
链式是通过连接输出流到另外一个流并创建多个对个流操作链的机制。链式流一般用于管道操作。
一个例子
用管道和链式拉i压缩和解压缩文件
创建compress.js
fs=require("fs" zlib=require("zlib"
fs.createReadStream("stream.txt").pipe(zlib.createGzip()).pipe(fs.createWriteStream("stream.txt.gz""文件压缩完成");
学习资料
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。