Nodejs中cluster模塊的多進程共享數據問題

前述

　　nodejs在v0.6.x之后增加了一個模塊cluster用於實現多進程，利用child_process模塊來創建和管理進程，增加程序在多核CPU機器上的性能表現。本文將介紹利用cluster模塊創建的多線程如何共享數據的問題。

進程間數據共享

　　首先舉個簡單的例子，代碼如下：

var cluster = require('cluster'); 
var data = 0;//這里定義數據不會被所有進程共享，各個進程有各自的內存區域 
if (cluster.isMaster) { //主進程 
    var numCPUs = require('os').cpus().length; 
    for (var i = 0; i < numCPUs; i++) { 
        var worker = cluster.fork(); 
    }    
    data++; 
    console.log('DATA VALUE in MainProcess: %d ' , data);
} else { //子進程,會被調用numCPUs次 
    data++; 
    console.log('DATA VALUE in ChildProcess %d: %d ' cluster.worker.id, data);
}

　　運行結果如下：

　　為什么我們在主進程代碼塊以及子進程代碼塊之外來聲明的變量不應該是全局變量么？答案是否定的。因為每個進程在內存都有各自的區域，因此data++操作是在各自的區域內進行的，也就是說變量data沒被共享。那么怎么來在各進程之間共享數據呢？來看下面的代碼：

var cluster = require('cluster'); 
var http = require('http'); 
 
if (cluster.isMaster) { 
  var numCPUs = require('os').cpus().length; 
  var data = 0; 
  // 啟動多個進程. 
  for (var i = 0; i < numCPUs; i++) { 
   //增加一個進程 
    var worker_process = cluster.fork(); 
    //偵聽子進程的message事件 
    worker_process.on('message', function(msg) { 
      if (msg.cmd && msg.cmd == 'notifyRequest') { 
        data++; 
        console.log('DATA VALUE : %d ', data);
      } 
    }); 
  } 
} else { 
    process.send({ cmd: 'notifyRequest' }); 
} 

　　運行結果如下：

因此如果需要共享數據，需要在進程間使用消息通知來達到這個目的。