当前位置：首页 > news >正文

node.js之---集群（Cluster）模块

news 来源：原创 2025/7/17 21:47:15

为什么会有集群（Cluster）模块？

集群（Cluster）模块的作用

如何使用集群（Cluster）模块？

为什么会有集群（Cluster）模块

Node.js 是基于 单线程事件驱动 模型的，这意味着每个 Node.js 进程只会在一个 CPU 核心上运行。虽然 Node.js 的事件循环模型非常适合处理 I/O 密集型的操作，但它在 CPU 密集型任务（例如复杂的计算、数据处理等）上的表现不如多核处理器那样高效。

问题背景：

单线程限制：
- Node.js 默认是单线程的，所有任务都由一个线程处理。对于大规模的并发请求，Node.js 可以高效地处理 I/O 请求，但在处理计算密集型任务时，单线程的性能可能无法满足需求。
多核处理器的未利用：
- 现代服务器通常配备多核处理器，多个 CPU 核心可以并行处理任务。Node.js 只使用一个核心，导致其无法充分利用多核处理器的性能优势。

因此，为了更好地利用服务器的硬件资源，并在多核环境中实现高并发和高性能，Node.js 提供了 集群（Cluster）模块，允许通过多个进程来并行工作，充分利用多核 CPU。

集群（Cluster）模块的作用

Node.js 集群模块提供了一个 多进程并发 机制，通过多个工作进程来分担主进程的负载。集群模块能够让 Node.js 应用同时在多个 CPU 核心上运行，从而提升应用的吞吐量和性能。

具体来说，集群模块的作用可以分为以下几个方面：

1. 提升性能与并发能力

多进程并行：集群模块可以启动多个工作进程，每个工作进程都能独立地处理请求，从而充分利用服务器的多核 CPU。每个工作进程都可以处理自己的请求，主进程负责协调和管理这些工作进程。
负载均衡：集群模块通过操作系统的负载均衡机制（例如 Linux 上的 SO_REUSEPORT）来自动将流量分发到多个工作进程，避免某个进程过载，提升系统的整体并发处理能力。

2. 增强应用的可扩展性

横向扩展：通过集群模块，Node.js 可以非常方便地将应用部署在多个进程中，而不需要改变应用的代码逻辑。这使得应用能够轻松地在多核服务器上扩展，甚至在云平台上分布式部署时更加灵活。
进程管理：主进程负责创建和管理多个工作进程，并且能够自动监控工作进程的状态。当工作进程出现异常或崩溃时，主进程可以自动重启这些进程，确保应用的高可用性。

3. 提高可靠性与容错性

容错机制：集群模块能够监控工作进程的状态。如果某个工作进程崩溃或异常退出，主进程可以自动重新启动它。这种容错机制提高了应用的可靠性，确保它在出现问题时不会彻底宕机。
平滑重启：在需要更新或维护时，集群模式可以实现平滑重启，主进程可以逐步重启工作进程，不会影响系统的稳定性和服务的可用性。

4. 使得 Node.js 更适合多核系统

Node.js 本身是单线程的，这意味着它不能直接利用多个 CPU 核心。集群模块通过创建多个工作进程，使得每个进程运行在不同的核心上，从而使得 Node.js 可以在多核服务器上充分发挥性能。

5. 提供进程间通信（IPC）

集群模块允许主进程和工作进程之间进行 进程间通信（IPC）。工作进程可以通过 process.send() 向主进程发送消息，主进程也可以向工作进程发送命令或数据。这为进程间的协调和状态管理提供了有效的手段。

总结：集群模块的作用

负载均衡：将客户端请求分配到多个工作进程，确保每个进程都有相对均衡的负载。
多核利用：使 Node.js 能够充分利用多核处理器，提升应用的并发处理能力和整体性能。
容错和高可用性：确保即使某些工作进程崩溃，应用仍能正常运行，自动重启失败的进程。
可扩展性：方便应用横向扩展，能够动态增加或减少工作进程，适应不同的负载需求。
进程间通信：允许主进程和工作进程之间进行有效的通信和协调。

