node可以开启多线程吗-前端问答-PHP中文网

node可以开启多线程吗

WBOY

发布： 2022-06-15 17:06:37

原创

2736人浏览过

node可以开启多线程；可以利用node自带的“child_process”模块来开启多线程，语法为“child_process.fork(modulepath[, args][, options])”；使用该模块可以创建exec、execfile、spawn、fork四种类型的子进程。

node可以开启多线程吗

本教程操作环境：windows10系统、nodejs 12.19.0版本、Dell G3电脑。

node可以开启多线程吗

node可以开启多线程

我们都知道 Node.js 是以单线程的模式运行的，但它使用的是事件驱动来处理并发，基于事件驱动、非阻塞I/O模型，充分利用操作系统提供的异步 I/O 进行多任务的执行，适合于 I/O 密集型的应用场景，因为异步，程序无需阻塞等待结果返回

NodeJS多线程的出现不为了提高并发，而是为了充分提高CPU的利用率

开多线程的几种方式

使用Node自带的 child_process 模块

child_process.fork(modulePath[, args][, options])

登录后复制

衍生新的 Node.js 进程并使用建立的 IPC 通信通道（其允许在父子进程之间发送消息）调用指定的模块

cluster 集群模块可以轻松创建共享服务器端口的子进程，工作进程使用 child_process.fork() 方法衍生

在这里插入图片描述

使用多进程

express

新建三个文件 server.js(express服务) cluster.js（多线程服务文件）extensionServer.js （express 子服务）
下面操作确保安装 express

npm intsall express --seve-dev

extensionServer.js 使用express 创建子服务

const express = require("express"), //Express框架
app = express();

// api 先关接口
app.all(&#39;/userinfo&#39;, (req, res) => {
  res.json({ name: &#39;自夏&#39;, msg: &#39;我在自夏 selfsummer&#39; })
})

app.listen(4000, () => {
 console.log(`子服务启动成功`);
})

登录后复制

serve.js 先创建Express 多线程服务

const  { fork } = require("child_process"),
express = require("express"), //Express框架
app = express();

const { pid, ppid } = require(&#39;process&#39;)

// api 先关接口
app.all(&#39;/123&#39;, (req, res, next) => {
   console.log(`本次进程id为: ${pid}`);
  res.end(`本次进程id为: ${pid}`)
})

app.all(&#39;/456&#39;, (req, res, next) => {
  console.log(`本次进程id为: ${pid}`);
  res.end(`本次进程id为: ${pid}`)
})


app.listen(3888, () => {
 console.log(`服务器端启动成功 父进程 ${ppid} 当前服务进程id为 ${pid}`);
 // 开启多进程
 fork(&#39;extensionServer.js&#39;)
})

module.exports = {
  app,
  express,
};

登录后复制

启动服务这个时候主服务和自服务都启动好了

在这里插入图片描述

访问 Express 主服务以及子服务地址都可成功

cluster.js 把Express 服务改为集群

使用 cluster集群模块开启多线程

const os = require(&#39;os&#39;);
const cluster = require(&#39;cluster&#39;);
const { log } = console;
const express = require("express"); //Express框架

const app = express();
const processId = process.pid;

// 判断当前是否有主进程
if (cluster.isMaster)
{
	// 获取当前本机cpu核数，开启多线程
  const cpus = os.cpus().length;
  for (let i = 0; i < cpus; i++){
    cluster.fork()
  }
	//进程已断开连接	
	  cluster.on(&#39;disconnect&#39;, (worker) => {
	    console.log(`进程号 #${worker.id} 已断开`);
	  });
	// 意外退出进程
	cluster.on(&#39;exit&#39;, (worker, code, signal) => {
	      cluster.fork();
  	});


} else
{
	// 引用Express主服务 开启主进程  
  require(&#39;./server&#39;)
}

登录后复制

启动集群服务 node cluster

当然也可以在集群里面继续开子进程

访问二次（一个浏览器访问，一个Postman 访问）后接口
在这里插入图片描述

为什么会有多个 服务器端启动成功当前服务进程id为 xxx

应为 cluster 模块在当前主进程下面衍生子进程，每一个子进程是基于主进程的所有
衍生新的进程，进程之间是相互独立的，每个进程都有自己的 V8 实例、内存，系统资源是有限的，不建议衍生太多的子进程出来，通长根据系统*
CPU 核心数*设置

前面我们有判断是否是有主进程

如果有主进程就使用 cluster 模块开启子进程

没有就开启进程

把Express 服务改为默认http 服务

只需要更改server.js 文件内容

const http = require(&#39;http&#39;)const { pid, ppid } = require(&#39;process&#39;)const server = http.createServer((req, res) => {
  res.end(router(req.url))})const router = (url) => {
  switch (url)
  {
    case &#39;/132&#39;:
      return `进程${pid} 很高兴为你服务`;
    case &#39;/456&#39;:
      return `进程${pid} 很高兴为你服务`;
    default: return `没有此接口`
  }}server.listen(3889, () => {
  console.log(`Server Started in process ${pid}`);})

登录后复制

依旧是启动 cluster.js（多线程服务文件）
在这里插入图片描述