天天學點node系列-fs文件系統（續）

時間 2019-12-14

標籤天天 node 系列文件系統简体版

原文原文鏈接

理想若是不向現實作一點點屈服，那麼理想也將歸於塵土。css

建立目錄

異步建立目錄

path<string> | <Buffer> | <URL>
options <Object> | <integer>
  - recursive <boolean> 默認值: false。
  - mode <integer> Windows 上不支持。默認值: 0o777。
callback <Function>
  - err <Error></Error>

// fs.mkdir(path[, mode], callback)
var fs = require('fs')
fs.mkdir('sub', function(err){
    if(err) throw err
    console.log('建立目錄成功')
})

執行結果：html

$ node 1.js
建立目錄成功

同步建立目錄

path<string> | <Buffer> | <URL>
  - options <Object> | <integer>
  - recursive <boolean> 默認值: false。
mode <integer> Windows 上不支持。默認值: 0o777。

// fs.mkdirSync(path[, mode])
var fs = require('fs')
try{
    fs.mkdirSync('rock')
    console.log('建立目錄成功')
}catch(e){
    throw e
}

執行結果：node

$ node 1.js
建立目錄成功

讀取目錄

異步讀取目錄

path<string> | <Buffer> | <URL>
options <string> | <Object>
  - encoding <string> 默認值: 'utf8'。
  - withFileTypes <boolean> 默認值: false。
callback <Function>
  - err <Error>
  - files <string[]> | <Buffer[]> | <fs.Dirent[]></Error>

注意： files 是目錄中的文件名的數組（不包括 '.' 和 '..'）數據庫

let fs = require('fs')
fs.readdir('./sub', 'utf8', (err, files) => {
    if (err) console.log(err)
    console.log(files)
})

執行結果：json

$ node 1.js
[ '1.css', 'index.html' ]

同步讀取目錄

path <string> | <Buffer> | <URL>
options <string> | <Object>
  - encoding <string> 默認值: 'utf8'。設置爲 'buffer'，則返回的文件名是 Buffer 對象。
  - withFileTypes <boolean> 默認值: false。 設置爲 true，則返回的結果將包含 fs.Dirent 對象。
返回: <string[]> | <Buffer[]> | <fs.Dirent[]></boolean>

let fs = require('fs')
try {
    let result = fs.readdirSync('./sub', 'utf8')
    console.log(result)
} catch (error) {
    console.log(error)
}

執行結果：api

$ node 1.js
[ '1.css', 'index.html' ]

遍歷目錄

var fs = require('fs')
var path = require('path')
var getFilesInDir = function (dir) {
    var results = [path.resolve(dir)]
    var files = fs.readdirSync(dir, 'utf8')
    files.forEach(function (file) {
        file = path.resolve(dir, file)
        var stats = fs.statSync(file)
        if (stats.isFile()) {
            results.push(file)
        } else if (stats.isDirectory()) {
            results = results.concat(getFilesInDir(file))
        }
    })
    return results
}
var files = getFilesInDir('./api');
console.log(files);

注意：fs.readdirSync()只會讀一層，因此須要判斷文件類型是否目錄，若是是，則進行遞歸遍歷。數組

執行結果：異步

