位置: 编程技术 - 正文

node 利用进程通信实现Cluster共享内存(node 线程 进程)

编辑:rootadmin

推荐整理分享node 利用进程通信实现Cluster共享内存(node 线程 进程),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:node子进程,node子进程,node 线程 进程,node多进程,node获取某个进程pid,node进程通信,node 进程管理,node子进程,内容如对您有帮助,希望把文章链接给更多的朋友!

Node.js的标准API没有提供进程共享内存,然而通过IPC接口的send方法和对message事件的监听,就可以实现一个多进程之间的协同机制,通过通信来操作共享内存。

##IPC的基本用法:

在Node.js中,通过send和on(‘message', callback)实现的IPC通信有几个特点。首先,master和worker之间可以互相通信,而各个worker之间不能直接通信,但是worker之间可以通过master转发实现间接通信。另外,通过send方法传递的数据,会先被JSON.stringify处理后再传递,接收后会再用JSON.parse解析。所以Buffer对象传递后会变成数组,而function则无法直接传递。反过来说,就是可以直接传递除了buffer和function之外的所有数据类型(已经很强大了,而且buffer和function也可以用变通的方法实现传递)。

基于以上特点,我们可以设计一个通过IPC来共享内存的方案:

1、worker进程作为共享内存的使用者,并不直接操作共享内存,而是通过send方法通知master进程进行写入(set)或者读取(get)操作。

2、master进程初始化一个Object对象作为共享内存,并根据worker发来的message,对Object的键值进行读写。

3、由于要使用跨进程通信,所以worker发起的set和get都是异步操作,master根据请求进行实际读写操作,然后将结果返回给worker(即把结果数据send给worker)。

node 利用进程通信实现Cluster共享内存(node 线程 进程)

##数据格式

为了实现进程间异步的读写功能,需要对通信数据的格式做一点规范。

首先是worker的请求数据:

master在接到数据后,会根据method执行相应操作,然后根据requestMessage.id将结果数据发给对应的worker,数据格式如下:

规范数据格式的意义在于,master在接收到请求后,能够将处理结果发送给对应的worker,而worker在接到回传的结果后,能够调用此次通信对应的callback,从而实现协同。

规范数据格式后,接下来要做的就是设计两套代码,分别用于master进程和worker进程,监听通信并处理通信数据,实现共享内存的功能。

##User类

User类的实例在worker进程中工作,负责发送操作共享内存的请求,并监听master的回信。

##Manager类

Manager类的实例在master进程中工作,用于初始化一个Object作为共享内存,并根据User实例的请求,在共享内存中增加键值对,或者读取键值,然后将结果发送回去。

##使用方法

标签: node 线程 进程

本文链接地址:https://www.jiuchutong.com/biancheng/368541.html 转载请保留说明!

上一篇:基于Datatables跳转到指定页的简单实例(datatable.load)

下一篇:Express系列之multer上传的使用(express model)

  • 小规模纳税人月销售额超过15万
  • 缴纳以前年度所得税怎么做账
  • 增值税报税后多久缴纳期限
  • 2019发票认证期限新规
  • 员工回家探亲的文案
  • 住宿发票税点为什么有6%和3%的区别
  • 停业的纳税人还交税吗
  • 商品房的销售方式有哪些
  • 税负率怎么算计算公式举例说明
  • 应纳税所得额就是企业所得税吗
  • 企业缴纳的财产保险费会计分录
  • 股东贷款是什么意思
  • 公司注销固定资产清理需要开票吗
  • 营利性医院如何开办对外药房业务
  • 从公司账户取现金
  • 医疗器械销售税负率是多少
  • 个人取得利息需要缴纳增值税吗
  • 公司车辆怎么处理
  • 预收房款属于什么科目
  • 自产货物用于捐赠的会计处理
  • 一般人企业所得税怎么算
  • 企业赠送客户产品如何账务处理
  • 个税扣除每个月更新吗
  • 供应商是收款人还是付款人
  • 出纳电汇流程
  • 印花税可以不计提嘛
  • 国外差旅费如何报销
  • 差旅费的会计处理
  • 出差环境补贴怎么算
  • 建筑企业挂靠账务怎么处理?
  • 会计凭证出现的问题
  • 企业合并发生的审计费用,评估费用会计分录
  • 交易性金融资产的入账价值
  • 支付航天信息服务费怎么入账
  • 会计在账本上怎么记账
  • redis提供了对值进行运算的命令
  • 成本费用做账
  • 以无形资产向外单位投资会引起会计要素
  • 财务报销中的冲销是啥意思
  • 体育用品账务处理
  • RabbitMQ个人实践
  • python之sqlalchemy创建表的实例详解
  • SQLite3 API 编程手册
  • 技术开发费免税政策
  • 所得税汇算清缴怎么操作
  • 假退库会计分录
  • 短期借款会计分录例题及答案
  • 开发研究的定义
  • 车辆保险费用查询
  • 取得虚开普票如何处置
  • 员工持股平台合伙企业
  • 大家怎么看理想这个牌子
  • 增值税明细账怎么结账
  • 关联方往来款账务处理
  • 单位代扣代缴个人所得税凭证
  • 怎样充高速路etc现金
  • 预收物业费预收什么意思
  • 客户要扣货款太多怎么处理
  • 小规模纳税人增值税计算公式
  • 企业的财务战略
  • window10系统电脑配置
  • 无法进入睡眠状态
  • win10系统如何快速打开控制面板
  • sybase ase数据库用户名密码
  • windows无法访问指定设备路径权限
  • centos init
  • Win7 64位操作系统怎么使用DVD刻录光驱复制软件
  • youphone.exe是什么
  • 第三方win7系统哪个最好
  • linux命令光标移动到末尾
  • win8应用商店下载
  • shell脚本编写 方法
  • 安卓作业仿银行
  • Android AsyncTaskLoader需要注意的问题
  • jquery easyui插件
  • 利用jQuery实现一个时间无法显示
  • 增值税申报表如何填报
  • 北京买车如何摇号
  • 中国税务总局贵州省税务局
  • 江苏城市规划
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设