如何在Express应用中用worker_threads处理请求响应，释放主线程

核心思路 #

worker_threads无法直接操作主线程的req/res对象（即使传递结构化克隆版本，也只是数据副本，无法直接调用res.send()这类方法），所以可行的模式是：

• 主线程接收请求后，提取请求中的结构化数据（比如req.body、req.query、req.params、请求头等）
• 创建worker线程，将这些纯数据传给worker
• worker独立处理业务逻辑，把处理结果发回主线程
• 主线程收到结果后，用原res对象给客户端返回响应
• 主线程在worker处理期间会立即空闲，可继续接收新请求

具体实现代码 #

1. 主线程（Express入口文件） #

const express = require('express');
const { Worker } = require('worker_threads');
const path = require('path');

const app = express();
app.use(express.json());

app.post('/process', (req, res) => {
  // 提取需要传给worker的结构化请求数据
  const requestData = {
    body: req.body,
    query: req.query,
    params: req.params,
    headers: req.headers
    // 按需添加其他需要的请求字段
  };

  // 为当前请求创建新的worker线程
  const worker = new Worker(path.resolve(__dirname, 'worker.js'), {
    workerData: requestData
  });

  // 接收worker处理后的结果并响应客户端
  worker.on('message', (result) => {
    res.status(result.statusCode || 200).json(result.data);
    worker.terminate(); // 处理完成后销毁线程，避免内存泄漏
  });

  // 处理worker执行异常
  worker.on('error', (err) => {
    res.status(500).json({ error: err.message });
    worker.terminate();
  });

  // 监听线程退出状态
  worker.on('exit', (code) => {
    if (code !== 0) {
      console.error(`Worker线程异常退出，代码：${code}`);
    }
  });

  // 主线程至此已完成当前请求的初始化，可立即接收下一个请求
});

const PORT = 3000;
app.listen(PORT, () => {
  console.log(`服务运行在端口 ${PORT}`);
});

2. Worker线程文件（worker.js） #

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

// 模拟耗时业务处理逻辑
function processRequest(data) {
  return new Promise((resolve) => {
    // 这里替换为实际的业务代码：比如数据库查询、复杂计算等
    setTimeout(() => {
      resolve({
        statusCode: 200,
        data: {
          message: '请求处理完成',
          receivedRequestData: data
        }
      });
    }, 2000); // 模拟2秒耗时操作
  });
}

// 执行处理并将结果发回主线程
processRequest(workerData)
  .then(result => parentPort.postMessage(result))
  .catch(err => parentPort.postMessage({
    statusCode: 500,
    data: { error: err.message }
  }));

关键注意事项 #

• 禁止直接传递req/res对象：req和res包含底层TCP套接字句柄和Express内部状态，结构化克隆会丢失这些关键信息，必须只传递纯数据。
• 线程生命周期管理：每个请求对应的worker线程处理完成后，务必调用worker.terminate()销毁线程，防止内存泄漏。
• 异常处理：必须监听worker的error和exit事件，避免线程异常导致主线程阻塞或资源泄漏。

和Cluster模式的区别 #

• Cluster是多进程模式，每个进程拥有独立的Event Loop，适合CPU密集型任务，可充分利用多核CPU；
• Worker Threads是单进程内的多线程，线程间可共享内存（通过SharedArrayBuffer），适合IO密集型或需要共享内存的场景，主线程可专注于接收请求。

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