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('吃饱了');
});