node.js - Node 中的异步递归 Readdir

Question

我正在尝试使用我编写的递归函数扫描一个大目录的文件和子目录。它与this answer中给出的并行循环非常相似。 。

var fs = require('fs');
var walk = function(dir, done) {
  var results = [];
  fs.readdir(dir, function(err, list) {
    if (err) return done(err);
    var pending = list.length;
    if (!pending) return done(null, results);
    list.forEach(function(file) {
      file = dir + '/' + file;
      fs.stat(file, function(err, stat) {
        if (stat && stat.isDirectory()) {
          walk(file, function(err, res) {
            results = results.concat(res);
            if (!--pending) done(null, results);
          });
        } else {
          results.push(file);
          if (!--pending) done(null, results);
        }
      });
    });
  });
};

这个问题是它并不是真正的异步。整个过程处理并返回一个巨大的文件数组。有没有办法异步递归扫描目录？

更像是:

walk(path,function(files) {
  // do stuff with each file as its found
});

编辑:一旦我开始获取文件，我计划访问它们并使用async模块来处理它们并防止耗尽文件描述符。所以像这样:

walk(path,function(files) {
    async.each(files,function() {
        // do more stuff
    }
});

异步扫描可以正常工作吗？

Answer 1

是HeadCode 已经在上面的评论中解释了。您可以使用 eventEmitter 来做这种异步递归的事情。对于您的代码，您可以将 walk 函数作为事件回调。

var EventEmitter = require("events").EventEmitter;

var ee = new EventEmitter();
ee.on("walk", YourWalkFunction);

ee.emit("walk",YourParams);