如何使用集群（Cluster）模块

1. 基本概念

主进程（Master Process）：负责启动和管理工作进程，处理负载均衡和进程监控。
工作进程（Worker Processes）：每个工作进程都有自己的事件循环和 HTTP 服务器，负责处理实际的请求。
主进程和工作进程之间可以通过 进程间通信（IPC） 进行通信。

2、Cluster模块

cluster.isMaster：判断当前进程是否是主进程。
cluster.fork()：在主进程中创建新的工作进程。
cluster.on('exit', callback)：监听工作进程退出事件，可以进行容错处理。
process.send()：主进程和工作进程之间的通信。

Cluster模块使用代码

const cluster = require('cluster');
const http = require('http');
const os = require('os');// 获取 CPU 核心数
const numCPUs = os.cpus().length;if (cluster.isMaster) {console.log(`主进程 ${process.pid} 正在运行`);// 为每个 CPU 核心创建一个工作进程for (let i = 0; i < numCPUs; i++) {cluster.fork();  // 创建工作进程}// 监听工作进程退出cluster.on('exit', (worker, code, signal) => {console.log(`工作进程 ${worker.process.pid} 退出`);});} else {// 工作进程处理请求http.createServer((req, res) => {res.writeHead(200);res.end(`请求由工作进程 ${process.pid} 处理`);}).listen(8000, () => {console.log(`工作进程 ${process.pid} 已启动，监听端口 8000`);});
}

node.js之---集群（Cluster）模块

为什么会有集群（Cluster）模块？ 集群（Cluster）模块的作用如何使用集群（Cluster）模块？ 为什么会有集群（Cluster）模块 Node.js 是基于单线程事件驱动模型的…...

编程日记 2025/7/17 21:47:15

PTA数据结构作业四

7-10 判断两点之间是否存在路径本题要求输出两个顶点之间是否存在路径输入格式: 输入包括两部分，第一部分是邻接矩阵表示方法中对应1的两个顶点，用0 0 表示结束第二部分是两个顶点，例如 Vi和Vj 输出格式: 如果Vi和Vj存在路径，输出1；否则输出0 输入样例: 0 1 1 0…...

编程日记 2025/7/16 1:55:36

Spring-kafka快速Demo示例

使用Spring-Kafka快速发送/接受Kafka消息示例代码，项目结构是最基础的SpringBoot结构，提前安装好Kafka，确保Kafka已经正确启动 pom.xml，根据个人情况更换springboot、java版本等 <?xml version"1.0" encoding&qu…...

编程日记 2025/7/17 17:36:13

Java开发工具-Jar命令

Java开发工具-Jar 1、jar命令全平台使用 2、jar命令的作用为类和资源创建存档，并从存档中操作或恢复单个类或资源 3、摘要 jar [OPTION …] [ [–release VERSION] [-C dir] files] … 4、jar命令描述 jar命令通常作为用于压缩与解压的工具，基于ZIP或Z…...

编程日记 2025/7/18 4:44:40

flux文生图模型实践

flux文生图模型实践 flyfish https://github.com/black-forest-labs/flux Black Forest Labs发布FLUX.1 Tools，这是一套模型全家桶，旨在为FLUX.1基础文本转图像模型添加控制和可操纵性，从而实现对真实图像和生成图像的修改和重新创建。FLU…...

编程日记 2025/7/18 1:04:54

Lecture 19

冯诺依曼模型 (The von Neumann Model) 核心概念： 1. 冯诺依曼模型的基本结构： • 该模型描述了现代计算机的基本结构，包含以下关键组件： • 输入设备 (Input device)： • 用于从用户向计算机传递信息，…...

编程日记 2025/7/18 4:47:50

学习EDK2显示图片

原本想看看Logo是怎么显示的，但是发现可以通过EDK显示Logo的方式显示图片，因为我发现它并没有解码函数，就是写个Driver,代码会有点乱，我后面会整理后修改的。在MdeModulePkg下，我们可以找到Logo此文件夹。 Logo.ibf中…...

