詳解nodeJs文件系統(tǒng)（fs）與流（stream）

更新時(shí)間：2018年01月24日 09:58:24 作者：黃大渣渣

這篇文章主要介紹了詳解nodeJs文件系統(tǒng)（fs）與流（stream），小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧

一、簡(jiǎn)介

本文將介紹node.js文件系統(tǒng)（fs）和流（stream）的一些API已經(jīng)參數(shù)使用情況。

二、目錄

文件系統(tǒng)將介紹以下方法：

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對(duì)象的事件。

三、文件系統(tǒng)fs主要方法介紹

1、fs.readFile

readFile方法主要是讀取文件內(nèi)容，異步操作。

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以異步的方式寫(xiě)入文件，fs.writeFile(file, data[, options], callback)

var fs = require('fs')
console.log("準(zhǔn)備寫(xiě)入文件")
fs.writeFile('input.txt',"寫(xiě)入的內(nèi)容",function(err){
  if (err){
    return console.error(err);
  }else{
    console.log("寫(xiě)入成功");
  }
})

3、fs.open()

在異步方式下打開(kāi)文件，fs.open(path, flags[, mode], callback)

var fs = require("fs");
// 異步打開(kāi)文件
console.log("準(zhǔn)備打開(kāi)文件");
fs.open('a.txt', 'r+', function(err, fd) {//r+是以讀寫(xiě)模式打開(kāi)，fd為返回的文件描述符
  if (err) {
    return console.error(err);
  }
 console.log("文件打開(kāi)成功！");   
});

4、fs.read（）

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

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

console.log("準(zhǔn)備打開(kāi)文件！");
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);
   }
   // 僅輸出讀取的字節(jié)
   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類的實(shí)例有很多方法，比如stats.isFile()判斷是否是文件，stats.isDirectory()判斷是否是目錄，。。。。。。

6、fs.close()

fs.close()是以異步的方式關(guān)閉文件，語(yǔ)法格式：fs.close(fd, callback)，參數(shù)如下：

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

callback - 回調(diào)函數(shù)，沒(méi)有參數(shù)。

7、fs.mkdir()

此方法為創(chuàng)建目錄，格式：fs.mkdir(path[, mode], callback)，參數(shù)如下：

path：路徑。

mode:目錄權(quán)限，默認(rèn)0777.。

callback：回調(diào)，沒(méi)有參數(shù)。

var fs = require("fs");
console.log("創(chuàng)建目錄/test/");
fs.mkdir("/test/",function(err){
  if (err) {
    return console.error(err);
  }
  console.log("創(chuàng)建/test目錄成功。");
});

8、fs.rmdir()

刪除目錄，語(yǔ)法格式：fs.rmdir(path,callback)

9、fs.readdir()

此方法為讀取目錄，語(yǔ)法格式：fs.readdir(path, callback)，callback回調(diào)函數(shù)有兩個(gè)參數(shù)，第一個(gè)是err，第二個(gè)為目錄下的文件數(shù)組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("準(zhǔn)備刪除文件！");
fs.unlink('input.txt', function(err) {
  if (err) {
    return console.error(err);
  }
  console.log("文件刪除成功！");
});

四、stream流類型與事件介紹

1、 stream：流是一個(gè)抽象接口，有四種流類型：

readable ：可讀；
writable ：可寫(xiě)操作；
duplex ：可讀可寫(xiě)操作；
transform ：操作被寫(xiě)入數(shù)據(jù)，然后讀出結(jié)果。

所有的stream對(duì)象都是EventEmitter 的實(shí)例，常用事件有：

data：當(dāng)有數(shù)據(jù)可讀觸發(fā)，
end：沒(méi)有數(shù)據(jù)可讀觸發(fā)，
error：發(fā)生錯(cuò)誤時(shí)觸發(fā)，
finish：完成觸發(fā)。

2、從流中讀數(shù)據(jù)

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

// 創(chuàng)建可讀流
var readerStream = fs.createReadStream('input.txt');

// 設(shè)置編碼為 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("程序執(zhí)行完畢");

3、寫(xiě)入流：

var fs = require("fs");
var data = '寫(xiě)入流數(shù)據(jù)';

// 創(chuàng)建一個(gè)可以寫(xiě)入的流，寫(xiě)入到文件 output.txt 中
var writerStream = fs.createWriteStream('output.txt');

// 使用 utf8 編碼寫(xiě)入數(shù)據(jù)
writerStream.write(data,'UTF8');

// 標(biāo)記文件末尾
writerStream.end();

// 處理流事件 --> data, end, and error
writerStream.on('finish', function() {
  console.log("寫(xiě)入完成。");
});

writerStream.on('error', function(err){
  console.log(err.stack);
});

console.log("程序執(zhí)行完畢");

4、管道流（pipe）

var fs = require("fs");

// 創(chuàng)建一個(gè)可讀流
var readerStream = fs.createReadStream('input.txt');

// 創(chuàng)建一個(gè)可寫(xiě)流
var writerStream = fs.createWriteStream('output.txt');

// 管道讀寫(xiě)操作
// 讀取 input.txt 文件內(nèi)容，并將內(nèi)容寫(xiě)入到 output.txt 文件中
readerStream.pipe(writerStream);
console.log("程序執(zhí)行完畢");

5、鏈?zhǔn)搅?/p>

鏈?zhǔn)绞峭ㄟ^(guò)連接輸出流到另外一個(gè)流并創(chuàng)建多個(gè)流操作鏈的機(jī)制。鏈?zhǔn)搅饕话阌糜诠艿啦僮鳌?/p>

接下來(lái)我們就是用管道和鏈?zhǔn)絹?lái)壓縮和解壓文件。

//壓縮
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("文件解壓完成。");

五、總結(jié)

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: