浅谈pm2基本工作原理

要谈Node.js pm2的工作原理,需要先来了解撒旦(Satan)和上帝(God)的关系。

撒旦(Satan),主要指《圣经》中的堕天使(也称堕天使撒旦),他是反叛上帝耶和华的堕天使(Fallen Angels),曾经是上帝座前的天使,后来他因骄傲自大妄想与神同等而堕落成为魔鬼,被看作与上帝的力量相对的邪恶、黑暗之源。

简单的说Satan是破坏神,就是进程的异常退出、kill等;God是守护神,保护进程、重启进程等。

一图胜千言,pm2的 RPC基本框架。Client与Daemon是采用了RPC进行通讯。

浅谈pm2基本工作原理

RPC(Remote Procedure Call Protocol)——远程过程调用协议,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信模型中,RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

1.Client启动关联Daemon

daemon.innerStart(function() {

    KMDaemon.launchAndInteract(that.conf, {

        machine_name : that.machine_name,

        public_key : that.public_key,

        secret_key : that.secret_key

    }, function(err, data, interactor_proc) {

        that.interactor_process = interactor_proc;

    });

    that.launchRPC(function(err, meta) {

        return cb(null, {

            daemon_mode : that.conf.daemon_mode,

            new_pm2_instance : false,

            rpc_socket_file : that.rpc_socket_file,

            pub_socket_file : that.pub_socket_file,

            pm2_home : that.pm2_home

        });

    });

});

child.once(‘message’, function(msg) {

    debug(‘PM2 daemon launched with return message: ‘, msg);

    child.removeListener(‘error’, onError);

    child.disconnect();

    if (opts && opts.interactor == false)

        return cb(null, child);

    /**

     * Here the Keymetrics agent is launched automaticcaly if

     * it has been already configured before (via pm2 link)

     */

    KMDaemon.launchAndInteract(that.conf, {

        machine_name : that.machine_name,

        public_key : that.public_key,

        secret_key : that.secret_key

    }, function(err, data, interactor_proc) {

        that.interactor_process = interactor_proc;

        return cb(null, child);

    });

});

2.Daemon有start,stop,close,kill进程的方法,与God的事件发射器(EventEmitter)关联

God.bus.on(‘axm:monitor’, function axmMonitor(msg) {

    if (!msg.process)

        return console.error(‘[axm:monitor] no process defined’);

    if (!msg.process || !God.clusters_db[msg.process.pm_id])

        return console.error(‘Unknown id %s’, msg.process.pm_id);

    util._extend(God.clusters_db[msg.process.pm_id].pm2_env.axm_monitor, Utility.clone(msg.data));

    msg = null;

});

3.Satan.js

3.1.Ping进程是否活着或者关闭

Satan.pingDaemon = function pingDaemon(cb) {

    var req = axon.socket(‘req’);

    var client = new rpc.Client(req);

    debug(‘[PING PM2] Trying to connect to server’);

    client.sock.once(‘reconnect attempt’, function() {

        client.sock.close();

        debug(‘Daemon not launched’);

        process.nextTick(function() {

            return cb(false);

        });

    });

    client.sock.once(‘connect’, function() {

        client.sock.once(‘close’, function() {

            return cb(true);

        });

        client.sock.close();

        debug(‘Daemon alive’);

    });

    req.connect(cst.DAEMON_RPC_PORT);

};

3.2.通知God

Satan.notifyGod = function(action_name, id, cb) {

    Satan.executeRemote(‘notifyByProcessId’, {

        id : id,

            action_name : action_name,

            manually : true

    }, function() {

        debug(‘God notified’);

        return cb ? cb() : false;

    });

};

4.God是事件监听

var God = module.exports = {

    next_id : 0,

    clusters_db : {},

    bus : new EventEmitter2({

        wildcard: true,

        delimiter: ‘:’,

        maxListeners: 1000
        
    })

};

5.God的监听进程方法有

God.ping

God.notifyKillPM2

God.duplicateProcessId

God.startProcessId

God.stopProcessId

God.resetMetaProcessId

God.deleteProcessId

God.restartProcessId

God.restartProcessName

God.sendSignalToProcessId

God.sendSignalToProcessName

God.stopWatch

God.toggleWatch

God.startWatch

God.reloadLogs

God.sendDataToProcessId

God.msgProcess

God.getVersion

6.God的进程运行模式用两种

6.1. Cluster集群模式

6.2. Fork模式

一般开发环境用fork模式,生产环境使用cluster模式

简单pm2进程管理描述,更多方法请阅读源码。

原文链接:https://www.jianshu.com/p/72d9de1e1680

发表评论

登录后才能评论