当线程被创建之后，他们彼此之间是没有共享内存或者数据的。所有的数据交换只能通过worker.send和worker.on('message',handler)在主线程里处理，下面列举一个广播系统的实例。
var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;
if (cluster.isMaster) {
var workers=[];
//新建worker
function newWorker(){
var worker=cluster.fork();
//监听信息，如果type为broadcast的话，则确定为广播
worker.on('message', function(msg) {
if(msg.type=='broadcast'){
var event=msg.event;
//向所有worker发送此条广播
workers.forEach(function(worker){
worker.send(event);
})
}
});
return worker;
}
for (var i = 0; i < numCPUs; i++) {
workers.push(newWorker());
}
cluster.on('online',function(worker){
console.log('worker %d is online',worker.id);
})
} else {
var worker=cluster.worker;
//广播就是发送一个type为broadcast的信息，event就是广播内容
worker.broadcast=function(event){
worker.send({
type:'broadcast',
event:event
});
}
//这里用worker.on貌似不能监听到返回的信息
process.on('message',function(event){
console.log('worker: '+worker.id+' recived event from '+event.workerId);
})
//发送广播
worker.broadcast({
message:'online',
workerId:worker.id
})
}
需要注意的问题
在上面也提到，线程之间是不能共享数据的，所有的数据交换只能通过线程之间的通信来交换。而且所交换的数据都是可序列化的，所以函数，文件描述符和HttpResponse之类的东西都不能传递。
如果使用cluster，则需要在程序设计的时候考虑到数据交换的问题，我自己的做法就是将类似session的这些数据都存放在redis里，每个线程都做好存取的工作，所有的数据都不放在node内存里。
最后一点，cluster目前还被Node官方标记为Experimental状态，api在将来也许会改变。
网友评论