标签：处理 over class output src compress alt run ror
Stream是一个抽象接口，Node中有很多对象实现了这个接口。例如，对http服务器发送请求的request对象就是一个Stream。
Stream有四种流类型：
所有Stream对象都是EventEmitter的实例，常用的事件：
创建stream.txt文件，内容如下：
Hello Stream world......
创建stream.js文件，代码如下：
//引入fs模块。 var fs=require("fs"); //接收数据变量 var data=‘‘; //创建可读流 var readerStream=fs.createReadStream("stream.txt"); //设置编码utf8 readerStream.setEncoding("UTF8"); //处理流事件——>data,end,error readerStream.on(‘data‘,function(chunk){ data+=chunk; }); readerStream.on("end",function(){ console.log(data); }); readerStream.on("error",function(err){ console.log(err.stack); }); console.log("程序执行Over");
执行
创建write.js
//引入fs var fs=require("fs"); var data="hello my stream world."; //创建一个可以写入的流。写入到文件output.txt中 var writeStream=fs.createWriteStream("output.txt"); //使用utf8 写入文件 writeStream.write(data,"UTF8"); //标记文件末尾 writeStream.end(); //处理流事件 writeStream.on("finish",function(){ console.log("写入完成"); }); writeStream.on("error",function(err){ console.log(err.stack); }); console.log("程序执行完毕");
执行
这时，在output.txt中就可以看到内容了。
管道提供了一个输出流到输入流的机制。通常用于从一个流中获取数据并将数据传递到另外一个流中。
一个例子
var fs=require("fs"); //创建一个可读流 var readerStream=fs.createReadStream("stream.txt"); //创建一个可写流 var writeStream=fs.createWriteStream("output.txt"); //管道读写操作 //读取stream.txt文件内容，并将内容写入到output.txt文件中。 readerStream.pipe(writeStream); console.log("程序执行完毕");
链式是通过连接输出流到另外一个流并创建多个对个流操作链的机制。链式流一般用于管道操作。
一个例子
用管道和链式拉i压缩和解压缩文件
创建compress.js
var fs=require("fs"); var zlib=require("zlib"); //压缩stream.txt 文件 stream.txt.gz fs.createReadStream("stream.txt").pipe(zlib.createGzip()).pipe(fs.createWriteStream("stream.txt.gz")); console.log("文件压缩完成");
学习资料
http://www.runoob.com/nodejs/nodejs-stream.html
标签：处理 over class output src compress alt run ror
原文地址：http://www.cnblogs.com/wolf-sun/p/6346573.html
