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

進程間數(shù)據(jù)共享

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

var cluster = require('cluster'); 
var data = 0;//這里定義數(shù)據(jù)不會被所有進程共享，各個進程有各自的內(nèi)存區(qū)域 
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 { //子進程,會被調(diào)用numCPUs次 
 data++; 
 console.log('DATA VALUE in ChildProcess %d: %d ' cluster.worker.id, data);
}

運行結(jié)果如下：　

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

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' }); 
}

運行結(jié)果如下：