nodeJs文件系统(fs)与流(stream)

Posted supersmile

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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文件系统(fs)与流(stream)的主要内容,如果未能解决你的问题,请参考以下文章

nodejs模块之fs&&stream

深入Nodejs模块fs - 文件系统操作

nodejs fs读取静态json文件

nodejs fs 读取文件流一次读取多少数据

入门大数据---Spark_Streaming与流处理

写入文件 fs 流 NodeJS 时出错