nodeks —— fs模块 —— 从流中 读取和写入数据
Fs流读取和写入数据
使用文件流来读取大文件不会卡顿
1, 从流中读取数据
var fs = require("fs");
var data = '';
var count = 0;
// 创建可读流
var readerStream = fs.createReadStream('t.txt');
// 设置编码为 utf8。
readerStream.setEncoding('UTF8');
// 处理流事件 --> data, end, and error
readerStream.on('data', function(chunk) {
data += chunk;
count++
});
readerStream.on('end',function(){
console.log(data);
console.log(count); //count:读取次数
});
readerStream.on('error', function(err){
console.log(err.stack);
});
console.log("程序执行完毕");
2, 写入流
var fs = require("fs");
var data = ' ----- 数据库数据 ----- ';
// 创建一个可以写入的流,写入到文件 t.txt 中
var writerStream = fs.createWriteStream('t.txt');
// 使用 utf8 编码写入数据
writerStream.write(data,'UTF8');
// 标记文件末尾
writerStream.end();
// 处理流事件 --> data, end, and error
writerStream.on('finish', function() {
console.log("写入完成。");
});
writerStream.on('error', function(err){
console.log(err.stack);
});
console.log("程序执行完毕");
3, 管道流
var fs = require('fs')
var readerStream = fs.createReadStream('t.txt')
// 1,覆盖原来内容
// var writerStream = fs.createWriteStream('pipe.txt')
// 2.原内容后追加
var writerStream = fs.createWriteStream('pipe.txt',{ 'flags': 'a' })
readerStream.pipe(writerStream)
console.log('管道输送完成')
4, 链式流
链式是通过连接输出流到另外一个流并创建多个流操作链的机制。链式流一般用于管道操作。
接下来我们就是用管道和链式来压缩和解压文件。
创建 compress.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("文件压缩完成。");
代码执行结果如下:
$ node compress.js
文件压缩完成。
执行完以上操作后,我们可以看到当前目录下生成了 input.txt 的压缩文件 input.txt.gz。
接下来,让我们来解压该文件,创建 decompress.js 文件,代码如下:
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("文件解压完成。");
代码执行结果如下:
$ node decompress.js
文件解压完成。
相关文章
- python之psutil模块(获取系统性能数据)
- swoole模块的编译安装:php编译安装swoole模块的代码
- 时间模块和random模块
- 第四十二节,configparser特定格式的ini配置文件模块
- 第三十五节,json数据类型转换字符串模块
- python 查看模块的存放位置
- python-面向对象-12_模块和包
- Nginx编译安装第三方模块http_substitutions_filter_module2222
- 【IIS】模块 DLL C:WindowsSystem32inetsrvauthcert.dll 未能加载。返回的数据为错误信息。
- Eigen(几何模块)——常用相互转换
- 〖Python 数据库开发实战 - Python与MySQL交互篇⑤〗- MySQL Connector 模块的删除数据
- 〖Python 数据库开发实战 - Python与MySQL交互篇⑦〗- MySQL Connector模块的综合案例 2
- 关于Python的随机数模块,你必须要掌握!
- Python编程:shelve模块-持久化python数据
- Python:PyMySQL模块读写MySQL数据
- Python:使用 mysqlsmom 模块实时同步MySQL数据到ElasticSearch
- js 模块化基础和模块规范AMD、CMD、ES6模块
- 【CSS】浮动 ④ ( 浮动布局案例 - 电商布局模块 | 案例分析 | 布局测量摆放 | 浮动布局代码示例 )
- FastAdmin 建议引入模块JS的地方不要固定写死
- 手把手教你做用户画像——标签数据开发:用户画像工程化的重点模块,包含统计类、规则类、挖掘类、流式计算类标签的开发,标签相关数据可存储在Hive、MySQL、HBase、Elasticsearch等数据库中
- Spring-Boot-Starter常用依赖模块详解
- 并行数据流转换为一种特殊串行数据流模块的设计:设计两个可综合的电路模块,第一个模块(M1)能把4位的并行数据转换为符合以下协议的串行数据流