[Node.js] Child Process with fork() to handle heavy calculation process
2023-09-14 09:00:49 时间
When build server, if we have a API endpoint requires some heavy calculation process, it will block the whole world. In this post, we will see how to use 'child_process' fork() to solve the problem;
Let's see the blocking code example:
const http = require('http'); const longComputation = () => { let sum = 0; for (let i = 0; i < 1e9; i++) { sum += i; } return sum; } const server = http.createServer(); server.on('request', (req, res) => { if (req.url === '/compute') { const sum = longComputation(); return res.end(`Sum is ${sum}`); } else { res.end('Ok'); } })
When we request '/compute' API endpoint, because of 'longCompute', it blocks the world, no other request can go thought.
curl localhost:3000/compute
Let's see how to fix it:
1. We will create a compute.js to hold the 'longCompute' function and also listen to the 'message' event on the global:
// Compute.js const longComputation = () => { let sum = 0; for (let i = 0; i < 1e9; i++) { sum += i; } return sum; } // listen the mssage event on the global // then do the computation process.on('message', (msg) => { const sum = longComputation(); process.send(sum); })
2. In server.js, instead of calling 'longCompute' directly, we fork the compute.js;
Send signal to tell the compute file to start doing the job, then we also need to listen to the event come back after computation is done.
// start processing compute.send('start');
// listen to the message compute.on('message', sum => { res.end(`Sum is ${sum}`); });
Full code for server.js
const http = require('http'); const {fork} = require('child_process'); const server = http.createServer(); server.on('request', (req, res) => { if (req.url === '/compute') { const compute = fork('compute.js'); // start processing compute.send('start'); // listen to the message compute.on('message', sum => { res.end(`Sum is ${sum}`); }); } else { res.end('Ok'); } }); server.listen(3000)
相关文章
- js中settimeout和setinterval的区别是什么?
- Node.js中Process.nextTick()和setImmediate()的区别
- Node.js数据流Stream之Duplex流和Transform流
- [Node.js] Set the Node.js Project to ECMAScript Modules (ESM)
- [NPM] Use npx to run commands with different Node.js versions
- [Node.js] Add Logging to a Node.js Application using Winston
- [Node.js] Pass command line arguments to node.js
- [Whole Web] [Node.js] Using npm run to launch local scripts
- [Node.js]29. Level 6: Socket.io: Setting up Socket.io server-side & Client socket.io setup
- 关于JS中的constructor与prototype{转}
- [Node.js] process.nextTick for converting sync to async
- [Node.js] Add Logging to a Node.js Application using Winston
- [Node.js] Node Util Promisify - How to Convert Callback Based APIs to Promise-based
- [Node.js] Pass command line arguments to node.js
- [Node.js] Using npm link to use node modules that are "in progress"
- [Node.js]24. Level 5: Express, Express routes
- Node.js 应用访问 https 服务器时遇到的错误消息 unable to get local issuer certificate
- Node.js学习笔记——包管理工具