"流"是一种抽象的数据结构

通过使用"流"可以将一段数据分割成几段,并按顺序传输,使用"流"可以降低对系统性能的要求,减少对CPU的消耗

Stream有三个响应事件

1.data -- 表示数据正在传输

2.end  -- 表示数据传输完成

3.error -- 表示数据传输有误

我们以创建一个文档流读取为例:

//使用严格模式
"use strict";

//引入fs模块
const fs = require("fs");

//创建文档阅读流
let re = fs.createReadStream("test.txt", "utf-8");

//监听刚刚创建的文档流的状态
re.on("data", function( chunk ){
  console.log("data: ");
  console.log( chunk );

});

re.on("end", function(){
  console.log("Read End!!");
});

re.on("error", function(err){
  console.log(err);
});

注:在一次读取文档的过程中,chunk是可以有多个的

文档流写入的方式如下:

"use strict;

const fs = require("fs");

//创建写入流
let wr = fs.createWriteStream("test.txt", "utf-8");

//一段一段地写入到test.txt文档中
wr.write("这是要写入的东西");
wr.write("另一段要写入的东西");
wr.write("写完了");

console.log("Write End!!");

注:需要流写入的话需要使用write方法

对流的pipe( 管道 )方法的使用,实现文件的复制

05-11 10:54
查看更多