热代码推送的NodeJS(Hot Code Push NodeJS)

2019-08-03 03:44发布

我一直在试图找出对Node.js的这种“热代码推送” 基本上,我的主文件(当你键入运行node app.js )由一些设置,配置和初始化的。 在该文件中我有一个文件观察者,使用chokidar。 当我的文件已经加入,我只是require的文件。 如果一个文件已被更改或更新我会删除缓存delete require.cache[path] ,然后再需要它。 所有这些模块没有出口任何东西,它只是用单一的全局工作的Storm对象。

Storm.watch = function() {
    var chokidar, directories, self = this;
    chokidar = require('chokidar');
    directories = ['server/', 'app/server', 'app/server/config', 'public'];
    clientPath = new RegExp(_.regexpEscape(path.join('app', 'client')));
    watcher = chokidar.watch(directories, {
    ignored: function(_path) {
        if (_path.match(/\./)) {
            !_path.match(/\.(js|coffee|iced|styl)$/);
        } else {
            !_path.match(/(app|config|public)/);
        }
    },
    persistent: true
    });


    watcher.on('add', function(_path){
    self.fileCreated(path.resolve(Storm.root, _path));
    //Storm.logger.log(Storm.cliColor.green("File Added: ", _path));
    //_console.info("File Updated");
    console.log(Storm.css.compile('     {name}: {file}', "" +
        "name" +
        "{" +
        "color: white;" +
        "font-weight:bold;" +
        "}" +
        "hr {"  +
        "background: grey" +
        "}")({name: "File Added", file: _path.replace(Storm.root, ""), hr: "=================================================="}));
    });

    watcher.on('change', function(_path){
    _path = path.resolve(Storm.root, _path);
    if (fs.existsSync(_path)) {
        if (_path.match(/\.styl$/)) {
            self.clientFileUpdated(_path);
        } else {
            self.fileUpdated(_path);
        }
    } else {
        self.fileDeleted(_path);
    }
    //Storm.logger.log(Storm.cliColor.green("File Changed: ", _path));
    console.log(Storm.css.compile('     {name}: {file}', "" +
        "name" +
        "{" +
        "color: yellow;" +
        "font-weight:bold;" +
        "}" +
        "hr {"  +
        "background: grey" +
        "}")({name: "File Changed", file: _path.replace(Storm.root, ""), hr: "=================================================="}));
    });

    watcher.on('unlink', function(_path){
    self.fileDeleted(path.resolve(Storm.root, _path));
    //Storm.logger.log(Storm.cliColor.green("File Deleted: ", _path));
    console.log(Storm.css.compile('     {name}: {file}', "" +
        "name" +
        "{" +
        "color: red;" +
        "font-weight:bold;" +
        "}" +
        "hr {"  +
        "background: grey" +
        "}")({name: "File Deleted", file: _path.replace(Storm.root, ""), hr: "=================================================="}));
    });

    watcher.on('error', function(error){
    console.log(error);
    });


};


Storm.watch.prototype.fileCreated = function(_path) {

    if (_path.match('views')) {
    return;
    }

    try {
    require.resolve(_path);
    } catch (error) {
    require(_path);
    }

};


Storm.watch.prototype.fileDeleted = function(_path) {
    delete require.cache[require.resolve(_path)];
};

Storm.watch.prototype.fileUpdated = function(_path) {
    var self = this;
    pattern = function(string) {
    return new RegExp(_.regexpEscape(string));
    };

    if (_path.match(pattern(path.join('app', 'templates')))) {
    Storm.View.cache = {};
    } else if (_path.match(pattern(path.join('app', 'helpers')))) {
    self.reloadPath(path, function(){
        self.reloadPaths(path.join(Storm.root, 'app', 'controllers'));
    });
    } else if (_path.match(pattern(path.join('config', 'assets.coffee')))) {
    self.reloadPath(_path, function(error, config) {
        //Storm.config.assets = config || {};
    });
    } else if (_path.match(/app\/server\/(models|controllers)\/.+\.(?:coffee|js|iced)/)) {
    var isController, directory, klassName, klass;

    self.reloadPath(_path, function(error, config) {
        if (error) {
            throw new Error(error);
        }
    });

    Storm.serverRefresh();

    isController = RegExp.$1 == 'controllers';
    directory    = 'app/' + RegExp.$1;
    klassName = _path.split('/');
    klassName = klassName[klassName.length - 1];
    klassName = klassName.split('.');
    klassName.pop();
    klassName = klassName.join('.');
    klassName = _.camelize(klassName);

    if (!klass) {
        require(_path);
    } else {
        console.log(_path);
        self.reloadPath(_path)
    }

    } else if (_path.match(/config\/routes\.(?:coffee|js|iced)/)) {
    self.reloadPath(_path);
    } else {
    this.reloadPath(_path);
    }

};

