星空网 > 软件开发 > Java

NodeJs多进程和socket.io通讯

一、开启多进程

const os = require('os');const cp = require('child_process');const forkList = {};const forkPrefix = 'fork_';let cpusLen = os.cpus().length;let port = 9562;for (var i = 1; i <= cpusLen; i++) {  forkList[forkPrefix + i] = cp.fork(`${__dirname}/a.js`, [port]);  var childPid = forkList[forkPrefix + i].pid;  console.log("子进程Fork成功.Pid:" + childPid);  port++;}// 监听子进程分发消息var pid = process.pid;for (var key in forkList) {  var forkObj = forkList[key];  var childPid = forkObj.pid;  forkObj.on('message', (m) => {    console.log('主进程ID:' + pid + ',子进程ID:' + childPid + ',message:', m);    send(m);  });}// 轮询所有子进程消息发送function send(m) {  for (var key in forkList) {    forkList[key].send(m);  }}

 

二、启动websocket服务-------(a.js)

var pid = process.pid;console.log('starting socket.io server......', pid);var argvs = process.argv.slice(2);if (argvs.length <= 0) {  console.log("fork child params bad...");  return false;}var port = argvs[0];var server = require('http').createServer();var io = require('socket.io')(server);io.on('connection', function (socket) {  socket.on('router', function (data) {    console.log(data);    // 把消息发送给主进程,由主进程分发给所有子进程    process.send(data);  });  socket.on('disconnect', function () {  });});server.listen(port);// 监听由主进程分发消息process.on('message', (m) => {  console.log('pid:' + pid + ',message:', m);  io.sockets.emit('router', m);});

 

三、DEMO演示截图

1、服务端启动程序

NodeJs多进程和socket.io通讯

 2、客户端1

NodeJs多进程和socket.io通讯

 

3、客户端2

NodeJs多进程和socket.io通讯

4、客户端3

NodeJs多进程和socket.io通讯

5、客户端4

NodeJs多进程和socket.io通讯

 




原标题:NodeJs多进程和socket.io通讯

关键词:JS

JS
*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。

西班牙权威机构发布报告:62%西班牙消费者购物首选AliExpress等平台:https://www.ikjzd.com/articles/1679352468024356865
千亿市场闷声发财:美瞳代工厂冲击上市,新锐品牌海外圈粉百万:https://www.ikjzd.com/articles/1679377731256872961
外贸“新三样”出口暴增,其他行业怎么抄作业?:https://www.ikjzd.com/articles/1679378710199037954
卷到底!卖家打0.1折直逼“0元购”,会员日状况连连!:https://www.ikjzd.com/articles/1679380634402496514
如何在上海找到最适合的FBA头程货代?:https://www.ikjzd.com/articles/1679383202298621954
赚大了!亚马逊新兴站点Q3爆品攻略来袭,100+星级选品、20大品类!:https://www.ikjzd.com/articles/1679392588802846721
2024.03.29亚马逊选品推荐(仅供参考):宠物饮水机滤芯片:https://www.kjdsnews.com/a/1836532.html
想要搞钱,就去做离搞钱最近的事:https://www.kjdsnews.com/a/1836533.html
相关文章
我的浏览记录
最新相关资讯
海外公司注册 | 跨境电商服务平台 | 深圳旅行社 | 东南亚物流