什么是流?
说到流,就涉及到一个*nix的概念:管道——在*nix中,流在Shell中被实现为可以通过 |(管道符) 进行桥接的数据,一个进程的输出(stdout)可被直接作为下一个进程的输入(stdin)。
在Node中,流(Stream)的概念与之类似,代表一种数据流可供桥接的能力。
pipe
流化的精髓在于 .pipe()方法。可供桥接的能力,在于数据流的两端(上游/下游 或称为 读/写流)以一个 .pipe()方法进行桥接。

伪代码的表现形式为:
//上游.pipe(下游)
Readable.pipe(Writable);
流的分类
这里并不打算讨论所谓的Node v0.4 之前的“经典”流。那么,流分为这么几类(皆为抽象接口:
1.stream.Readable 可读流(需要实现_read方法,关注点在于对数据流读取的细节
2.stream.Writable 可写流(需要实现_write方法,关注点在于对数据流写入的细节
3.stream.Duplex 可读/写流(需要实现以上两接口,关注点为以上两接口的细节
4.stream.Transform 继承自Duplex(需要实现_transform方法,关注点在于对数据块的处理
简单来说:
1).pipe() 的拥有者一定具备 Readable 流(并不局限于)能力,它拥有 ‘readable’/’data’/’end’/’close’/’error’ 一系列事件可供订阅,也提供 .read()/.pause()/.resume()等一系列方法供调用;
2).pipe() 的参数一定具备Writable 流(并不局限于 )能力,它拥有 ‘drain’/’pipe’/’unpipe’/’error’/’finish’ 事件可供访问,也提供 .write()/.end() 等一系列方法供调用
什么鬼
有没有一丝丝焦虑?别急,做为一个说人话的低级码工,我会把Stream掰开了和您扯一扯的。
Stream类,在 Node.js的源码 里,是这么定义的:
var EE = require(‘events’).EventEmitter;
var util = require(‘util’);
util.inherits(Stream, EE);
function Stream() {
EE.call(this);
}
可以看出,本质上,Stream是一个EventEmitter,那意味着它具备事件驱动的功能(.emit/.on…)。众所周知,“Node.js 就是基于V8的事件驱动平台”,实现了事件驱动的流式编程,具备了和Node一样的异步回调的特征。
比如在 Readable 流中,有一个 readable 事件,在一个暂停的只读流中,只要有数据块准备好可读时,它就会被发送给订阅者(Readable 流有哪些呢?express中的 req,ftp或者mutli-form上传组件的req.part,系统中的标准输入 process.stdin等)。有了readable 事件,我们可以做个处理shell 命令输出的分析器之类的工具:









