首页 > web前端 > js教程 > 正文

Node.js Stream(流)

黄舟
发布: 2017-01-17 15:49:49
原创
1084人浏览过

学习要点:

从流中读取数据 

写入流 

管道流 

链式流 

node.js stream(流)

从流中读取数据 

案例:main.js

[code]var fs = require('fs');
var data = '';
// 创建可读流
var readerStream = fs.createReadStream('input.txt');
// 设置utf8编码
readerStream.setEncoding('UTF8');
// 处理流事件
// data 当有数据可读时触发
readerStream.on('data', function (chunk) {
    data += chunk;
});
// end 当没有数据读时触发
readerStream.on('end', function () {
    console.log(data);
});
// error  在接收和写入过程中发生错误时触发。
readerStream.on('error', function (err) {
    console.log(err.stack);
});
console.log('程序执行完毕。');
登录后复制

268.png

写入流 

案例:main2.js

[code]var fs = require('fs');
var data = '我是谁?';
// 创建写入流
var writeStream = fs.createWriteStream('ouput.txt');
// 编码
writeStream.write(data, 'UTF8');
// 标记文件末尾
writeStream.end();
// 处理流事件
// finish 所有数据已被写入到底层系统时触发。
writeStream.on('finish', function () {
    console.log('写入完成');
});
// error 在读入和写入数据是触发
writeStream.on('error', function (err) {
    console.log(err.stack);
});
console.log('程序执行完毕。');
登录后复制

269.png

管道流 

将一个流中的数据输入到另一个流中 

案例:pipe.js

[code]var fs = require('fs');
// 创建可读流
var readerStream = fs.createReadStream('input.txt');
// 创建写入流
var writeStream = fs.createWriteStream('ouput.txt');
// 管道读写
readerStream.pipe(writeStream);
console.log('程序执行完毕。');
登录后复制

270.png

链式流 

就是将多个输入输出流连接起来

案例:压缩文件 express.js

[code]var fs = require('fs');
var zlib = require('zlib');
// 将 input.txt 压缩为 input.gz
fs.createReadStream('input.txt')
    .pipe(zlib.createGzip())
    .pipe(fs.createWriteStream('input.gz'));
console.log('文件压缩完毕');
登录后复制

271.png

案例:解压文件 decompress.js

[code]var fs = require('fs');
var zlib = require('zlib');
// 解压 input.gz 为 input.gz.txt
fs.createReadStream('input.gz')
    .pipe(zlib.createGunzip())
    .pipe(fs.createWriteStream('input.gz.txt'));
console.log('解压文件完毕');
登录后复制

272.png

以上就是Node.js Stream(流)的内容,更多相关内容请关注PHP中文网(www.php.cn)!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号