node中可读流、可写流

javascript的一个不足之处是不能处理二进制数据,于是node中引入了Buffer类型。这个类型以一个字节(即8位)为单位,给数据分配存储空间。它的使用类似于Array,但是与Array又有不同:Buffer在定义的时候必须明确知道其长度,但是Array的长度是可以动态变化的。定义Buffer有三种方式:

1. var buf = new Buffer(3);//指定buffer占用3个字节

2. var buf = new Buffer("hello","utf-8");//指定了字符串,以及字符串的编码类型为utf-8,占用5个字节

3. var buf = new Buffer([256,255,2]);//定义了buffer的每个字节所存储的数字,最大为255,超过255取模

为什么介绍Buffer呢?因为本文所介绍的流就是以字节为单位传输的,而Buffer存储的就是字节。

Node中用fs模块的createReadStream和createWriteStream分别创建可读流和可写流。先介绍第一个接口。

一. createReadStream

let fs = require('fs');
let rs =fs.createReadStream('1.txt',{highWaterMark:1});
let str = '';
rs.on('data',function (chunk) {
str+=chunk
console.log(chunk)
rs.pause();//暂停,暂停是on('data')的触发
setTimeout(function () {
rs.resume();//回复data事件
},1000);
});
rs.on('end',function () {
console.log(str)
});
rs.on('err',function (err) {
console.log(err)
})
这里highWaterMark最高水位线,内部缓冲区最多能容纳的字节数,如果超过这个大小,就停止读取资源文件,默认值是64KB这里设置1,这样比较耗性能,比如有一个100KB的文件,设置highWaterMark为10KB,
那么系统会先从资源文件中读取出10KB的数据,再触发data事件;然后再读取10KB的数据,触发data事件,不断执行,直到读出了所有的数据,触发end事件。highWaterMark不能设置的过小,过小就会频繁的操作文件,影响性能。
可读流还有两个重要的方法:pause和resume,分别可以禁止发射data事件以及激活发射data事件,本例用定时器进行演示。end以后读取完1.txt文件打印stx在后台以buffer展示 二.createWriteStream
  和createReadStream一样,它也是events的一个子类。它的drain事件在缓冲区数据写入完毕后被触发。

highWaterMark:缓存区能够容纳的最大字节数,默认为16KB,如果超过这个值,write方法就会返回false

      可写流的highWaterMark也代表了缓冲区的容量,如果缓冲区已经装满了,继续写入数据就会失败。只有等缓冲区里的内容被写入文件后,才可以重新调用write方法写入下一个highWaterMark大小的数据(data chunk)。

      可写流也有两个重要的方法:write和end,write定义了写入的内容,end可以将还未写入的内容强行写入文件,并且关闭目标文件(不能继续写入了)

例二:

let fs = require('fs');
let ws = fs.createWriteStream('3.txt');
let rs = fs.createReadStream('4.txt');
rs.on('data',function (data) {
var flag = ws.write(data);
if(!flag){
rs.pause()
}
})
ws.on('drain',function () {//当读入的文件全部写入后就恢复读取
rs.resume(); ws.end('吃饱了');
});
 
 
 
上一篇:微信小程序onlaunch异步,首页onLoad先执行?


下一篇:团队服务器搭建(搭建php环境和安装在线mysql管理工具phpmyadmin)