2017-12-18 216 views
1

我有类似的代码的NodeJS:如果NodeJS API服务失败,如何重新启动?

cluster.js

'use strict'; 

const cluster = require('cluster'); 
var express = require('express'); 
const metricsServer = express(); 
const AggregatorRegistry = require('prom-client').AggregatorRegistry; 
const aggregatorRegistry = new AggregatorRegistry(); 
var os = require('os'); 

if (cluster.isMaster) { 
    for (let i = 0; i < os.cpus().length; i++) { 
     cluster.fork(); 
    } 

    metricsServer.get('/metrics', (req, res) => { 
     aggregatorRegistry.clusterMetrics((err, metrics) => { 
      if (err) console.log(err); 
      res.set('Content-Type', aggregatorRegistry.contentType); 
      res.send(metrics); 
     }); 
    }); 

    metricsServer.listen(3013); 
    console.log(
     'Cluster metrics server listening to 3013, metrics exposed on /metrics' 
    ); 
} else { 
    require('./app.js'); // Here it'll handle all of our API service and it'll run under port 3000 
} 

正如你可以在上面的代码中看到我使用的是手动的NodeJS聚类方法,而不是PM2集群,因为我需要通过Prometheus监控我的API。我通常通过pm2 start cluster.js启动cluster.js,但由于某些数据库连接,我们的app.js服务失败,但是cluster.js没有。它显然看起来像我没有处理数据库连接错误,即使我没有处理它。我想知道,

  • 我该如何确保我的app.js和cluster.js总是重新启动,如果它崩溃?

  • 是否有Linux crontab可以放置检查某些端口始终运行(即3000和3013)? (如果这是一个好主意,我很感激,如果你能提供给我的代码,我没有太多熟悉Linux)

  • 或者,我可以部署其他的NodeJS API检查某些服务正在运行,但因为我的API实时并捕获一定量的负载;做这件事我不高兴吗?

任何帮助将不胜感激,提前致谢。

回答

0

我最近发现,如果它死了/关闭,我们可以听工人事件,并相应地重新启动它。

下面是代码:

'use strict'; 

const cluster = require('cluster'); 
var express = require('express'); 
const metricsServer = express(); 
var os = require('os'); 

if (cluster.isMaster) { 
for (let i = 0; i < os.cpus().length; i++) { 
    cluster.fork(); 
} 

cluster.on(
     "exit", 
     function handleExit(worker, code, signal) { 

      console.log( "Worker has died.", worker.process.pid); 
      console.log( "Death was suicide:", worker.exitedAfterDisconnect); 

      // If a Worker was terminated accidentally (such as by an uncaught 
      // exception), then we can try to restart it. 
      if (! worker.exitedAfterDisconnect) { 

       var worker = cluster.fork(); 
       // CAUTION: If the Worker dies immediately, perhaps due to a bug in the 
       // code, you can run [from what I have READ] into rapid CPU consumption 
       // as Master continually tries to create new Workers. 

      } 

     } 
    ); 

} else { 
require('./app.js'); 
}