$ node 1.js
[ 'C:\\Users\\Administrator\\Desktop\\api',
  'C:\\Users\\Administrator\\Desktop\\api\\config.1.json',
  'C:\\Users\\Administrator\\Desktop\\api\\config.json',
  'C:\\Users\\Administrator\\Desktop\\api\\config16.json',
  'C:\\Users\\Administrator\\Desktop\\api\\integral-consumpte'
...

修改權限

path <string> | <Buffer> | <URL>
mode <integer>
callback <Function>
  - err <Error>

var fs = require('fs')
fs.chmod('1.txt', '777', function (err) {
    if (err) {
        console.log(err)
    } else {
        console.log("change done")
    }
})

同步修改全部者

path <string> | <Buffer> | <URL>
mode <integer>

var fs = require('fs')
fs.chmodSync('./1.txt', '777')

訪問/權限檢測

path<string> | <Buffer> | <URL>
    mode <integer> 默認值: fs.constants.F_OK。
    callback <Function>
  - err <Error></Error>

const fs = require('fs')
const file = '1.txt';
// 檢查當前目錄中是否存在該文件。
fs.access(file, fs.constants.F_OK, (err) => {
    console.log(`${file} ${err ? '不存在' : '存在'}`);
});
// 檢查文件是否可讀。
fs.access(file, fs.constants.R_OK, (err) => {
    console.log(`${file} ${err ? '不可讀' : '可讀'}`);
});
// 檢查文件是否可寫。
fs.access(file, fs.constants.W_OK, (err) => {
    console.log(`${file} ${err ? '不可寫' : '可寫'}`);
});
// 檢查當前目錄中是否存在該文件，以及該文件是否可寫。
fs.access(file, fs.constants.F_OK | fs.constants.W_OK, (err) => {
if (err) {
    console.error(
        `${file} ${err.code === 'ENOENT' ? '不存在' : '只可讀'}`);
    } else {
        console.log(`${file} 存在，且它是可寫的`);
    }
});

執行結果：ui

$ node 1.js
1.txt 存在
1.txt 可讀
1.txt 可寫
1.txt 存在，且它是可寫的

不建議在調用 fs.open()、 fs.readFile() 或 fs.writeFile() 以前使用 fs.access() 檢查文件的可訪問性。這樣作會引入競態條件，由於其餘進程可能會在兩個調用之間更改文件的狀態。相反，應該直接打開、讀取或寫入文件，若是文件沒法訪問則處理引起的錯誤。this

寫入（不推薦）

const fs = require('fs')
const file = '1.txt'
fs.access(file, (err) => {
    if (!err) {
        console.error(`${file} 已存在`)
        return
    }
    fs.open(file, 'wx', (err, fd) => {
        if (err) throw err
        writeMyData(fd)
    })
})

寫入（推薦）

const fs = require('fs')
fs.open('1.txt', 'wx', (err, fd) => {
    if (err) {
        if (err.code === 'EEXIST') {
            console.error('1.txt 已存在')
            return
        }
        throw err
    }
    writeMyData(fd)
})

同步訪問/權限檢測

path<string> | <Buffer> | <URL>
mode <integer> 默認值: fs.constants.F_OK。

注意：若是可訪問性檢查失敗，則拋出 Error。不然，該方法將返回 undefined。

try {
    fs.accessSync('./1.txt', fs.constants.R_OK | fs.constants.W_OK)
    console.log('能夠讀寫')
} catch (err) {
    console.error('無權訪問')
}

刪除目錄

異步刪除目錄

path<string> | <Buffer> | <URL>
callback <Function>
  - err <Error>

注意：在文件（而不是目錄）上使用 fs.rmdir() 會致使在 Windows 上出現 ENOENT 錯誤、在 POSIX 上出現 ENOTDIR 錯誤。

var fs = require('fs')

fs.rmdir('./rock', function(err){
    if(err) throw err
    console.log('目錄刪除成功')
})

同步刪除目錄

path <string> | <Buffer> | <URL>

var fs = require('fs')
fs.rmdirSync('./rock')

實用場景

文件鎖

使用獨佔標記建立鎖文件

fs模塊爲全部須要打開文件的方法提供了一個x標記。這告訴操做系統這個文件應該以獨佔模式打開（O_EXCL）。當使用這個方法時，若這個文件存在，文件不能被打開。

文件數據庫

策略是不斷的追加記錄，在處理的時候不斷的覆蓋原始記錄。

var fs = require('fs')
var EventEmitter = require('events').EventEmitter
var Database = function (path) {
    this.path = path
    // 數據庫key/value映射表
    this._records = Object.create(null)
    this._writeStream = fs.createWriteStream(this.path, {
        encoding: 'utf8',
        flags: 'a'
    })
    this._load()
}
// 繼承自EventEmitter，讓它有能夠監聽事件、傳遞事件的功能
Database.prototype = Object.create(EventEmitter.prototype)
Database.prototype._load = function () {
    var stream = fs.createReadStream(this.path, { encoding: 'utf8' })
    var database = this
    var data = ''
    // 當輸入流準備好時觸發
    stream.on('readable', function () {
        data += stream.read()
        // 每一行是一組數據
        var records = data.split('\n')
        data = records.pop()
        for (var i = 0; i < records.length; i++) {
            try {
                var record = JSON.parse(records[i])
                if (record.value == null) {
                    delete database._records[record.key]
                } else {
                    database._records[record.key] = record.value
                }
            } catch (e) {
                database.emit('error', 'found invalid record:', records[i])
            }
        }
    })
    // 流處理完後發送load事件給消費者
    stream.on('end', function () {
        database.emit('load')
    })
}
let database = new Database('./sub/a.txt')
database._writeStream.write('beep')

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。