编程日记 2025/7/14 17:15:14

MYSQL如何重置root密码

如果您从未为MySQL分配root密码，则服务器根本不需要以root身份连接的密码。但是，这是不安全的。建议一定要设置root密码。如果您知道root密码并想要更改它，推荐使用ALTER USER user IDENTIFIED BY auth_string; 如果您之前分配了root密码但…...

编程日记 2025/7/18 4:57:42

基于Python实现车辆检测、机动车检测、识别位置标记、计数

目录引言背景与应用场景车辆检测的研究意义相关工作车辆检测概述机动车检测方法分类基于传统计算机视觉的检测方法基于深度学习的检测方法技术与方法车辆检测技术概述基于Python的车辆检测方法图像处理与特征提取深度学习方法（如YOLO、SSD、Faster R-CNN等）数据集与标注常用…...

编程日记 2025/7/17 10:43:34

277-基于八路256Ksps 24bit AD生物电震动检测FMC子卡

一、板卡概述板卡基于AD7768 AD芯片设计的八路低速采集的FMC 子卡，支持直流耦合，产品应用于生物电、脑电波、声音，震动等信号采集。二、板卡参数及性能板卡功能参数内容 ADC 芯片型号 AD7768 路数 8路ADC， 采样率 2…...

编程日记 2025/7/13 16:30:10

连接到Milvus 验证Milvus服务器正在侦听哪个本地端口。将容器名称替换为您自己的名称。 docker port milvus-standalone 19530/tcp docker port milvus-standalone 2379/tcp docker port milvus-standalone 192.168.1.242:9091/api/v1/health 使用浏览器访问连接地址htt…...

编程日记 2025/7/14 21:11:23

GitHub 上排名前 11 的开源管理后台（Admin Dashboard）项目

如果你是一名开发者，经常处理数据或参与项目管理，那么这篇文章绝对值得收藏！当你需要一个高效、易用的管理后台（Admin Dashboard）项目时，本文会给你灵感。在现代企业管理和业务运营中，管理后台…...

编程日记 2025/7/15 19:50:35

C++ 实现map容器从大到小排序

map容器默认从小到大排序利用仿函数可以修改map容器的排序规则为从大到小示例： #include<iostream> #include<string> #include<map> using namespace std; class MyCompare { public: bool operator()(const int v1, const int v2) co…...

编程日记 2025/7/18 4:54:50

vue项目利用webpack进行优化案例

使用 Webpack 优化 Vue 项目是提升性能和减少打包体积的关键步骤。以下是几个常见的优化案例及其详细实现方法： 1. 优化打包大小 1.1 按需加载 (Lazy Loading) Vue 提供了路由懒加载功能，可以将组件拆分成独立的块，按需加载，从而…...

编程日记 2025/7/17 10:04:14

centos双网卡不能上网

双网卡类型 ens33 仅主机 ens34 NAT 问题 window配置一切正常，虚拟机不能上网解决方案1：路由引起查看路由 route结果如下： [rootdata-repository ~]# route Kernel IP routing table Destination Gateway Genmask …...

编程日记 2025/7/17 22:50:32

十个Scala的小知识

# 1. 与Java的互操作性 Scala与Java有很好的互操作性。可以在Scala项目中直接使用Java类库，也可以将Scala代码编译后供Java项目使用。例如，一个Java框架可以轻松地集成Scala编写的代码模块。 # 2. 强大的集合库 Scala拥有功能丰富的集合库。像List、Se…...

编程日记 2025/7/13 20:29:24

Redis Stream：实时数据处理的高效解决方案

Redis Stream：实时数据处理的高效解决方案引言在当今这个数据驱动的时代，实时数据处理对于各种应用场景都至关重要。Redis，作为一个高性能的键值存储系统，自然也紧跟这一趋势，推出了Redis Stream——一种用于处理实…...

编程日记 2025/7/17 21:09:41

Bert中文文本分类

