Node.js Streams文件读写操作详解

Node.js 天生异步和事件驱动，非常适合处理 I/O 相关的任务。如果你在处理应用中 I/O 相关的操作，你可以利用 Node.js 中的流(stream)。因此，我们先具体看看流，理解一下它们是怎么简化 I/O 操作的吧。 

流是什么
流是 unix 管道，让你可以很容易地从数据源读取数据，然后流向另一个目的地。
简单来说，流不是什么特别的东西，它只是一个实现了一些方法的 EventEmitter 。根据它实现的方法，流可以变成可读流(Readable)，可写流(Writable)，或者双向流(Duplex，同时可读可写)。
可读流能让你从一个数据源读取数据，而可写流则可以让你往目的地写入数据。
如果你已经用过 Node.js，你很可能已经遇到过流了。
例如，在一个 Node.js 的 HTTP 服务器里面， request 是一个可读流， response 是一个可写流。
你也可能用过 fs 模块，它能帮你处理可读可写流。
 现在让你学一些基础，理解不同类型的流。本文会讨论可读流和可写流，双向流超出了本文的讨论范围，我们不作讨论。
 可读流 (Readable Streams)
 我们可以用可读流从一个数据源中读取数据，这个数据源可以是任何东西，例如系统中的一个文件，内存中的 buffer，甚至是其他流。因为流是 EventEmitter ，它们会用各种事件发送数据。我们会利用这些事件来让流工作。

从流中读取数据
 从流中读取数据最好的方式是监听 data 事件，添加一个回调函数。当有数据流过来的时候，可读流会发送 data 事件，回调函数就会触发。看看下面的代码片段：

 var fs = require('fs');var readableStream = fs.createReadStream('file.txt');var data = '';var readableStream.on('data', function(chunk){ data += chunk;});readableStream.on('end', function(){ console.log(data);}); 

fs.createReadStream 会给你一个可读流。
最开始的时候，这个流不是流动态的。当你添加了 data 的事件监听器，加上一个回调函数时，它才会变成流动态的。在这之后，它就会读取一小块数据，然后传到你的回调函数里面。
流的实现者决定了 data 事件的触发频率，例如 HTTP request 会在读取到几 KB 数据的时候触发 data 事件。 当你从一个文件中读取数据的时候，你可能会决定当一行被读完的时候就触发 data 事件。
当没有数据可读的时候 (读到文件尾部时)，流就会发送 end 事件。在上面的例子中，我们监听了这个事件，当读完文件的时候，就把数据打印出来。
还有另一种读取流的方式，你只要在读到文件尾部前不断调用流实例中的 read() 方法就可以了。

 var fs = require('fs');var readableStream = fs.createReadStream('file.txt');var data = '';var chunk;readableStream.on('readable', function(){ while ((chunk = readableStream.read()) != null) { data += chunk; }});readableStream.on('end', function(){ console.log(data);});