| NodeJS开启多线程和集群 | 您所在的位置：网站首页 › node怎么实现多线程 › NodeJS开启多线程和集群 |
NodeJS开启多线程和集群
|
我们都知道 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() 方法衍生 参数 下面是Nodejs中文网站*child_process.fork参数介绍
新建三个文件 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('/userinfo', (req, res) => { res.json({ name: '自夏', msg: '我在自夏 selfsummer' }) }) app.listen(4000, () => { console.log(`子服务启动成功`); }) serve.js 先创建Express 多线程 服务 const { fork } = require("child_process"), express = require("express"), //Express框架 app = express(); const { pid, ppid } = require('process') // api 先关接口 app.all('/123', (req, res, next) => { console.log(`本次进程id为: ${ pid}`); res.end(`本次进程id为: ${ pid}`) }) app.all('/456', (req, res, next) => { console.log(`本次进程id为: ${ pid}`); res.end(`本次进程id为: ${ pid}`) }) app.listen(3888, () => { console.log(`服务器端启动成功 父进程 ${ ppid} 当前服务进程id为 ${ pid}`); // 开启多进程 fork('extensionServer.js') }) module.exports = { app, express, };启动服务 这个时候主服务和自服务都启动好了
访问 Express 主服务 以及子服务地址都可成功 cluster.js 把Express 服务改为集群使用 cluster集群模块开启多线程 const os = require('os'); const cluster = require('cluster'); 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 console.log(`进程号 #${ worker.id} 已断开`); }); // 意外退出进程 cluster.on('exit', (worker, code, signal) => { cluster.fork(); }); } else { // 引用Express主服务 开启主进程 require('./server') }启动集群服务 node cluster 当然也可以在集群里面继续开子进程 访问二次（一个浏览器访问，一个Postman 访问）后接口 为什么会有多个 服务器端启动成功 当前服务进程id为 xxx 应为 cluster 模块在 当前主进程下面衍生子进程，每一个子进程是基于主进程的所有 衍生新的进程，进程之间是相互独立的，每个进程都有自己的 V8 实例、内存，系统资源是有限的，不建议衍生太多的子进程出来，通长根据系统* CPU 核心数*设置 前面我们有判断是否是有主进程 如果有主进程就 使用 cluster 模块 开启 子进程 没有就开启进程 把Express 服务改为 默认http 服务只需要更改server.js 文件内容 const http = require('http') const { pid, ppid } = require('process') const server = http.createServer((req, res) => { res.end(router(req.url)) }) const router = (url) => { switch (url) { case '/132': return `进程${ pid} 很高兴为你服务`; case '/456': return `进程${ pid} 很高兴为你服务`; default: return `没有此接口` } } server.listen(3889, () => { console.log(`Server Started in process ${ pid}`); })依旧是启动 cluster.js（多线程服务文件） 版权声明 本文为[自夏]所创，转载请带上原文链接，感谢 https://blog.csdn.net/qq_39970857/article/details/120867009 |
【本文地址】
| 今日新闻 |
| 推荐新闻 |
| 专题文章 |