node中的流的介绍（Stream）

Stream是一个抽象接口&＃xff0c;Node中有很多对象实现了这个接口。例如&＃xff0c;对http服务器发起请求的request对象就是一个Stream&＃xff0c;还有stdout&＃xff08;标准输出&＃xff09;。

Node.js&＃xff0c;Stream有四种流类型&＃xff1a;

Readable--可读操作。
Writable--可写操作。
Duplex--可读可写操作。
Transform--操作被写入数据&＃xff0c;然后读出结果。

所有的Stream对象都是EventEmitter的实列。常用的事件有&＃xff1a;

data--当有数据可读时触发。
end--没有更多的数据可读时触发。
error--在接收和写入过程中发生错误时触发。
finish--所有数据已被写入到底层系统时触发。

1、Readable

可读流的例子包括&＃xff1a;
- HTTP responses, on the client
- HTTP requests, on the server
- fs read streams
- zlib streams
- crypto streams
- TCP sockets
- child process stdout and stderr
- process.stdin

以fs为例创建一个可读流&＃xff1a;

fs.createReadStream&＃xff08;path,[options]&＃xff09;;

path --- 要读取文件的路径
options --- 一个数组对象包含&＃xff1a;

flags:指定用什么模式打开&＃xff0c;“w”代表写&＃xff0c;“r”代表读。

endoding:编码格式“utf8"&＃xff0c;"ascii"&＃xff0c;"base64"三种格式&＃xff0c;默认“utf8”。

highWaterMark:水位线

autoClose:为true时&＃xff08;默认行为&＃xff09;&＃xff0c;对错误或结束的文件描述符将自动关闭&＃xff0c;为 false时&＃xff0c;文件描述符将不会被关闭&＃xff0c;即使他们报错了。

start&＃xff1a;开始读取的字节位置

end&＃xff1a;结束读取的字节位置。

创建一个1.txt文件&＃xff0c;内容&＃xff1a;asdfasd

同一目录下创建一个js文件

let fs &＃61; require("fs"); let path &＃61; require("path"); let readable &＃61; fs.createReadStream(path.join(__dirname,"./1.txt"),{flags: &＃39;r&＃39;,encoding: &＃39;utf8&＃39;,autoClose: true,mode: "0666", }); readable.on(&＃39;data&＃39;, function(chunk){console.log( chunk.length, chunk); }); //7 &＃39;asdfasd&＃39;

可读的流有两种模式&＃xff1a;

流动模式&＃xff1a;数据会自动从来源流出&＃xff0c;直到来源数据耗尽。

暂停模式&＃xff1a;你得通过stream.read()主动去要数据&＃xff0c;不要数据就一直等在那。

可读流在创建时都是暂停模式。暂停模式和流动模式可以相互转换。

2、Writable

可写流的例子包括了&＃xff1a;
- HTTP requests, on the client
- HTTP responses, on the server
- fs write streams
- zlib streams
- crypto streams
- TCP sockets
- child process stdin
- process.stdout, process.stderr

例如&＃xff1a;

let fs &＃61; require("fs"); let path &＃61; require("path"); let writable &＃61; fs.createWriteStream(path.join(__dirname,"./1.txt"),{flags: &＃39;w&＃39;,encoding: &＃39;utf8&＃39;,autoClose: true,mode: "0666", }); writable.on(&＃39;finish&＃39;, function(){console.log(&＃39;写入完成&＃39;);process.exit(0); }); writable.write(&＃39;node修炼中...&＃39;, &＃39;utf8&＃39;); writable.end(); //写入完成