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

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

首先舉個(gè)簡(jiǎn)單的例子，代碼如下：

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

運(yùn)行結(jié)果如下：　

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

var cluster = require('cluster'); 
var http = require('http'); 
 
if (cluster.isMaster) { 
 var numCPUs = require('os').cpus().length; 
 var data = 0; 
 // 啟動(dòng)多個(gè)進(jìn)程. 
 for (var i = 0; i < numCPUs; i++) { 
 //增加一個(gè)進(jìn)程 
 var worker_process = cluster.fork(); 
 //偵聽子進(jìn)程的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' }); 
}

運(yùn)行結(jié)果如下：