详解nodeJs文件系统（fs）与流（stream）

更新时间：2018年01月24日 09:58:24 作者：黄大渣渣

这篇文章主要介绍了详解nodeJs文件系统（fs）与流（stream），小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

一、简介

本文将介绍node.js文件系统（fs）和流（stream）的一些API已经参数使用情况。

二、目录

文件系统将介绍以下方法：

1.fs.readFile

2.fs.writeFile

3.fs.open

4.fs.read

5.fs.stat

6.fs.close

7.fs.mkdir

8.fs.rmdir

9.fs.readdir

10.fs.unlink

stream流的四种类型readable，writable，duplex，transform以及stream对象的事件。

三、文件系统fs主要方法介绍

1、fs.readFile

readFile方法主要是读取文件内容，异步操作。

var fs = require('fs')
fs.readFile('a.txt',function(err,data){
  if (err){
    return console.error(err);
  }else{
    console.log("异步读取: " + data.toString());
  }
})

2、fs.writeFile

writeFile以异步的方式写入文件，fs.writeFile(file, data[, options], callback)

var fs = require('fs')
console.log("准备写入文件")
fs.writeFile('input.txt',"写入的内容",function(err){
  if (err){
    return console.error(err);
  }else{
    console.log("写入成功");
  }
})

3、fs.open()

在异步方式下打开文件，fs.open(path, flags[, mode], callback)

var fs = require("fs");
// 异步打开文件
console.log("准备打开文件");
fs.open('a.txt', 'r+', function(err, fd) {//r+是以读写模式打开，fd为返回的文件描述符
  if (err) {
    return console.error(err);
  }
 console.log("文件打开成功！");   
});

4、fs.read（）

此方法为异步方式下读取文件，格式：fs.read(fd, buffer, offset, length, position, callback)

var fs = require("fs");
var buf = new Buffer(1024);

console.log("准备打开文件！");
fs.open('at.txt', 'r+', function(err, fd) {
  if (err) {
    return console.error(err);
  }
  fs.read(fd, buf, 0, buf.length, 0, function(err, bytes){
   if (err){
     console.log(err);
   }
   // 仅输出读取的字节
   if(bytes > 0){
     console.log(buf.slice(0, bytes).toString());
   }
  });
});

5、fs.stat()

此方法为异步方式获取文件信息，格式：fs.stat(path, callback)

fs.stat('fs.js', function (err, stats) {
  console.log(stats.isFile());     //true
})

异步返回的stats类的实例有很多方法，比如stats.isFile()判断是否是文件，stats.isDirectory()判断是否是目录，。。。。。。

6、fs.close()

fs.close()是以异步的方式关闭文件，语法格式：fs.close(fd, callback)，参数如下：

d - 通过 fs.open() 方法返回的文件描述符。

callback - 回调函数，没有参数。

7、fs.mkdir()

此方法为创建目录，格式：fs.mkdir(path[, mode], callback)，参数如下：

path：路径。

mode:目录权限，默认0777.。

callback：回调，没有参数。

var fs = require("fs");
console.log("创建目录/test/");
fs.mkdir("/test/",function(err){
  if (err) {
    return console.error(err);
  }
  console.log("创建/test目录成功。");
});

8、fs.rmdir()

删除目录，语法格式：fs.rmdir(path,callback)

9、fs.readdir()

此方法为读取目录，语法格式：fs.readdir(path, callback)，callback回调函数有两个参数，第一个是err，第二个为目录下的文件数组files。

var fs = require("fs");

console.log("查看 /tmp 目录");
fs.readdir("/tmp/",function(err, files){
  if (err) {
    return console.error(err);
  }
  files.forEach( function (file){
    console.log( file );
  });
});

10、fs.unlink()

此方法作用为删除文件，格式：fs.unlink(path, callback)

var fs = require("fs");

console.log("准备删除文件！");
fs.unlink('input.txt', function(err) {
  if (err) {
    return console.error(err);
  }
  console.log("文件删除成功！");
});

四、stream流类型与事件介绍

1、 stream：流是一个抽象接口，有四种流类型：

readable ：可读；
writable ：可写操作；
duplex ：可读可写操作；
transform ：操作被写入数据，然后读出结果。

所有的stream对象都是EventEmitter 的实例，常用事件有：

data：当有数据可读触发，
end：没有数据可读触发，
error：发生错误时触发，
finish：完成触发。

2、从流中读数据

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

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

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

// 处理流事件 --> data, end, and error
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("程序执行完毕");

3、写入流：

var fs = require("fs");
var data = '写入流数据';

// 创建一个可以写入的流，写入到文件 output.txt 中
var writerStream = fs.createWriteStream('output.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("程序执行完毕");

4、管道流（pipe）

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("程序执行完毕");

5、链式流

链式是通过连接输出流到另外一个流并创建多个流操作链的机制。链式流一般用于管道操作。

接下来我们就是用管道和链式来压缩和解压文件。

//压缩
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基础之多进程实例详解
这篇文章主要介绍了nodejs基础之多进程,结合实例形式分析了nodejs多进程的概念、原理、相关函数使用方法及操作注意事项,需要的朋友可以参考下
2018-12-12
测试驱动ChatGPT编程示例详解
这篇文章主要为大家介绍了测试驱动ChatGPT编程示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-03
Nodejs Sequelize手册学习快速入门到应用
这篇文章主要为大家介绍了Nodejs Sequelize手册学习快速入门到应用，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-10-10
Node.js中的模块系统介绍
这篇文章介绍了Node.js中的模块系统，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-04-04
Node.js进程管理之进程集群详解
这篇文章介绍了Node.js进程管理之进程集群，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-07-07
nodejs实现大文件（在线视频）的读取
这篇文章主要为大家详细介绍了nodejs实现大文件的读取，比如在线视频，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-12-12
Nodejs Docker镜像体积优化实践详解
这篇文章主要为大家介绍了Nodejs Docker镜像体积优化实践示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-07-07
nodejs更新package.json中的dependencies依赖到最新版本的方法
今天小编就为大家分享一篇nodejs更新package.json中的dependencies依赖到最新版本的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-10-10
Electron架构深入探究
这篇文章主要为大家介绍了Electron架构深入探究，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-02-02
node前端开发模板引擎Jade的入门
这篇文章主要介绍了node前端开发模板引擎Jade的入门,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-05-05

详解nodeJs文件系统（fs）与流（stream）

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具