-
-
Save telesma/c69e561004c2ec9343378141051a4880 to your computer and use it in GitHub Desktop.
Node.js clustered HTTP server example
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(function () { | |
'use strict'; | |
var cluster = require('cluster'), | |
http = require('http'), | |
os = require('os'), | |
/* | |
* ClusterServer object | |
* | |
* We start multi-threaded server instances by passing the server object | |
* to ClusterServer.start(server, port). | |
* | |
* Servers are automatically started with a number of threads equivalent | |
* to the number of CPUs reported by the os module. | |
*/ | |
ClusterServer = { | |
name: 'ClusterServer', | |
cpus: os.cpus().length, | |
autoRestart: true, // Restart threads on death? | |
start: function (server, port) { | |
var me = this, | |
i; | |
if (cluster.isMaster) { // fork worker threads | |
for (i = 0; i < me.cpus; i += 1) { | |
console.log(me.name + ': starting worker thread #' + i); | |
cluster.fork(); | |
} | |
cluster.on('death', function (worker) { | |
// Log deaths! | |
console.log(me.name + ': worker ' + worker.pid + ' died.'); | |
// If autoRestart is true, spin up another to replace it | |
if (me.autoRestart) { | |
console.log(me.name + ': Restarting worker thread...'); | |
cluster.fork(); | |
} | |
}); | |
} else { | |
// Worker threads run the server | |
server.listen(port); | |
} | |
} | |
}, | |
/* | |
* Simple example HelloWorld HTTP server | |
* | |
* Repsonds to any request with a plain txt "Hello World!" message. | |
* | |
* You can replace this with much more complex processing, naturally. | |
*/ | |
helloWorldServer = http.createServer(function (request, response) { | |
response.writeHead(200, { | |
'Content-type': 'text/plain' | |
}); | |
response.end('Hello World!'); | |
console.log('helloWorldServer: Served a hello!'); | |
}); | |
ClusterServer.name = 'helloWorldServer'; // rename ClusterServer instance | |
ClusterServer.start(helloWorldServer, 8081); // Start it up! | |
}()); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment