通过监控线程状态来保证socket服务器的稳定运行

//此服务用来监控云平台的socket服务进程，若进程崩溃或重启，则重新启动socket服务、ws服务、任务超时检测
var http=require(‘http‘);
var moment = require(‘moment‘)
//var host="http://xxx"; //本地调试
var host="http://xxxxxx"; //内网服务
//var host="http://xxxx";//公网服务
var statusCheck="xxx";
var startSocket= "xxx" ;
var startWs= "xxx"  ;
var taskTimeout=  "xxx";
var inteval;
function start() {
    inteval = setInterval(checkStatus, 20000);
}
function end() {
    clearInterval(inteval);
}
start();
function checkStatus() {
    try {
        http.get(host + statusCheck, function (res) {
            res.on(‘data‘, function (data) {
                var socketStatus = JSON.parse(data.toString());
                if (socketStatus.socketServer == ‘挂了‘ || socketStatus.socketServer == ‘Stopped‘) {
                    console.log(moment(new Date()).format(‘YYYY-MM-DD HH:mm:ss‘) + "   socket服务不可用,正在重启")
                    //重启服务
                    restartService();
                }
            })
        }).on(‘error‘, function (e) {
            console.log(moment(new Date()).format(‘YYYY-MM-DD HH:mm:ss‘) + "错误：" + e.message);
        });
    }
    catch (e) {
        console.log(e.message);
    }
}
function restartService() {
    //end();
    http.get(host + startSocket, function (res) {
        statusCode(res.statusCode, ‘startSocket‘);
        console.log(moment(new Date()).format(‘YYYY-MM-DD HH:mm:ss‘) + "   重启socketserver" + res.statusCode);
        res.resume();
    });
    http.get(host + startWs, function (res) {
        statusCode(res.statusCode, ‘startWs‘);
        console.log(moment(new Date()).format(‘YYYY-MM-DD HH:mm:ss‘) + "   重启wsserver" + res.statusCode);
        res.resume();
    });
    http.get(host + taskTimeout, function (res) {
        statusCode(res.statusCode, ‘taskTimeout‘);
        console.log(moment(new Date()).format(‘YYYY-MM-DD HH:mm:ss‘) + "   重启任务状态监控" + res.statusCode);
        res.resume();
    });
    var status = { startSocket: false, startWs: false, taskTimeout: false };
    function statusCode(code, name) {
        if (code == 200) {
            status[name] = true;
        }
        if (status.startSocket && status.startWs && status.taskTimeout) {
            //start();
        }
    }
}