Nodejs cluster process 값 공유 하기

Sample Code.

Express와 같이 사용 하였다.

var express = require('express')
  , routes = require('./routes')
  , user = require('./routes/user')
  , http = require('http')
  , path = require('path');

var app = express();

var cluster = require('cluster')
  , numCPUs = require('os').cpus().length;

function setting() {
  app.configure(function(){
    app.set('port', process.env.PORT || 3000);
    app.set('views', __dirname + '/views');
    app.set('view engine', 'ejs');
    app.use(express.favicon());
    app.use(express.logger('dev'));
    app.use(express.bodyParser());
    app.use(express.methodOverride());
    app.use(express.cookieParser('your secret here'));
    app.use(express.session());
    app.use(app.router);
    app.use(express.static(path.join(__dirname, 'public')));
  });

  app.configure('development', function(){
    app.use(express.errorHandler());
  });

  app.get('/', routes.index);
  app.get('/users', user.list);

  http.createServer(app).listen(app.get('port'), function(){
    console.log("Express server listening on port " + app.get('port'));
  });
}

function eachWorker(callback) {
  for (var id in cluster.workers) {
    callback(cluster.workers[id]);
  }
}

// master
if (cluster.isMaster) {
  for (var i=0; i<numCPUs; i++) {
    var worker = cluster.fork();

    worker.on('message', function(message) {
      if (message.cmd == 'broadcast') {
        console.log('send worker');

        setInterval(function() {
          eachWorker(function(_worker) {
            _worker.send({ cmd: 'broadcast', message: 'test message' });
          })
        }, 1000);
      }
    });
  }

  cluster.on('exit', function(worker, code, signal) {
    log.info('worker ' + worker.process.pid + ' died');
  });

// worker
} else {
  if (cluster.isWorker) {
    console.log(' I am worker ' + cluster.worker.id);

    process.on('message', function(message) {
      if (message.cmd == 'broadcast') {
        console.log('receive message: ' + message.message);
      }
    });

    process.send({ cmd: 'broadcast' });
  }
}

1.1  Master (Parent)

부모 프로세스 로 볼 수 있으며 자식 프로세스를 생성 한다. 위 코드를 참고 시 'broadcast' 라는 명령어로 event 감지 하여 데이터를 주고 받는다.

1.2  Worker (Child)

부모 프로세스 가 fork() 할 경우 생성 된다. 해당 프로세스는 생성 되는 시점에서 'message' 라고 명령어를 보낸다.

1.3  Test 

sample를 실행해 보자.

whitelife@whitelife:~/work/cluster_test$ node app.js 

 I am worker #1

send worker.....

 I am worker #2

send worker.....

receive message: test message

receive message: test message

※ 참고 사이트

  - node api: http://www.nodejs.org/api/cluster.html