Node.js Web服务器密集计算时无响应的问题及解决方案咨询

为什么服务器在calculate执行时无法响应请求？ #

Node.js是单线程事件循环模型，事件循环只有在当前执行栈完全清空后，才会去处理回调队列里的任务（比如HTTP请求、定时器回调等）。

你代码里的calculate()虽然返回了Promise，但Promise的执行器函数是同步执行的——里面的三个大循环（生成随机数数组、深拷贝对象、排序数组）都是连续的同步阻塞操作，会一直霸占主线程直到全部执行完毕。这期间事件循环完全没机会切换到处理网络请求的阶段，所以服务器没法响应任何请求。

事件循环不会“主动暂停”正在运行的同步代码，它只能等当前执行栈的所有同步代码跑完，才会开启下一轮任务处理。

如何保证密集计算时的服务响应性？ #

1. 拆分大任务为小批次，主动让出事件循环 #

把长时间运行的同步任务拆成多个小批次，每次只执行一部分，然后用setImmediate把剩余任务放到下一轮事件循环中执行，给主线程留出处理HTTP请求的间隙。

修改后的calculate函数示例：

function calculate() {
  return new Promise((res, rej) => {
    let payload = [];
    let msgArr = [];
    let max = 10000;
    
    // 生成随机数数组（这部分耗时较短，可直接执行）
    for (var i = 0; i < max; i++) {
        let rand = Math.floor(Math.random() * max);
        payload.push(rand);
    }
    let msg = { payload };
    for (var i = 0; i < max; i++) {
        let msgCopy = JSON.parse(JSON.stringify(msg));
        msgArr.push(msgCopy);
    }
    
    const batchSize = 100; // 每次处理100个任务
    let currentIndex = msgArr.length - 1;

    function processBatch() {
      const end = Math.max(currentIndex - batchSize, -1);
      while (currentIndex > end) {
        msgArr[currentIndex].payload.sort();
        console.log(`Remaining: ${currentIndex}`);
        currentIndex--;
      }
      if (currentIndex >= 0) {
        setImmediate(processBatch); // 让出事件循环，优先处理其他任务
      } else {
        res();
      }
    }

    processBatch();
  });
}

2. 使用Worker Threads（推荐方案） #

Node.js的worker_threads模块可以把密集计算放到单独的线程中执行，主线程只专注处理HTTP请求，两者互不阻塞。

步骤1：抽离计算逻辑到单独文件（calculation-worker.js）

const { parentPort } = require('worker_threads');

parentPort.on('message', () => {
  let payload = [];
  let msgArr = [];
  let max = 10000;
  
  for (var i = 0; i < max; i++) {
      let rand = Math.floor(Math.random() * max);
      payload.push(rand);
  }
  let msg = { payload };
  for (var i = 0; i < max; i++) {
      let msgCopy = JSON.parse(JSON.stringify(msg));
      msgArr.push(msgCopy);
  }
  
  let msgLen = msgArr.length;
  while (msgLen--) {
    msgArr[msgLen].payload.sort();
    console.log(`Remaining: ${msgLen}`);
  }
  parentPort.postMessage('done');
});

步骤2：主线程中调用Worker

const express = require('express');
const app = express();
const port = 3000;
const { Worker } = require('worker_threads');

function calculate() {
  return new Promise((res, rej) => {
    const worker = new Worker('./calculation-worker.js');
    worker.on('message', () => {
      worker.terminate();
      res();
    });
    worker.on('error', rej);
    worker.postMessage('start');
  });
}

app.get('/', (req, res) => {
  res.send('Hello World!')
});

app.listen(port, () => {
  console.log(`Example app listening on port ${port}`);
  calculate();
});

3. 使用Cluster模块（多核CPU场景） #

如果服务器是多核CPU，可以用cluster模块创建多个子进程，让每个CPU核都参与任务处理，充分利用硬件资源。这种方式更适合高并发请求场景，单个密集计算任务用Worker Threads更轻量。

内容的提问来源于stack exchange，提问作者ojek