/
server.js
75 lines (62 loc) · 1.42 KB
/
server.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
'use strict';
/**
* Libraries
**/
var cluster = require('cluster');
var datefmt = require('dateformat');
var os = require('os');
/**
* Setup
**/
var env = process.env.NODE_ENV;
var cores = os.cpus().length;
if (env === 'production') {
cores = cores === 1 ? cores : cores - 1;
} else {
cores = cores > 1 ? cores / 2 : cores;
}
var workers = parseInt(process.env.CLUSTER_WORKERS || cores, 10);
cluster.setupMaster({ exec: 'app.js' });
/**
* Utilities
**/
var restartCount = 0;
function say(message) {
console.log('[SERVER] ' + message);
}
function checkRestart() {
if (restartCount >= 8) {
say('FATAL: Too many restarts in too short a time.');
process.exit(1);
}
restartCount = 0;
}
setInterval(checkRestart, 2000);
/**
* Startup Messaging
**/
say('Master starting:');
say('time => ' + datefmt(new Date(), 'ddd, dd mmm yyyy hh:MM:ss Z'));
say('pid => ' + process.pid);
say('environment => ' + env);
/**
* Fork Workers
**/
say('Workers starting:');
for (var i = 0; i < workers; i += 1) {
cluster.fork();
}
/**
* Worker Event Handlers
**/
cluster.on('exit', function (worker) {
say('worker => with pid: ' +
worker.process.pid +
', died. Restarting...');
restartCount++;
cluster.fork();
});
cluster.on('online', function (worker) {
say('worker => start with pid: ' + worker.process.pid + '.');
});
// vim: ft=javascript sw=4 sts=4 et: