概述

node 的fs文檔密密麻麻的 api 非常多，畢竟全面支持對文件系統(tǒng)的操作。文檔組織的很好，操作基本分為文件操作、目錄操作、文件信息、流這個(gè)大方面，編程方式也支持同步、異步和 Promise。

本文記錄了幾個(gè)文檔中沒詳細(xì)描寫的問題，可以更好地串聯(lián)fs文檔思路：

• 文件描述符
• 同步、異步與 Promise
• 目錄與目錄項(xiàng)
• 文件信息
• stream

文件描述符

文件描述符是一個(gè)非負(fù)整數(shù)。它是一個(gè)索引值，操作系統(tǒng)可以根據(jù)它來找到對應(yīng)的文件。

在 fs 的很多底層 api 中，需要用到文件描述符。在文檔中，描述符通常用fd來代表。例如：fs.read(fd, buffer, offset, length, position, callback)。與這個(gè) api 相對應(yīng)的是：fs.readFile(path[, options], callback)。

因?yàn)椴僮飨到y(tǒng)對文件描述符的數(shù)量有限制，因此在結(jié)束文件操作后，別忘記 close:

const fs = require("fs");

fs.open("./db.json", "r", (err, fd) => {
    if (err) throw err;
    // 文件操作...
    // 完成操作后，關(guān)閉文件
    fs.close(fd, err => {
        if (err) throw err;
    });
});

同步、異步與 Promise

所有文件系統(tǒng)的 api 都有同步和異步兩種形式。

同步寫法

不推薦使用同步 api，會(huì)阻塞線程。

try {
    const buf = fs.readFileSync("./package.json");
    console.log(buf.toString("utf8"));
} catch (error) {
    console.log(error.message);
}

異步寫法

異步寫法寫起來容易進(jìn)入回調(diào)地獄。

fs.readFile("./package.json", (err, data) => {
    if (err) throw err;
    console.log(data.toString("utf8"));
});

(推薦)Promise 寫法

在 node v12 之前，需要自己借助 promise 封裝：

function readFilePromise(path, encoding = "utf8") {
    const promise = new Promise((resolve, reject) => {
        fs.readFile(path, (err, data) => {
            if (err) return reject(err);
            return resolve(data.toString(encoding));
        });
    });
    return promise;
}

readFilePromise("./package.json").then(res => console.log(res));

在 node v12 中，引入了 fs Promise api。它們返回 Promise 對象而不是使用回調(diào)。 API 可通過require('fs').promises訪問。如此一來，開發(fā)成本更低了。

const fsPromises = require("fs").promises;

fsPromises
    .readFile("./package.json", {
        encoding: "utf8",
        flag: "r"
    })
    .then(console.log)
    .catch(console.error);

目錄與目錄項(xiàng)

fs.Dir 類：封裝了和文件目錄相關(guān)的操作

fs.Dirent 類：封裝了目錄項(xiàng)的相關(guān)操作。例如判斷設(shè)備類型（字符、塊、FIFO 等）。

它們之間的關(guān)系，通過代碼展示：

const fsPromises = require("fs").promises;

async function main() {
    const dir = await fsPromises.opendir(".");
    let dirent = null;
    while ((dirent = await dir.read()) !== null) {
        console.log(dirent.name);
    }
}

main();

文件信息

fs.Stats 類：封裝了文件信息相關(guān)的操作。它在fs.stat()的回調(diào)函數(shù)中返回。

fs.stat("./package.json", (err, stats) => {
    if (err) throw err;
    console.log(stats);
});

注意，關(guān)于檢查文件是否存在：

• 不建議在調(diào)用 fs.open()、 fs.readFile() 或 fs.writeFile() 之前使用 fs.stat() 檢查文件是否存在。而是應(yīng)該直接打開、讀取或?qū)懭胛募绻募豢捎脛t處理引發(fā)的錯(cuò)誤。
• 要檢查文件是否存在但隨后并不對其進(jìn)行操作，則建議使用 fs.access()

ReadStream 與 WriteStream

在 nodejs 中，stream 是個(gè)非常重要的庫。很多庫的 api 都是基于 stream 來封裝的。例如下面要說的 fs 中的 ReadStream 和 WriteStream。

fs 本身提供了 readFile 和 writeFile，它們好用的代價(jià)就是性能有問題，會(huì)將內(nèi)容一次全部載入內(nèi)存。但是對于幾 GB 的大文件，顯然會(huì)有問題。

那么針對大文件的解決方案自然是：一點(diǎn)點(diǎn)讀出來。這就需要用到 stream 了。以 readStream 為例，代碼如下：

const rs = fs.createReadStream("./package.json");
let content = "";

rs.on("open", () => {
    console.log("start to read");
});

rs.on("data", chunk => {
    content += chunk.toString("utf8");
});

rs.on("close", () => {
    console.log("finish read, content is:\n", content);
});

借助 stream 的 pipe，一行快速封裝一個(gè)大文件的拷貝函數(shù)：

function copyBigFile(src, target) {
    fs.createReadStream(src).pipe(fs.createWriteStream(target));
}

以上就是如何在Nodejs中使用模塊fs文件系統(tǒng)的詳細(xì)內(nèi)容，更多關(guān)于Nodejs的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論