[Node.js]Stream

发布时间:2019-03-07 发布网站:脚本之家
脚本之家收集整理的这篇文章主要介绍了[Node.js]Stream脚本之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

摘要

Stream是一个抽象接口,Node中有很多对象实现了这个接口。例如,对http服务器发送请求的request对象就是一个Stream。

Stream

Stream有四种流类型:

  1. Readable:可读操作。
  2. Writable:可写操作。
  3. Duplex:可读写操作。
  4. Transform:操作被写入数据,然后读出结果。

所有Stream对象都是EventEmitter的实例,常用的事件:

  1. data:当有数据可读时触发。
  2. end:没有更多的数据可读时触发。
  3. error:在接收和写入过程中发生错误时触发。
  4. 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""文件压缩完成");

学习资料

总结

以上是脚本之家为你收集整理的[Node.js]Stream全部内容,希望文章能够帮你解决[Node.js]Stream所遇到的程序开发问题。

如果觉得脚本之家网站内容还不错,欢迎将脚本之家网站推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:76874919,请注明来意。
标签: