add

Author: webVueBlog

企业级/流.md

@@ -138,6 +138,140 @@ rr.on('end', () => {
 
 调用 stream.resume()并且readsFlowing不为true时，将发出resume事件。
 
+## stream.Readable 类方法
 
+stream.Readable类包含以下常用的方法：
+
+1. destroy
+
+readable.destroy([error]) 方法用于销毁流，并触发 error 事件 和 close 事件. 调用后，可读流将释放所有的内部资源，且忽视后续的push()调用。
+
+实现流时不应该重写这个方法，而是重写readable._destroy()
+
+2. isPaused
+
+readable.isPaused()方法用于返回可读流当前的操纵状态。主要用于 readable.pipe() 底层的机制，大多数情况下无须直接使用该方法
+
+```js
+const readable = new stream.Readable();
+
+readable.isPaused(); // === false
+readable.pause();
+readable.isPaused(); // === true
+readable.resume();
+readable.isPaused(); // ==== false
+```
+
+3. pause 与 resume
+
+readable.pause() 方法使流动模式的流停止触发 data 事件，并切换到流动模式。任何可用的数据都会保留在内部缓存中。
+
+相对的, readable.resume() 将被暂停⏸️的可读流恢复触发data事件，并将流切换到流动模式。
+
+```js
+const fs = require('fs');
+
+const readable = fs.createReadStream('data.txt');
+readable.on('data', (chunk) => {
+ console.log(`接收到${chunk.length}字节的数据`);
+ // 暂停
+ readable.pause();
+
+ console.log('暂停一秒');
+ setTimeout(() => {
+  console.log('数据重新开始流动');
+  // 继续
+  readable.resume();
+ },1000);
+});
+
+readable.on('end', () => {
+ console.log('结束');
+});
+```
+
+4. pipe
+
+readable.pipe(destination[, options]) 方法用于绑定 可写流 到 可读流，将 可读流 自动切换到流动模式，并将可读流的所有数据推送到绑定的可写流。
+
+数据流会被自动管理，所以即使可读流更快，目标可写流也不会超负荷。
+
+将可读流的所有数据通过管道推送到 write-data.txt 文件
+
+```js
+const fs = require('fs')
+
+const readable = fs.createReadStream('data.txt');
+
+const writable = fs.createWriteStream('write-data.txt');
+
+// readable 的所有数据都推送到 write-data.txt
+readable.pipe(writable);
+```
+
+可以在单个可读流上绑定多个可写流。
+
+```js
+readable.pipe() // 会返回目标流的引用，这样就可以对流进行链式的管道操作。
+
+const fs = require('fs');
+const zlib = require('zlib');
+
+const readable = fs.createReadStream('data.txt');
+const gzip = zlib.createGzip();
+const writable2 = fs.createWriteStream('write-data.txt.gz');
+
+// 在单个可读流上绑定多个可写流
+readable.pipe(gzip).pipe(writable2);
+```
+
+默认情况下，当来源可读流触发 end 事件时，目标可写流 也会调用 stream.end() 结束写入。
+
+若要禁用这种默认行为，end选项应设为 false ，这样目标流就回保持打开。
+
+```js
+reader.pipe(writer, { end: false });
+reader.on('end', () => {
+ writer.end('结束');
+});
+```
+
+如果可读流发生错误🙅🙅‍♂️，目标可写流不会自动关闭，需要手动关闭所有流以避免内存泄漏。
+
+process.stderr 和 process.stdout 可写的流在 Node.js 进程退出之前永远不会关闭，无论指定的选项如何。
+
+5. read
+
+readable.read([size]) 方法用于从内部缓冲拉取并返回数据。其中，size 指定要读取的数据的字节数。如果没有指定 size 参数，则返回内部缓冲中的所有数据。
+
+该方法如果没有可读的数据，则返回null。默认情况下，readable.read() 返回的数据是 Buffer对象，除非使用 readable.setEncoding() 指定字符编码或流 处于对象模式。
+
+如果可读的数据不足size 个字节，则返回内部缓冲剩余的数据，如果流已经结束则 返回null
+
+readable.read() 应该只对 处于暂停模式的可读流调用。在流动模式中， readable.read() 会自动调用直到内部缓冲的数据完全耗尽。
+
+如果 readable.read() 返回一个数据块，则data 事件也会触发。
+
+end事件触发后再调用 stream.read([size]) 会返回null，不会抛出错误。
+
+```js
+const fs = require('fs');
+const readable = fs.createReadStream('data.txt');
+
+// 设置字符编码
+readable.setEncoding('utf-8');
+
+// 读取数据
+readable.on('readable', () => {
+ let chunk;
+ while (null !== (chunk = readable.read(10))) {
+  console.log
+ }
+})
+
+readable.on('end', () =>{
+ console.log()
+})
+```