用Node.js遍历一个目录

我在node.js中有这个代码的问题。 我想recursion地遍历一个目录树,并将callbackaction到树中的每个文件。 这是我目前的代码:

 var fs = require("fs"); // General function var dive = function (dir, action) { // Assert that it's a function if (typeof action !== "function") action = function (error, file) { }; // Read the directory fs.readdir(dir, function (err, list) { // Return the error if something went wrong if (err) return action(err); // For every file in the list list.forEach(function (file) { // Full path of that file path = dir + "/" + file; // Get the file's stats fs.stat(path, function (err, stat) { console.log(stat); // If the file is a directory if (stat && stat.isDirectory()) // Dive into the directory dive(path, action); else // Call the action action(null, path); }); }); }); }; 

问题是在每个循环中 ,通过可变path为每个文件调用stat。 当callback被调用时, path已经有了另一个值,所以它会跳入错误的目录或调用错误文件的action

可能这个问题很容易通过使用fs.statSync来解决,但这不是我想要的解决scheme,因为它阻止了这个过程。

       

网上收集的解决方案 "用Node.js遍历一个目录"

var path = dir + "/" + file;

你忘了把path变成局部variables。 现在它不会在循环后面改变。

使用节点目录为此。 因为你需要对目录和文件进行单独的操作,所以我会给你2个简单的使用node-dir的迭代器。

asynchronous迭代目录及其子目录的文件,并将文件path数组传递给callback函数。

 var dir = require('node-dir'); dir.files(__dirname, function(err, files) { if (err) throw err; console.log(files); //we have an array of files now, so now we'll iterate that array files.forEach(function(filepath) { actionOnFile(null, filepath); }) }); 

asynchronous迭代目录及其子目录的子目录,并将目录path数组传递给callback。

 var dir = require('node-dir'); dir.subdirs(__dirname, function(err, subdirs) { if (err) throw err; console.log(subdirs); //we have an array of subdirs now, so now we'll iterate that array subdirs.forEach(function(filepath) { actionOnDir(null, filepath); }) }); 

不确定是否真的应该把这个作为答案,但为了方便和其他用户,这里是一个重写的OP版本,可能会certificate是有用的。 它提供:

  • 更好的错误pipe理支持
  • 探索完成时调用的全局完成callback

代码:

 /** * dir: path to the directory to explore * action(file, stat): called on each file or until an error occurs. file: path to the file. stat: stat of the file (retrived by fs.stat) * done(err): called one time when the process is complete. err is undifined is everything was ok. the error that stopped the process otherwise */ var walk = function(dir, action, done) { // this flag will indicate if an error occured (in this case we don't want to go on walking the tree) var dead = false; // this flag will store the number of pending async operations var pending = 0; var fail = function(err) { if(!dead) { dead = true; done(err); } }; var checkSuccess = function() { if(!dead && pending == 0) { done(); } }; var performAction = function(file, stat) { if(!dead) { try { action(file, stat); } catch(error) { fail(error); } } }; // this function will recursively explore one directory in the context defined by the variables above var dive = function(dir) { pending++; // async operation starting after this line fs.readdir(dir, function(err, list) { if(!dead) { // if we are already dead, we don't do anything if (err) { fail(err); // if an error occured, let's fail } else { // iterate over the files list.forEach(function(file) { if(!dead) { // if we are already dead, we don't do anything var path = dir + "/" + file; pending++; // async operation starting after this line fs.stat(path, function(err, stat) { if(!dead) { // if we are already dead, we don't do anything if (err) { fail(err); // if an error occured, let's fail } else { if (stat && stat.isDirectory()) { dive(path); // it's a directory, let's explore recursively } else { performAction(path, stat); // it's not a directory, just perform the action } pending--; checkSuccess(); // async operation complete } } }); } }); pending--; checkSuccess(); // async operation complete } } }); }; // start exploration dive(dir); }; 

另一个合适的库是filehound 。 它支持文件过滤(如果需要),callback和承诺。

例如:

 const Filehound = require('filehound'); function action(file) { console.log(`process ${file}`) } Filehound.create() .find((err, files) => { if (err) { return console.error(`error: ${err}`); } files.forEach(action); }); 

该图书馆是有据可查的,并提供了许多常见用例的例子。 https://github.com/nspragg/filehound

免责声明:我是作者。

不要重新发明轮子,而应该为开源贡献力量。 尝试以下方法之一:

 function loop( ) { var item = list.shift( ); if ( item ) { // content of the loop functionWithCallback( loop ); } else { // after the loop has ended whatever( ); } }