Node.Js多进程开启和socket.io通讯实现的代码是什么
Admin 2022-08-18 群英技术资讯 300 次浏览
一、开启多进程
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、服务端启动程序
2、客户端1
3、客户端2
4、客户端3
5、客户端4
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。
猜你喜欢
这篇文章主要为大家介绍了闭包结合递归等于柯里化的原理解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
node项目中如何优雅的修改node_modules的依赖库?下面本篇文章就来带大家优雅修改node_modules中依赖库的方法,希望对大家有所帮助!
node中怎么使用Nest.js 连接 MongoDB 数据库?下面本篇文章给大家介绍一下node 框架 Nest.js 使用 MongoDB 的方法,希望对大家有所帮助!
怎么利用node生成word文档?下面本篇文章给大家介绍一下使用node生成word文档的方法,分享一个实用库,聊聊该库的使用方法,希望对大家有所帮助!
这篇文章主要介绍了JavaScript设计模式之职责链模式,对设计模式感兴趣的同学,可以参考下
成为群英会员,开启智能安全云计算之旅
立即注册Copyright © QY Network Company Ltd. All Rights Reserved. 2003-2020 群英 版权所有
增值电信经营许可证 : B1.B2-20140078 粤ICP备09006778号 域名注册商资质 粤 D3.1-20240008