摘要:由于刪除目錄只能刪除空目錄如果有子文件或文件夾要先刪除目錄結(jié)構(gòu)算是典型的二叉樹模型所以涉及到遍歷樹結(jié)構(gòu)二叉樹遍歷分為深度和廣度以及先序中序后序之分以下以深度先序解決目錄刪除在中由于主線程為單線程可以采取串行方式和并行方式無論用什么方法刪除就
由于刪除目錄只能刪除空目錄(如果有子文件或文件夾要先刪除)
目錄結(jié)構(gòu)算是典型的二叉樹模型,所以涉及到遍歷樹結(jié)構(gòu)
二叉樹遍歷(分為深度和廣度,以及先序,中序,后序之分)
以下以深度先序解決目錄刪除
在node中由于主線程為單線程, 可以采取串行方式和并行方式
無論用什么方法刪除,就一點(diǎn)核心: 如果是文件直接刪除, 如果不是就刪除所有子文件或子目錄, 然后記得(一定記得刪除自己)
深度先序(串行) 深度先序(串行 回調(diào)方式)const fs = require("fs") const path = require("path") function rmdir(filePath, callback) { // 先判斷當(dāng)前filePath的類型(文件還是文件夾,如果是文件直接刪除, 如果是文件夾, 去取當(dāng)前文件夾下的內(nèi)容, 拿到每一個(gè)遞歸) fs.stat(filePath, function(err, stat) { if(err) return console.log(err) if(stat.isFile()) { fs.unlink(filePath, callback) }else { fs.readdir(filePath, function(err, data) { if(err) return console.log(err) let dirs = data.map(dir => path.join(filePath, dir)) let index = 0 !(function next() { // 此處遞歸刪除掉所有子文件 后刪除當(dāng)前 文件夾 if(index === dirs.length) { fs.rmdir(filePath, callback) }else { rmdir(dirs[index++],next) } })() }) } }) } rmdir("a", function() { console.log("刪除成功") })深度先序 (串行 promise寫法)
const fs = require("fs") const path = require("path") function rmdirPromise(filePath) { return new Promise((resolve, reject) => { fs.stat(filePath, function(err, stat) { if(err) reject(err) if(stat.isFile()) { fs.unlink(filePath, function(err) { if(err) reject(err) resolve() }) }else { fs.readdir(filePath, function(err, dirs) { if(err) reject(err) dirs = dirs.map(dir => path.join(filePath, dir)) // a/b a/c let index = 0; (function next() { if(index === dirs.length) { fs.rmdir(filePath, function(err) { if(err) reject(err) resolve() }) }else { rmdirPromise(dirs[index++]).then(() => { next() }, err => { reject(err) }) } })() }) } }) }) } rmdirPromise("a").then(() => { console.log("刪除成功") })深度先序 (串行 async await寫法)
// 在node v10.0.0+版本中fs模塊提供 promise 寫法 const fs = require("fs").promises // 如果在node 10之前的版本中可以引入第三方模塊 mz const fs = require("mz/fs") 用法一致 https://www.npmjs.com/package/mz const fs = require("fs").promises const path = require("path") async function rmdirAsync(filePath) { let stat = await fs.stat(filePath) if (stat.isFile()) { await fs.unlink(filePath) } else { let dirs = await fs.readdir(filePath) dirs = dirs.map(dir => path.join(filePath, dir)) let index = 0; (async function next() { if (index === dirs.length) { await fs.rmdir(filePath) } else { await rmdirAsync(dirs[index++]) await next() } })() } } rmdirAsync("a").then(() => { console.log("刪除成功") }, (err) => { console.log("err", err) })深度先序 (并行) 深度先序 (并行 回調(diào)寫法)
const fs = require("fs").promises const path = require("path") function rmdir(filePath, callback) { fs.stat(filePath, function(err,stat) { if(err) return console.log(err) if(stat.isFile()) { fs.unlink(filePath, callback) }else { fs.readdir(filePath, function(err, dirs) { if(err) return console.log(err) // 此處要添加dirs.length的驗(yàn)證,不然如果length為0 后面的forEach不執(zhí)行, 就刪不掉當(dāng)前目錄了, 也執(zhí)行不了callback if(dirs.length === 0) { fs.rmdir(filePath, callback) } dirs = dirs.map(dir => path.join(filePath, dir)) // 通過計(jì)數(shù)的方式來判斷是否子目錄都刪除了 let index = 0 function done() { if(++index === dirs.length) { fs.rmdir(filePath, callback) } } // 何為并行? a下有兩個(gè)目錄b, c,那么同時(shí)將b, c的刪除都推到event Loop中,用for循環(huán)實(shí)現(xiàn) dirs.forEach(dir => { // 通過done回調(diào)的方式來控制js執(zhí)行流程(LazyMan問題也是這么解決的) rmdir(dir, done) }); }) } }) } rmdir("a", function() { console.log("刪除成功") })深度先行 (并行promise寫法)
const fs = reqire("fs") const path = require("path") function rmdirPromise(filePath) { return new Promise((resolve, reject) => { fs.stat(filePath, function (err, stat) { if (err) reject(err) if (stat.isFile()) { fs.unlink(filePath, function (err) { if (err) reject(err) resolve() }) } else { fs.readdir(filePath, function (err, dirs) { if (err) reject(err) dirs = dirs.map(dir => path.join(filePath, dir)) dirs = dirs.map(dir => rmdirPromise(dir)) Promise.all(dirs).then(() => { fs.rmdir(filePath, resolve) }) }) } }) }) } rmdirPromise("a").then(() => { console.log("刪除成功") })深度先序 (并行 async + await寫法)
const fs = require("fs").promises const path = require("path") async function rmdirAsync(filePath) { let stat = await fs.stat(filePath) if(stat.isFile()) { await fs.unlink(filePath) }else { let dirs = await fs.readdir(filePath) dirs = dirs.map(dir => rmdirAsync(path.join(filePath, dir))) await Promise.all(dirs) await fs.rmdir(filePath) } } rmdirAsync("a").then(() => { console.log("刪除成功") })
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/104938.html
摘要:重新分片,把要?jiǎng)h除的主節(jié)點(diǎn)的數(shù)據(jù)槽移動(dòng)到其他主節(jié)點(diǎn)上,以免數(shù)據(jù)丟失。分區(qū)完成當(dāng)前主節(jié)點(diǎn)已經(jīng)沒有數(shù)據(jù)槽了。這樣就可以實(shí)現(xiàn)橫向動(dòng)態(tài)擴(kuò)容,新增加的主從節(jié)點(diǎn),用于存儲(chǔ)新的數(shù)據(jù)則可,對以前的節(jié)點(diǎn)的數(shù)據(jù)不會(huì)有任何影響。 需求: A redis cluster 集群 40 臺(tái)集群擴(kuò)容到 68 臺(tái)也就是 增加 28 臺(tái)新的機(jī)器 : 一主一從 為一組,一共12組 前期準(zhǔn)備 掃描新增擴(kuò)容服務(wù)器ip是...
閱讀 1720·2021-09-22 10:02
閱讀 1942·2021-09-02 15:40
閱讀 2845·2019-08-30 15:55
閱讀 2255·2019-08-30 15:44
閱讀 3602·2019-08-30 13:18
閱讀 3232·2019-08-30 11:00
閱讀 1956·2019-08-29 16:57
閱讀 571·2019-08-29 16:41