Node实现多线程服务器(2)线程之间的通信

     当线程被创建之后,他们彼此之间是没有共享内存或者数据的。所有的数据交换只能通过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在将来也许会改变。

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容