Pragmatic Programmer

Node.js를 멀티 코어에서 동작하도록 해주는 방법에 대해서 소개하도록 하겠습니다.

http://learnboost.github.com/cluster/ - Github Home

http://learnboost.github.com/cluster/docs/api.html - API Document

https://github.com/learnboost/cluster - Github Source

# npm install cluster

--------------------------------------------------------------------------------

server.js 파일

var http = require('http');

var server = http.createServer(function(req, res){
    res.writeHead(200);
    res.end('Hello World');
});

// 서버 시작
if (module === require.main)
    server.listen(4500);
else
    module.exports  = server;

console.log('listen on port 4500');

---------------------------------------------------------------------------------

cluster.js 파일

var cluster = require('cluster');
cluster('server')
    .use(cluster.repl('/var/run/cluster.sock'))
    .listen(4500);

node cluster.js – node.js 시작

listen on port 4500

listen on port 4500

listen on port 4500

listen on port 4500

listen on port 4500

listen on port 4500

listen on port 4500

listen on port 4500

# telnet /var/run/cluster.sock

cluster> help()

Commands

help(): Display help information

spawn(n): Spawn one or more additional workers

pids(): Output process ids

kill(id, signal): Send signal or SIGTERM to the given worker

shutdown(): Gracefully shutdown server

stop(): Hard shutdown

restart(): Gracefully restart all workers

echo(msg): echo the given message

stats(): Display server statistics

cluster> pids()

master: xxxxx

worker #0: xxxxx

worker #1: xxxxx

worker #2: xxxxx

worker #3: xxxxx

worker #4: xxxxx

worker #5: xxxxx

worker #6: xxxxx

worker #7: xxxxx

다른 예제

---------------------------------------------------------------------------------

app.js

var http = require('http');

module.exports = http.createServer(function(req, res){
  console.log('%s %s', req.method, req.url);
  var body = 'Hello World';
  res.writeHead(200, { 'Content-Length': body.length });
  res.end(body);
});

---------------------------------------------------------------------------------

server.js

var cluster = require('cluster')
  , app = require('./app');

cluster(app)
  .use(cluster.logger('logs'))
  .use(cluster.stats())
  .use(cluster.pidfiles('pids'))
  .use(cluster.cli())
  .use(cluster.repl(8888))
  .listen(3000);

---------------------------------------------------------------------------------

참고 URL : http://www.screenr.com/X8v Video