在节点中以特定顺序调用模块

Call to modules in specific order in node

我使用以下代码调用了两个模块,但调用操作在验证文件之前调用(我在调试中看到)。我应该如何验证 validateFileappHandler.invokeAction 之前被调用?我应该使用承诺吗?

var validator = require('../uti/valid').validateFile();
var appHandler = require('../contr/Handler');
appHandler.invokeAction(req, res);

更新

这是验证文件代码

var called = false;
var glob = require('glob'),
    fs = require('fs');
module.exports = {

    validateFile: function () {

        glob("myfolder/*.json", function (err, files) {
            var stack = [];
            files.forEach(function (file) {
                fs.readFile(file, 'utf8', function (err, data) { // Read each file
                    if (err) {
                        console.log("cannot read the file", err);
                    }
                    var obj = JSON.parse(data);
                    obj.action.forEach(function (crud) {
                        for (var k in crud) {
                            if (_inArray(crud[k].path, stack)) {

                                console.log("duplicate founded!" + crud[k].path);

                                break;
                            }
                            stack.push(crud[k].path);
                        }
                    })
                });
            });
        });
    }
};

因为fs.fileReadasync,你应该把你想在validateFile之后执行的代码放到它的callback.

来源可能是:

var validator = require('../uti/valid').validateFile();
var appHandler = require('../contr/Handler');
// create a new function that when execute, will call appHandler.invokeAction with req and res given to its arguments.
validator.validateFile(appHandler.invokeAction.bind(null, req, res));

验证器部分应该是:

var called = false;
var glob = require('glob'),
    fs = require('fs');
module.exports = {
    validateFile: function (callback) {

        glob("myfolder/*.json", function (err, files) {
            var stack = [];
            // Use it to decide whether all files processed or not.
            var filesToLoad = files.length;
            files.forEach(function (file) {
                fs.readFile(file, 'utf8', function (err, data) { // Read each file
                    --filesToLoad;
                    if (err) {
                        console.log("cannot read the file", err);
                        // If the invoke action doesn't depend on the result. You may want to call it here too.
                    }
                    var obj = JSON.parse(data);
                    obj.action.forEach(function (crud) {
                        for (var k in crud) {
                            if (_inArray(crud[k].path, stack)) {

                                console.log("duplicate founded!" + crud[k].path);

                                break;
                            }
                            stack.push(crud[k].path);
                        }
                    })

                    // Only called the callback after all files processed.
                    if (filesToLoad === 0) {
                      callback();
                    }

                });
            });
        });
    }
};

编辑:感谢Bergi的提醒,文件是一个数组,所有文件都处理完了要调用回调,所以我们还得用一个变量来决定还有多少文件还没有处理。

因为 globfs.readFile 是异步函数,并且 appHandler.invokeAction 在 i/o 期间从磁盘调用。

Promise 是解决此问题的好方法,但老派的回调可以完成这项工作。

validator.validateFile().then(function() {
  appHandler.invokeAction(req, res);
});

并用于验证

var Promise = require("bluebird"), // not required if you are using iojs or running node with `--harmony`
    glob = require('mz/glob'),
    fs = require('mz/fs');

module.exports = {
  validateFile: function () {
    return glob("myfolder/*.json").then(function(files) {
      return Promise.all(files.map(function(file) {
        // will return an array of promises, if any of them
        // is rejected, validateFile promise will be rejected
        return fs.readFile(file).then(function (content) {
          // throw new Error(''); if content is not valid
        });
      }));
    })
  }
};

如果你想使用 promise mz 可能会有所帮助:)