这是一个经典的文本分类问题，使用google的预训练模型BERT中文版bert-base-chinese来做中文文本分类。可以先在Huggingface上下载预训练模型备用。https://huggingface.co/google-bert/bert-base-chinese/tree/main 我使用的训练环境是 pip install torch2.0.0; pi…...

编程日记 2025/7/16 0:05:23

【Rust自学】8.5. HashMap Pt.1：HashMap的定义、创建、合并与访问

8.5.0. 本章内容第八章主要讲的是Rust中常见的集合。Rust中提供了很多集合类型的数据结构，这些集合可以包含很多值。但是第八章所讲的集合与数组和元组有所不同。第八章中的集合是存储在堆内存上而非栈内存上的，这也意味着这些集合的数据大小无需在编…...

编程日记 2025/7/13 6:56:06

使用云计算开发App 有哪些坑需要避免

当我们在云计算环境下开发App时，往往会觉得一切都变得“轻松”了。毕竟，云计算提供了无限的计算资源、灵活的存储方案，还有自动化的服务，仿佛有了一个万能的工具箱，啥都能搞定。可是，别被这种“轻松”外表骗…...

编程日记 2025/7/16 8:43:45

arcgis模版空库怎么用（一）

这里以某个项目的数据为例： 可以看到，属性表中全部只有列标题，无数据内容可能有些人会认为空库是用来往里面加入信息的，其实不是，正确的用法如下： 一、下图是我演示用的数据，我们可以看到其中…...

编程日记 2025/7/18 4:56:16

C#控件开发4—仪表盘

目录思路（GDI绘图）1.定义属性2.绘制图形3.最后生成（自定义各种监控值显示）End 如何让温度、湿度、压力等有量程的监控值如仪表盘（DashBoard）一样显示？ 思路（GDI绘图） 定…...

编程日记 2025/7/18 4:59:14

基于BiTCN双向时间卷积网络实现电力负荷多元时序预测(PyTorch版)

