Node.js Stream(流)（一）

流是为 Node.js 应用程序提供动力的基本概念之一。

流是一种以高效的方式处理读/写文件、网络通信、或任何类型的端到端的信息交换。

stream 提供了构建所有流 API 的基础。 所有的流都是EventEmitter的实例。

举例：

xxxxxxxxxx
var fs = require("fs");
fs.readFile(__dirname + '/input.txt', (err, data) => {
    console.log(data.toString())
  })

xxxxxxxxxx
//可读流可以从一文件中读取信息。
//读取的数据可以暂时存放在缓存（Buffer）里，防止应用程序无法及时处理。 
//创建可读流
var readerStream = fs.createReadStream('input.txt');

// 处理流事件 
readerStream.on('data', function(chunk) {
    data += chunk;
 
});

流基本上提供了两个主要优点：

• 内存效率: 无需加载大量的数据到内存中即可进行处理。
• 时间效率: 当获得数据之后即可立即开始处理数据，这样所需的时间更少，而不必等到整个数据有效负载可用才开始。

创建可读流

xxxxxxxxxx
const Stream = require('stream')
//首先创建流对象
const readableStream = new Stream.Readable()
//实现 readable._read() 方法
readableStream._read=()=>{}
//监听可读流里面是否有可读的数据
readableStream.on('data',(chunk)=>{
    console.log(chunk.toString())
})
//发送数据
readableStream.push('百战')
readableStream.push('程序员')

实时效果反馈

1.下列描述错误的是：

A 所有的流都是EventEmitter的实例

B 通过readableStream.on('data')可以读取可读流的数据

C fs.readFile创建一个可读流

D fs.createReadStream创建一个可读流

答案

1=>C