Node之在多个子进程中运行Node.js应用程序

2023-11-12

一个Node.js应用程序只能使用在一个线程中。最近,为了充分发挥多核CPU的优势,Node.js中提供了一个cluster模块,允许在多个子进程中运行不同的Node.js应用程序。

使用fork方法创建worker对象

在cluster模块中,可以使用fork方法开启多个子进程,在每个子进程中创建一个Node.js应用程序的实例,并且在该应用程序中运行一个模块文件

cluster.fork([env]
  • env:为一个对象,用于以“键名/键值”的形式为子进程指定环境变量。

fork方法返回一个隐式创建的worker对象,代表使用fork方法开启的子进程中运行的Node.js应用程序实例对象。

另外,在cluster模块中,分别提供了一个isMaster属性与一个isWorker属性,这两个属性的属性值均为一个布尔值。

  • 如果Node.js应用程序的实例对象运行在主进程中,则isMaster属性值为true。
  • 如果Node.js应用程序的实例对象运行在子进程中,则isWorker属性值为true。

在cluster模块中,可以通过workers属性值获取所有子进程中运行的worker对象

//对workers属性值进行遍历
for (var index in cluster.workers) {
    console.log(cluster.workers[index]);
}

在子进程运行的Node.js应用程序中,可以通过cluster.worker属性值获取当前子进程中运行的Node.js应用程序实例对象,还可以通过cluster.worker.id属性值获取cluster.worker对象的ID值

if (cluster.isMaster) {
    cluster.fork();
}
else if (cluster.isWorker) {
    console.log('I am worker #' + cluster.worker.id);
}

在子进程运行的Node.js应用程序中,可以通过cluster.worker.process属性值获取当前子进程,

if (cluster.isWorker) {
    worker.process.stdout.write('hello');
}

fork方法实例

var cluster = require('cluster');
var http = require('http');
if (cluster.isMaster) {
    cluster.fork();
    console.log('这段代码被运行在主进程中。');
}
else {
    http.createServer(function(req, res) {
        if(req.url!=="/favicon.ico"){
            res.writeHead(200, {'Content-Type': 'text/html'});
            res.write('<head><meta charset="utf-8"/></head>');
            res.end('你好\n');
            console.log("这段代码被运行在子进程中。");
        }
    }).listen(1337);
}

当使用fork方法开启子进程时,将同时触发fork事件,可以通过对该事件进行监听并指定事件回调函数的方法指定子进程开启时所要执行的处理

cluster.on('fork', function(worker) {
    //事件回调函数代码略
});

在使用fork方法开启一个新的用于运行Node.js应用程序的子进程后,该应用程序将会向主进程发送一个反馈信息,当主进程接收到该反馈信息后,触发online事件。可以通过对该事件进行监听并指定事件回调函数的方法指定当子进程中的Node.js应用程序向主进程发送反馈信息后所要执行的处理

cluster.on('online', function(worker) {
    //事件回调函数代码略
});

在online事件回调函数中,使用一个参数,参数值为使用fork方法开启子进程后返回的worker对象。

当在子进程中运行的Node.js应用程序中调用服务器的listen方法后,该服务器开始对指定地址及端口进行监听,同时触发listening事件。

cluster.on('listening', function(worker,address) {
    //事件回调函数代码略
});
  • worker:为使用fork方法开启子进程后返回的worker对象,
  • address:为一个对象,该对象具有如下所示的属性及属性值。
    • address:属性值为子进程中的服务器监听的地址。
    • port:属性值为子进程中的服务器监听的端口号。
    • addressType:属性值为服务器监听的地址类型。属性值为4时,表示该地址为IPv4地址;属性值为6时,表示该地址为IPv6地址。

setupMaster

子进程中的Node.js应用程序默认运行当前正在运行的Node.js应用程序中的主模块文件,可以使用setupMaster方法修改子进程中运行的模块文件或修改子进程中运行的Node.js应用程序的其他默认行为。

cluster.setupMaster([settings])
  • settings:在setupMaster方法中使用一个可选参数,参数值为一个用于设置子进程中运行的Node.js应用程序各种默认行为的对象,在该对象中可以使用的属性及属性值
    • exec:属性值为子进程中运行模板文件的完整路径及文件名,默认属性值为当前正在运行的Node.js应用程序中的主模块文件的完整路径文件名。
    • args:属性值为一个数组,其中存放了所有运行子进程中的Node.js应用程序时需要使用的参数,默认属性值为一个存放了由所有当前正在运行的Node.js应用程序所使用的参数构成的数组。
    • silent:属性值为一个布尔值。当属性值为false时,子进程对象与主进程对象共享标准输入/输出;当属性值为true时,子进程对象与主进程对象不共享标准输入/输出。默认属性值为false。

worker对象的方法与事件

在使用fork方法开启一个新的用于运行Node.js应用程序的子进程后,该应用程序将会向主进程发送一个反馈信息,当主进程接收到该反馈信息后,触发fork方法返回worker对象的online事件。可以通过对该事件进行监听并指定事件回调函数的方法指定当子进程中的Node.js应用程序向主进程发送反馈信息后所要执行的处理,在该回调函数中不使用任何参数。

var cluster = require('cluster');
var http = require('http');
if (cluster.isMaster) {
var worker=cluster.fork();
    console.log('这段代码被运行在主进程中。');
    worker.on('online', function() {
        console.log("已接收到子进程"+worker.id.toString()+"的反馈信息。");
    });
}
else {
    http.createServer(function(req, res) {
        if(req.url!=="/favicon.ico"){
            res.writeHead(200, {'Content-Type': 'text/html'});
            res.write('<head><meta charset="utf-8"/></head>');
            res.end('你好\n');
            console.log("这段代码被运行在子进程中。");
        }
    }).listen(1337);
}

当在子进程中运行的Node.js应用程序中调用服务器的listen方法后,该服务器开始对指定地址及端口进行监听,同时触发用于开启该子进程的worker对象的listening事件。可以通过对该事件进行监听并指定事件回调函数的方法指定子进程中运行的服务器开始监听时所要执行的处理

worker.on('listening', function(address) {
    //事件回调函数代码略
});
  • address:参数值为一个对象,该对象具有如下所示的属性及属性值。
    • address:属性值为子进程中的服务器监听的地址。
    • port:属性值为子进程中的服务器监听的端口号。
    • addressType:属性值为服务器监听的地址类型。属性值为4时,表示该地址为IPv4地址;属性值为6时,表示该地址为IPv6地址。

当使用fork方法开启子进程后,可以使用fork方法所返回的worker对象的send方法在主进程中向子进程发送消息,在子进程中也可以使用进程对象的send方法向主进程发送消息,在Node.js内部,这两个方法事实上是同一种方法。该方法的使用方式如下所示。

worker.send(message,[sendHandle]) //在主进程中向子进程发送消息
process.send(message,[sendHandle]) //在子进程中向主进程发送消息
  • message:用于指定需要发送的消息。
  • sendHandle:定为一个当接收到对方发送消息后执行的回调函数,也可以为一个服务器对象或socket端口对象,以达到在主进程与子进程之间共享该对象的目的。

强制关闭子进程

worker.kill([signal])
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Node之在多个子进程中运行Node.js应用程序 的相关文章

随机推荐

  • python+jieba分析唐诗三百首

    python jieba分析唐诗三百首 代码及源文件地址 poem 300 代码保证符合命名规范 遵循PEP8规则 导包顺序清晰 尽量做到复用性和不罗嗦 记得修改文件路径哟 如果有帮到您 还请给个评论或star 蟹蟹 1 题目描述 俗话说
  • 四种cast转换

    c 动态类型转换有四种const cast static cast dynamic cast reinterpreter cast 前面两个用的多 但是后面的针对其设计理念有许多其他的实现方法可达到同样的效果 1 const cast 用于
  • 三维数学(二)

    欧拉角 使用物体在三个旋转轴上的旋转角度来保存方位 API Transform eulerAngles 返回或设置物体的欧拉角 优点 1 仅使用三个数字表达方位 占用空间小 2 沿坐标轴旋转的单位为角度 符合人的思考方式 3 任意三个数字都
  • 【廖雪峰python入门笔记】list_按照索引访问

    1 按照索引访问list Python按照索引访问list 由于list是一个有序集合 所以 我们可以用一个list按分数从高到低表示出班里的3个同学 L Adam Lisa Bart 那我们如何从list中获取指定第 N 名的同学呢 方法
  • ubuntu小技巧27--基于dnsmasq快速搭建局域网dns服务器

    ubuntu小技巧27 基于dnsmasq快速搭建局域网dns服务器 1 介绍 2搭建dns服务器 2 1 搭建步骤 2 2 测试 3 注意事项 4 说明 1 介绍 DNS Domain Name Server 域名服务器 是进行域名 do
  • Kafka学习(三)——Java工具类、Springboot集成批量消费、SparkStreaming集成

    文章目录 前言 一 Java中工具类 1 添加maven依赖 2 消费者 KafkaConsumerTest 3 生产者 KafkaProducerTest 二 SpringBoot中使用 4 1 引入依赖 4 2 application
  • vim复制多行和删除多行的方法

    方法1 光标放到第6行 输入 2yy 光标放到第9行 输入 p 此方法适合复制少量行文本的情况 复制第6行 包括 下面的2行数据 放到第9行下面 方法2 命令行模式下输入 6 9 co 12 复制第6行到第9行之间的内容到第12行后面 方法
  • 泛微 E-Office文件上传漏洞复现(CVE-2023-2523、CVE-2023-2648)

    0x01 产品简介 泛微E Office是一款标准化的协同 OA 办公软件 泛微协同办公产品系列成员之一 实行通用化产品设计 充分贴合企业管理需求 本着简洁易用 高效智能的原则 为企业快速打造移动化 无纸化 数字化的办公平台 0x02 漏洞
  • Python 基础知识记录

    一 两个list第一个列表排序后 第二个列表根据第一个列表索引进行排序 x 2 1 4 5 6 0 y a b c d e f x sorted sorted x index sorted range len x key lambda k
  • QMessageBox的使用

    QMessageBox是Qt中常用的对话框类 用于显示消息 警告 错误等信息 常用的QMessageBox用法包括 1 显示信息框 QMessageBox information parent title text 2 显示警告框 QMes
  • 超实用!这是我见过最全面的python入门教程,新手小白不要错过

    Python 是一门开源免费 通用型的脚本编程语言 它上手简单 功能强大 坚持 极简主义 Python 类库 模块 极其丰富 这使得 Python 几乎无所不能 不管是传统的 Web 开发 PC 软件开发 Linux 运维 还是当下火热的机
  • Hello React (创建自己的第一个React 页面)

    Rract是啥 React 是用于构建用户界面的 JavaScript 库 构建用户界面 User Interface 对咱们前端来说 简单理解为 HTML 页面 javscrtipt库 不是框架 是库 react 全家桶才是框架 reac
  • 统计学习的基本概念和分类

    前言 一 统计学习的概念 1 统计学习应用领域 pic center 80 x80 2 统计学习的概念 统计学习是关于计算机基于数据构建概率统计模型并运用模型对数据进行预测与分析的一门学科 以计算机和网络为平台 以数据为研究对象 以预测和分
  • Fake Objects

    Spring的创始人Rod Johnson关于伪对象 Fake Objects objects in appearance but which don t exhibit some of the characteristics of obj
  • java: DAL using SQL Server

    sql 角色类型表RoleType geovindu 涂聚文 Geovin Du IF EXISTS select from sysobjects where id object id N dbo RoleTypeList and OBJE
  • 史上最全,K8s创建pod yaml例子

    kubernetes创建pod的yaml文件 参数说明 apiVersion v1 指定api版本 此值必须在kubectl apiversion中 kind Pod 指定创建资源的角色 类型 metadata 资源的元数据 属性 name
  • 服务器加固系统文档,手把手教你如何加固你的服务器.docx

    摘要 为提升服务器安全性 减少信息资产的泄漏风险 我们需要对服务器进行安全加固 从系统 策略 应用程序 帐号密码等各方面进行加强 避免一些低级安全问题的出现 本文基于集 团信息化安全规定 针对服务器安全配置的方法进行详细描述 并提供了服务器
  • 超全C1认证学习笔记,内容详细,赶快收藏

    在我们考过C认证和正在考C认证的同学们当中 都有十分认真的同学 他们每堂课都认证的记下笔记 归纳好 方便自己后续的复习 今天我们也收到我们C认证考生的投稿 他一共投稿了三篇文章 内容包括计算机通识 WEB基础 JavaScript基础三篇文
  • Android调用C++实现共享内存(Native层)

    Android下匿名共享内存java层接口利用MemoryFile实现进程间内存共享 利用MemoryFile可以参考这篇文章 https blog csdn net qq 24451593 article details 80514566
  • Node之在多个子进程中运行Node.js应用程序

    引 一个Node js应用程序只能使用在一个线程中 最近 为了充分发挥多核CPU的优势 Node js中提供了一个cluster模块 允许在多个子进程中运行不同的Node js应用程序 使用fork方法创建worker对象 在cluster