Bidirectional Temporal Convolutional Network \begin{aligned} &\text{\Large \color{#CDA59E}Bidirectional Temporal Convolutional Network}\\ \end{aligned} Bidirectional Temporal Convolutional Network Bidirectional Temporal Convolutional Network (BiTC…...

编程日记 2025/7/17 23:15:26

No.2十六届蓝桥杯备战|练习题4道|数据类型|字符型|整型|浮点型|布尔型|signed|unsigned(C++)

B2002 Hello,World! - 洛谷 #include <iostream> using namespace std; int main() { cout << "Hello,World!" << endl; return 0; }打印飞机 #include <iostream> using namespace std;int main() {cout << " …...

编程日记 2025/7/16 20:07:19

前端项目 npm报错解决记录

1.首先尝试解决思路 npm报错就切换yarn ， yarn报错就先切换npm删除 node_modules 跟 package-lock.json文件重新下载依 2. 报错信息： Module build failed: Error: Missing binding D:\vue-element-admin\node_modules\node-sass\vendor\win32-x64-8…...

编程日记 2025/7/18 4:56:16

正弦函数解析（sin.rs）

sin.rs文件提供了sin函数的实现，它计算并返回一个浮点数（f64类型）的正弦值。这个函数首先处理了一些特殊情况，如极小的值、无穷大和NaN（非数字），然后使用rem_pio2函数将输入参数x归约到[-π/2, …...

编程日记 2025/7/18 4:53:19

python 归并排序（Merge Sort）

归并排序（Merge Sort） 归并排序是一种高效的排序算法，采用分治法（Divide and Conquer）策略。它的基本思想是：将数组递归地分成两半，分别对两半进行排序，然后将排序后的两半合并成一…...

编程日记 2025/7/18 4:38:36

Zeotero安装”translate for Zotero“插件

一、Zeotero6translate for Zotero 1.0.28 二、打开Zeotero官网，找到下面圈起来的三、点击以上连接跳转，Releases windingwind/zotero-pdf-translate 下载 zotero-pdf-翻译.xpi 四、打开zeotero，工具>附加组件（或插件&am…...

编程日记 2025/7/14 5:36:16

python 选择排序（Selection Sort）

选择排序（Selection Sort） 选择排序是一种简单的排序算法。它的基本思想是：每次从未排序的部分中选择最小（或最大）的元素，将其放到已排序部分的末尾。重复这个过程，直到所有元素都被排序。选…...

编程日记 2025/7/18 4:55:42

履约系统：应用层、领域层、集成关系设计

在这篇文章中，我们一起探讨订单履约系统的应用架构设计。应用架构设计我们前面讨论了系统的核心概念模型和拆单逻辑。接下来，让我们从应用架构的角度，深入了解系统的各个层次。这包括应用层、领域层，以及与其他系统的集成关系。…...

编程日记 2025/7/16 4:00:07

SpringBoot开发——整合 Elasticsearch 实现数据高效搜索

文章目录一、Elasticsearch 简介二、Spring Boot 整合 Elasticsearch 的准备工作1. 安装 Elasticsearch2. 创建 Spring Boot 项目3. 添加 Maven 依赖三、配置 Elasticsearch 连接四、定义实体类和仓库接口1. 定义实体类2. 定义仓库接口五、实现业务逻辑和控制器1. 实现业务逻辑…...

编程日记 2025/7/14 19:10:56

风力涡轮机缺陷检测数据集，91.4％准确识别率，18912张图片，支持yolo，PASICAL VOC XML，COCO JSON格式的标注

风力涡轮机缺陷检测数据集，91.4％准确识别率，18912张图片，支持yolo，PASICAL VOC XML，COCO JSON格式的标注数据集下载： ｙｏｌｏ　ｖ&#…...

编程日记 2025/7/16 11:26:02

直观解读 JuiceFS 的数据和元数据设计（一）

大家读完觉得有意义和帮助记得关注和点赞！！！ 1 JuiceFS 高层架构与组件2 搭建极简 JuiceFS 集群 2.1 搭建元数据集群2.2 搭建对象存储（MinIO） 2.2.1 启动 MinIO server2.2.2 创建 bucket2.3 下载 juicefs 客户端2.4 创…...

编程日记 2025/7/18 4:37:59

【数据结构】（Python）差分数组。差分数组与树状数组结合

差分数组： 基于原数组构造的辅助数组。用于区间修改、单点查询。区间修改的时间复杂度O(1)。单点查询的时间复杂度O(n)。差分数组的元素：第一个元素等于原数组第一个元素，从第二个元素开始是原数组对应下标的元素与前一个元素的差&#xff0…...

编程日记 2025/7/18 4:57:06

基于zynq在linux下的HDMI实战

ZYNQ系列文章目录第一章：基于zynq在linux下的phy调试记录第二章：qemu制作ubuntu文件系统第三章：基于zynq在linux下的AXI-CAN实战第四章：基于zynq在linux下的HDMI实战文章目录 ZYNQ系列文章目录前言一、vivado中HDMI的配置1.…...

编程日记 2025/7/18 4:58:31

HT-HaiBOX边缘计算盒智慧工厂方案，智慧医疗方案，智慧加油站方案，智慧安防方案，智慧城市方案；方案定制开发

背景介绍在当今数字化时代，各个行业对于智能化视频监控设备的需求日益增长。无论是安防监控，还是智慧工厂、智慧城市等领域，都需要高效、智能的设备来保障安全和提高生产效率。然而，传统的视频监控设备存在诸多痛点：…...

编程日记 2025/7/18 4:38:00

【JMeter详解】

JMeter详解 Apache JMeter 是一个开源的、100%纯Java应用程序，设计用于负载测试和性能测量。它最初是为测试Web应用程序而设计的，但后来扩展到其他测试功能。JMeter可以用来对静态和动态资源（如静态文件、Servlets、Perl脚本、Java对象、数据…...

编程日记 2025/7/16 7:04:35

《PHP Switch》

《PHP Switch》介绍 PHP 是一种广泛使用的服务器端编程语言，而 switch 语句是 PHP 中用于基于不同条件执行不同代码块的关键字。在本篇文章中，我们将详细介绍 PHP 中的 switch 语句，包括其语法、用法、以及在实际编程中的应用场景。语法…...

编程日记 2025/7/15 10:05:19

如何确保涡度通量观测数据的准确性？涡度通量光敏感性分析、温度敏感性分析、数据风浪区分析等

确保涡度通量观测数据的准确性，可以采取以下几个步骤： 1.数据预处理：在进行数据分析之前，需要对原始的高频涡度通量数据进行预处理，包括剔除异常值和进行数据缺失插补。异常值剔除可以通过设定合理的阈值来识别并剔除数…...

编程日记 2025/7/18 4:54:00

linux自动化批量分发SSH密钥同时批量测试SSH连接教程（包含自动化脚本代码）

1、检查端口检查分发对象22端口是否打开 nmap -p22 ip地址如果要批量检查端口可以参考我写的这篇文章：linux自动化一键批量检查主机端口 2、命令行分发密钥原理 Linux分发密钥原理主要涉及SSH（Secure Shell）协议，该协议用于…...

编程日记 2025/7/15 20:30:42

C++ 设计模式：命令模式（Command Pattern）

链接：C 设计模式链接：C 设计模式 - 访问者模式命令模式（Command Pattern）是一种行为型设计模式，它将请求封装成一个对象，从而使你可以用不同的请求对客户进行参数化，对请求排队或记录请求日志…...

编程日记 2025/7/18 4:51:56

Flink源码解析之：Flink On Yarn模式任务提交部署过程解析

Flink源码解析之：Flink On Yarn模式任务提交部署过程解析一、Flink on Yarn部署模式概述 Apache Hadoop YARN 在许多数据处理框架中都很流行。 Flink 服务提交给 YARN 的 ResourceManager，后者会在 YARN NodeManagers 管理的机器上生成容器。 Flink 将…...

编程日记 2025/7/16 3:09:48

C++算法20例

1、求两个数的最大公约数 int gcd(int a, int b) { 2 return b 0 ? a : gcd(b, a % b); 3} 2、判断素数 bool isPrime(int n) {if (n < 1) return false; for (int i 2; i * i < n; i) {if (n % i 0) return false;}return true; } 3、冒泡排序 void bubbleSort…...

编程日记 2025/7/18 4:49:10

雷军：科技传奇的逐梦之旅

亲爱的小伙伴们😘，在求知的漫漫旅途中，若你对深度学习的奥秘、Java 与 Python 的奇妙世界，亦或是读研论文的撰写攻略有所探寻🧐，那不妨给我一个小小的关注吧🥰。我会精心筹备，在未来…...

编程日记 2025/7/17 4:12:14

python版本的Selenium的下载及chrome环境搭建和简单使用

针对Python版本的Selenium下载及Chrome环境搭建和使用，以下将详细阐述具体步骤： 一、Python版本的Selenium下载安装Python环境： 确保系统上已经安装了Python 3.8及以上版本。可以从[Python官方网站]下载并安装最新版本的Python，…...

编程日记 2025/7/17 4:12:13

linux tar 文件解压压缩

文件压缩和解压 tar -c: 建立压缩档案 -x：解压 -t：查看内容 -r：向压缩归档文件末尾追加文件 -u：更新原压缩包中的文件 -z：有gzip属性的 -j：有bz2属性的 -v：显示所有过程 -O：…...

编程日记 2025/7/17 21:42:10

Razzashi Raptor

拉扎什迅猛龙 Razzashi Raptor 2024.12.24 无论是工作、游戏，除了坚持，还需要一点运气，2024年跨年啦。 World of Warcraft [CLASSIC]80猎人[Grandel][祖尔格拉布][血领主曼多基尔][拉扎什迅猛龙]20241231跨年回报_哔哩哔哩bilibili_魔兽 Ra…...

编程日记 2025/7/16 4:32:58