add

Author: webVueBlog

企业级/流.md

@@ -48,18 +48,95 @@ const stream = require('stream');
 
 所有可读流都实现了 stream.Readable 类定义的接口。
 
-类事件
+Node.js可读流是对提供数据的来源的一种抽象。所有可读流都实现了stream.Readable类定义的接口。可读流常见的例子包括客户端的HTTP响应，服务器的HTTP请求，fs的读取流，zlib流，crypto流，TCP socket，子进程stdout与stderr, process.stdin.
 
-close 事件在流或其底层资源被关闭时触发。
+## stream.Readable 类事件
 
-data 事件
+stream.Readable 类定义了如下事件。
 
+1. close事件
 
+close事件在流或其底层资源（如文件描述符）被关闭时触发。表明不会再触发其他事件，也不会再发生操作。
 
+不是所有可读流都会触发close事件。如果使用emitClose选项创建可读流，则它将始终发出close事件。
 
+2. data事件
 
+data事件是在流将数据块传送给“消费者”后触发。对于非对象模式的流，数据块可以是字符串或Buffer。对于对象模式的流，数据块可以是除了null的任何JavaScript值。
 
+当调用 readable.pipe(), readable.resume() 或绑定监听器到 data 事件时，流会转换到流动模式。当调用 readable.read()且有数据块返回时，也会触发data事件。
 
+如果使用 readable.setEncoding() 为流指定 🈯️ 了默认的字符编码，则监听器回调传入的数据为字符串，否则传入的数据为Buffer。
+
+
+3. end事件
+
+end 事件在流中没有数据可供消费时触发。
+
+end 事件只有在你数据被完全消费掉后才会触发。要想触发该事件，可以将流转换到流动模式，或反复调用 stream.read() 直到数据被消费完。
+
+```js
+const readable = getReadableStreamSomehow();
+
+readable.on('data', (chunk) => {
+ console.log(`接收到${chunk.length}个字节的数据`);
+});
+
+readable.on('end', () => {
+ console.log(`已经没有数据`);
+});
+```
+
+4. error事件
+
+error事件通常是在当流因底层内部出错而不能产生数据，或推送无效的数据块时触发。
+
+监听器回调将传递一个Error对象
+
+5. pause事件
+
+调用 stream.pause() 并且 readsFlowing 不为 false时，会发出pause事件。
+
+6. readable事件
+
+readable事件在当流中有数据可供读取时触发。
+
+```js
+const readable = getReadableStreamSomehow();
+
+readable.on('readable', function() {
+ // 有数据可读取
+ let data;
+ while(data = this.read()) {
+  console.log(data);
+ }
+});
+```
+
+当到达流数据的尽头时，readable事件也会触发，但是在end事件之前触发。
+
+readable 事件表明流有新的动态，要么有新的数据，要么到达流的尽头。对于前者，stream.read() 会返回可用的数据。对于后者，stream.read() 会返回 null 。 例如，下面的例子中，foo.txt是一个空文件。
+
+```js
+const fs = require('fs');
+const rr = fs.createReadStream('data.txt');
+rr.on('readable', () => {
+ console.log(`读取的数据${rr.read()}`);
+});
+rr.on('end', () => {
+ console.log('结束');
+});
+```
+
+通常情况下， readable.pipe() 和 data事件的机制比 readable 事件更容易理解。处理 readable 事件可能造成吞吐量升高。
+
+如果同时使用 readable 事件 和 data 事件，则 readable 事件会优先控制流，也就是说，当调用 stream.read() 时才会触发 data 事件。 readableFlowing 属性会变成 false。
+
+当移除 readable 事件时，如果存在data事件监听器，则流会开始流动，也就是说，无须调用stream.resume() 也会触发data事件。
+
+7. resume事件
+
+调用 stream.resume()并且readsFlowing不为true时，将发出resume事件。