nodejs-Sream
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了nodejs-Sream相关的知识,希望对你有一定的参考价值。
Stream 是一个抽象接口,Node 中有很多对象实现了这个接口。例如,对http 服务器发起请求的request 对象就是一个 Stream,还有stdout(标准输出)。
Node.js,Stream 有四种流类型:
Readable - 可读操作。
Writable - 可写操作。
Duplex - 可读可写操作.
Transform - 操作被写入数据,然后读出结果。
所有的 Stream 对象都是 EventEmitter 的实例。常用的事件有:
data - 当有数据可读时触发。
end - 没有更多的数据可读时触发。
error - 在接收和写入过程中发生错误时触发。
finish - 所有数据已被写入到底层系统时触发。
var fs = require("fs");
var data = ‘‘;
// 创建可读流
var readerStream = fs.createReadStream(‘input.txt‘);
// 设置编码为 utf8。
readerStream.setEncoding(‘UTF8‘);
// 处理流事件 --> data, end, and error
// 有数据返回的时候,后台会出发eventEmitter.emit(‘data‘)事件
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("程序执行完毕");
管道流
1 2 3 4 5 6 7 8 9 10 11 12 13 | 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( "程序执行完毕" ); |
链式流
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | // --------------链式流----------- // -------------压缩文件----------- 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( "文件压缩完成。" ); // ----------------解压文件------- 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( "文件解压完成。" ); |
以上是关于nodejs-Sream的主要内容,如果未能解决你的问题,请参考以下文章