12

我希望能够加载已更改的模块。我当然必须先卸载模块。由于这是一个网络服务器设置,我想问是否有办法以异步方式加载模块,以避免在读取更新文件期间冻结网络服务器。

不久前 Node.JS 删除了该require.async功能。那么,在最新版本的 Node.JS 上,推荐的替代方案是什么?

  • 我是否应该先阅读整个文件,然后使用Module库来解析文件内容。(与采用文件名在内部读取和解析的默认功能相反)如何?
  • 我应该将这项工作外包给一些开源库吗?哪一个?
  • 我应该编写自己的模块处理程序 - 我自己的实现requireAsync吗?(我知道该怎样。)

注意:除了异步加载模块,我不想做任何事情,所以请不要建议我用新的网络服务器路由框架替换我的设置。

4

1 回答 1

5

我发布了这个答案,但欢迎您发布改进。

请参阅Node.JS 源代码

Module.prototype.require = function(path) { return Module._load(path, this); };

的精简版_load

Module._load = function(request, parent, isMain) {
  var filename = Module._resolveFilename(request, parent);
  if (Module._cache[filename]) return Module._cache[filename].exports;
  if (NativeModule.exists(filename)) {
    if (filename == 'repl') { // special case, needs the real require.
      var replModule = new Module('repl');
      replModule._compile(NativeModule.getSource('repl'), 'repl.js');
      NativeModule._cache.repl = replModule;
      return replModule.exports;
    }
    return NativeModule.require(filename);
  }
  var module = new Module(filename, parent);
  if (isMain) process.mainModule = module, module.id = '.';
  Module._cache[filename] = module;
  var hadException = true;
  try {
    module.load(filename);
    hadException = false;
  } finally {
    if (hadException) delete Module._cache[filename];
  }
  return module.exports;
};

我的版本require.async.js将类似于

var NativeModule = require('native_module');
var fs = require('fs');
if(!require.async) require.async = function (path, callback) { module.exports(path, this, callback); } // Comment out if you dislike using globals
module.exports = function(request, parent, callback) {
  var filename = Module.resolve(request, parent); // This is a Sync function. TODO, change it to an async function with a callback.
  if (Module.cache[filename]) callback(Module.cache[filename].exports);
  else if (NativeModule.exists(filename)) callback(new Error('What are you thinking?'))
  else fs.readFile(filename, 'utf8', function(err, file) {
    if (Module.cache[filename]) callback(null, Module.cache[filename].exports); // For the case when there are two calls to require.async at a time.
    else if(err) callback(err)
    else {
      var module = new Module(filename, parent);
      try {
        module._compile(file);
        Module.cache[filename] = module;
      } catch(ex) {
        callback(err)
      }
      if(Module.cache[filename]) callback(null, module.exports)
    }
}

注意事项

  • 代码中有一个 TODO 用于将多个调用设为stat异步。文件的实际读取是常规异步,所以这很好。
  • 如果您正在异步加载一个模块,并且您正在加载的那个模块正在同步加载另一个模块,那么您还没有完全与您的代码异步 - 有吗。
  • 它使用一种私有方法 - _compile.
于 2012-12-19T23:07:36.413 回答