Storm.watch.prototype.reloadPath = function(_path, cb) {

    _path = require.resolve(path.resolve(Storm.root, path.relative(Storm.root, _path)));
    delete require.cache[_path];
    delete require.cache[path.resolve(path.join(Storm.root, "server", "application", "server.js"))];
    //console.log(require.cache[path.resolve(path.join(Storm.root, "server", "application", "server.js"))]);
    require("./server.js");

    Storm.App.use(Storm.router);

    process.nextTick(function(){
    Storm.serverRefresh();
    var result = require(_path);
    if (cb) {
        cb(null, result);
    }
    });
};


Storm.watch.prototype.reloadPaths = function(directory, cb) {



};

有些代码是不完整的/不作为,我想了很多不同的方法。

什么是工作:

对于像下面的代码:

function run() {
   console.log(123);
}

完美的作品。 但是,任何异步代码无法更新。

问题=异步代码

app.get('/', function(req, res){
   // code here..
});

如果我那么过程的NodeJS运行时更新文件,什么都不会发生,但它会通过文件守望缓存被删除,然后重新建立。 另一个实例,其中它不工作是:

// middleware.js
function hello(req, res, next) {
  // code here...
}

// another file:
app.use(hello);

作为app.use将仍然使用旧版本的方法。

题:

我怎么能解决这个问题? 是否有什么我失踪?

请不要乱扔建议使用第三方模块像永远。 我试图在单个实例中包含的功能。

编辑:

研究流星代码库后(有在node.js中或浏览器“热代码推送”。令人惊讶的一点资源),并用我自己的实现修修补补左右我已经成功地做了一个可行的解决方案。 https://github.com/TheHydroImpulse/Refresh.js 。 这是尚处于发展的早期阶段,但它现在似乎固体。 我将实现一个浏览器解决方案也只是为了完成缘故。

Answer 1:

删除require的缓存实际上并没有‘卸载’你的旧代码,也没有撤消的代码做了什么。

举个例子如下功能:

var callbacks=[];
registerCallback = function(cb) {
    callbacks.push(cb);
};

现在让我们假设你有一个调用,全球功能的模块。

registerCallback(function() { console.log('foo'); });

您的应用程序启动后, callbacks将有一个项目。 现在,我们要修改的模块。

registerCallback(function() { console.log('bar'); });

你的“热补丁”代码运行,删除require.cache d版本并重新加载模块。

你必须知道的是,现在callbacks两个项目。 首先,它具有一参考(将其在应用程序启动时加),它记录FOO的功能向函数的引用,它记录栏(只添加)。

即使你删除缓存的参考模块的exports你不能真正删除模块。 至于JavaScript运行而言,你只是删除了一个参考了很多。 你的应用程序的任何其他部分仍然可以挂到旧模块在参考的东西。

这正是与你的HTTP应用中发生的。 当应用程序第一次启动时,你的模块连接匿名回调路线。 当您修改这些模块,它们附着一个新的回调到同一路线; 旧的回调不会被删除。 我猜你使用快递,和它加入他们的顺序调用路径处理程序。 因此,新的回调从来没有得到运行机会。


说实话,我不会用这种方法来对修改应用程序重新加载你。 大多数人写一个干净的环境的假设下,应用程序初始化代码; 您违反这种假设在一个肮脏的环境中运行初始化代码 - 也就是,一个是已经投入运行。

试图清理环境,让您的初始化代码运行几乎可以肯定是更多的麻烦比它的价值。 当你的基础文件已经改变了我只需重新启动整个应用程序。



Answer 2:

流星通过允许模块“注册”自己作为热代码推过程的一部分解决了这个问题。

他们实现这在他们的reload包装:

https://github.com/meteor/meteor/blob/master/packages/reload/reload.js#L105-L109

我已经看到了Meteor.reload在GitHub上的一些插件使用的API,但他们还用它在session包:

https://github.com/meteor/meteor/blob/master/packages/session/session.js#L103-L115

if (Meteor._reload) {
  Meteor._reload.onMigrate('session', function () {
    return [true, {keys: Session.keys}];
  });

  (function () {
    var migrationData = Meteor._reload.migrationData('session');
    if (migrationData && migrationData.keys) {
      Session.keys = migrationData.keys;
    }
  })();
}

所以基本上,当页面/窗口加载,流星运行“迁移”,这是最高的包中定义的数据/方法/等。 当热代码推送是由该得到重新计算。

它也正在被他们livedata包 (搜索reload )。

刷新之间他们节省了“状态”使用window.sessionStorage



文章来源: Hot Code Push NodeJS