关注我们

Node.js - Streams

Stream流是使您可以连续地从源读取数据或将数据写入目标的对象，在Node.js中，有四种类型的流-

Readable - 用于读取操作的流。
Writable - 用于写操作的流。
Duplex - 可用于读取和写入操作的流。
Transform - 一种双工流，其中基于输入来计算输出。

每种类型的流都是一个 EventEmitter 实例，例如，一些常用事件是-

data - 当有可读取的数据时，将触发此事件。
end - 当没有更多数据可读取时，将触发此事件。
error - 接收或写入数据时发生任何错误。
finish - 当所有数据都已刷新到系统时，将触发此事件。

本教程提供了对流上常用操作的基本了解。

读取流

创建一个名为input.txt的文本文件，其内容如下:

Learnfk Point is giving self learning content
to teach the world in simple and easy way!!!!!

使用以下代码创建一个名为main.js的js文件-

var fs=require("fs");
var data='';

//创建可读流
var readerStream=fs.createReadStream('input.txt');

//设置编码为utf8。
readerStream.setEncoding('UTF8');

//处理流事件 --> 数据、结束和错误
readerStream.on('data', function(chunk) {
   data += chunk;
});

readerStream.on('end',function() {
   console.log(data);
});

readerStream.on('error', function(err) {
   console.log(err.stack);
});

console.log("Program Ended");

现在运行main.js以查看输出-

$node main.js

验证输出。

Program Ended
Learnfk Point is giving self learning content
to teach the world in simple and easy way!!!!!

写入流

使用以下代码创建一个名为main.js的js文件-

var fs=require("fs");
var data='Simply Easy Learning';

//创建可写流
var writerStream=fs.createWriteStream('output.txt');

//将数据写入流，编码为 utf8
writerStream.write(data,'UTF8');

//标记文件结尾
writerStream.end();

//处理流事件 --> 完成和错误
writerStream.on('finish', function() {
   console.log("Write completed.");
});

writerStream.on('error', function(err) {
   console.log(err.stack);
});

console.log("Program Ended");

现在运行main.js以查看输出-

$node main.js

验证输出。

Program Ended
Write completed.

现在打开在当前目录中创建的output.txt；它应包含以下内容-

Simply Easy Learning

管道流

管道是一种机制，无涯教程将一个流的输出作为另一流的输入，它通常用于从一个流中获取数据并将该流的输出传递到另一流，管道操作没有限制。现在，无涯教程将展示一个管道示例，该示例用于读取一个文件并将其写入另一个文件。

无涯教程网

使用以下代码创建一个名为main.js的js文件-

var fs=require("fs");

//创建可读流
var readerStream=fs.createReadStream('input.txt');

//创建可写流
var writerStream=fs.createWriteStream('output.txt');

//管道读取和写入操作
//读取 input.txt 并将数据写入 output.txt
readerStream.pipe(writerStream);

console.log("Program Ended");

现在运行main.js以查看输出-

$node main.js

验证输出。

Program Ended

打开在当前目录中创建的output.txt；它应包含以下内容-

Learnfk Point is giving self learning content
to teach the world in simple and easy way!!!!!

链接流

链接是一种将一个流的输出连接到另一流并创建多个流操作的链的机制，通常用于管道操作，现在，无涯教程将使用管道和链接来压缩文件，然后将其解压缩

使用以下代码创建一个名为main.js的js文件-

var fs=require("fs");
var zlib=require('zlib');

//压缩文件 input.txt 为 input.txt.gz
fs.createReadStream('input.txt')
   .pipe(zlib.createGzip())
   .pipe(fs.createWriteStream('input.txt.gz'));
  
console.log("File Compressed.");

现在运行main.js以查看输出-

$node main.js

验证输出。

File Compressed.

您会发现input.txt已被压缩，并在当前目录中创建了文件input.txt.gz。现在让无涯教程尝试使用以下代码解压缩同一文件-

var fs=require("fs");
var zlib=require('zlib');

//解压文件 input.txt.gz 为 input.txt
fs.createReadStream('input.txt.gz')
   .pipe(zlib.createGunzip())
   .pipe(fs.createWriteStream('input.txt'));
  
console.log("File Decompressed.");