這篇文章主要介紹了詳解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:流是一個抽象接口,有四種流類型:
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中有關檔案系統與流的詳細內容。更多資訊請關注PHP中文網其他相關文章!