浅谈stream数据流

　　汴水流，泗水流，流到瓜州古渡头, 吴山点点愁。我们知道水是源源不断的, 抽刀断水水更流, 斩不断, 理还乱, 是水流。(技术贴, 本文权当读者没学过古诗).

　　　　在一些语言里, 我们的前辈把数据当成水流, 于是有了数据流的说法~ 很贴切, 也很好理解。今天呢, 我们就一起来看看node.js里面的stream数据流。

　　　　stream是一个抽象的接口, node里有很多对象实现了这个接口, 如: 对http服务器发起请求的request对象就是一个Stream, 还有stdout(标准输出);

　　　　node.js Stream有四种流类型:

　　　　1) Readable 可读操作

　　　　2) Writable 可写操作

　　　　3) Duplex 可读可写操作

　　　　4) Transform 操作被写入数据, 然后读出结果(大致是说, 你把数据载入我的方法里, 我帮你处理后再返回给你)

　　　　而且所有的stream 都是Events 对象的实例, 也就是说可以直接添加各种监听事件哈~ 常用的stream流的事件有:

　　　　1) data 当有数据可读时候触发

　　　　2) end 没有更多数据可读时触发

　　　　3) erroe 在接收和写入过程中发生错误时触发

　　　　4) finish 所有数据已被写入时触发 (写入操作时候用)

　　　　好了, 那我们简单说下怎么从流重读取数据, 创建love.txt, 内容如下: 这不是一封情书: i love ~ ♥

　　　　创建readStream.js 文件

var fs = require("fs");
var data = '';  // 定义data 接收数据// 创建可读流
var readerStream = fs.createReadStream('love.txt');// 设置编码为 utf8。
readerStream.setEncoding('UTF8');  // 其实默认就是utf8  去掉也无妨, 这里只是为了小伙伴们知道怎么去指定编码// 处理流事件 --> data, end, and error
readerStream.on('data', function(chunk) {  // chunk 是一种数据传输机制, 把数据流分成小块输出过来
   data += chunk;
});

readerStream.on('end',function(){  // 必须数据传输完成后 才能打印出data
   console.log(data);
});readerStream.on('error', function(err){
   console.log(err.stack);
});console.log("程序执行完毕");

　　运行结果如下

程序执行完毕
这不是一封情书: i love ~ ♥

　　成功读取到文件内容, 那么怎么去写入内容呢

var fs = require("fs");
var data = '杨帅要写入的内容';// 创建一个可以写入的流，写入到文件 output.txt 中
var writerStream = fs.createWriteStream('output.txt');// 使用 utf8 编码写入数据
writerStream.write(data,'UTF8');// 写完后停止写入
writerStream.end();// 处理流事件 --> data, end, and error
writerStream.on('finish', function() {
    console.log("写入完成");
});writerStream.on('error', function(err){
   console.log(err.stack);  // 打印错误信息
});console.log("程序执行完毕");

　　　跑一下

　　　然后查看目录里, 多了一个output.txt的文件, 文件内容为:

杨帅要写入的内容

　　　符合预期, 可是代码不够优雅, 也不够精简, 那么有更简单的方法么, 有！

　　　node里面提供了一个输出流到输入流的机制(pipe) , 俗称管道流。有了这个小玩意儿, 可以事半功倍哦(而且还有一些防止读入过快, 写入过慢, 也就是俗称爆仓的功效)。麻雀虽小五脏俱全！

　　 ok, 有了它 , 画风是这样的

//  十分好用的管道流
var fs = require('fs');
var readFile = fs.createReadStream('love.txt');var writeFile = fs.createWriteStream('copy-input.txt');  // 创建可写流 并写入copy-input.txtreadFile.pipe(writeFile);  console.log('数据传输完成');

　　看起来很甜美的代码, 运行测试一下

　　果然出现了一个copy-input.txt的文件M 内容为

    这不是一封情书: i love  ~ ♥

链式流　　

　　　我们知道, 管道不一定是直达的, 那么我们怎么达到我们的目标点呢。当然是接水管呀~

　　　在node里, 我们可以通过链式的方法来对数据进行一些中间层的操作。

　　　此时我们实现一个文件的压缩和解压的demo 来体验一下, 代码里会有详细的注释。

var fs = require('fs');
var zlib = require('zlib'); //压缩和解压文件模块// 比如我们要把love.txt 压缩成  yangshuai.zzzz
// 先读取love.txt
fs.createReadStream('love.txt')
    .pipe(zlib.createGzip()) // zlib.createGzip()是压缩文件的方法  这是一个transform流, 我们前面说过transform可以操作被写入数据, 然后读出结果
    .pipe(fs.createWriteStream('yangshuai.zzzz'));console.log('看起来很严谨, 很nice');

运行一下

然后看目录

　　果不其然, 这个压缩文件已经创建成功~ 可是打开都是二进制编码宝宝看不懂怎么办~

　　没关系, 我们来解压一下

var fs = require('fs');
var zlib = require('zlib'); //压缩和解压文件模块// 比如我们要把 yangshuai.zzzz 解压成 yangshuai.txt(为了区分, 不用love.txt)
// 先读取yangshuai.zzzoz
fs.createReadStream('yangshuai.zzzz')
    .pipe(zlib.createGunzip()) // zlib.createGzip()是压缩文件的方法  这是一个transform流
    .pipe(fs.createWriteStream('yangshuai.txt'));console.log('这段解压代码看起来也很严谨, 也很nice');