Node.js中先发客户端响应再执行耗时操作的最优方案

你遇到的问题其实是Node.js单线程事件循环的特性导致的——你的longAction是同步阻塞的代码，哪怕你先调用了res.send(html)，Node.js的主线程会先把当前同步代码块（包括后面的longAction循环）执行完，才会去处理响应的发送逻辑，所以客户端必须等循环结束才能收到响应。

下面给你几种可行的方案，按场景优先级推荐：

1. 轻量同步耗时操作：用setImmediate() #

这是最直接的解决方式，把耗时操作放到setImmediate的回调里，它会让代码在当前事件循环的I/O阶段完成后（也就是响应已经发送给客户端之后）再执行，不会阻塞响应的发送。

代码示例：

const express = require('express');
const app = express();

app.get('/', (req, res) => {
  const html = '<h1>Hello World</h1>';
  // 先发送响应
  res.send(html);

  // 把耗时操作放到setImmediate里，让它在响应发送后执行
  setImmediate(() => {
    longAction();
  });
});

function longAction() {
  for (let i = 0; i < 1000000000; i++) {}
  console.log('Finish');
}

app.listen(3000);

2. 重型计算/耗时操作：用Worker Threads #

如果你的longAction是非常消耗CPU的重型计算，哪怕用setImmediate，它还是会占用主线程，导致其他请求被阻塞。这种情况下，最好把耗时操作放到单独的线程里执行，用Node.js自带的worker_threads模块就可以实现：

主文件代码 #

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

app.get('/', (req, res) => {
  const html = '<h1>Hello World</h1>';
  res.send(html);

  // 创建一个新的Worker线程来执行耗时操作
  const worker = new Worker('./longActionWorker.js');
  
  // 监听Worker的消息
  worker.on('message', (message) => {
    console.log(message); // 输出"Finish"
  });
  
  // 监听Worker的错误
  worker.on('error', (err) => {
    console.error('Worker出错:', err);
  });
});

app.listen(3000);

单独的Worker文件（longActionWorker.js） #

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

function longAction() {
  for (let i = 0; i < 1000000000; i++) {}
  console.log('Finish');
  // 向主线程发送完成消息
  parentPort.postMessage('Finish');
}

longAction();

这种方式下，重型计算在单独的线程里运行，主线程可以继续处理其他请求，不会影响服务的整体性能。

额外说明 #

• 如果你的耗时操作本身就是异步的（比如数据库查询、文件读写），那不需要额外处理，直接在res.send之后调用就行——因为异步操作不会阻塞主线程，Node.js会在操作完成后再执行回调。
• 不要用setTimeout来实现，虽然它也能把代码延后执行，但setImmediate是专门为这种"当前操作完成后尽快执行但不阻塞I/O"的场景设计的，比setTimeout更可靠。

内容的提问来源于stack exchange，提问作者Boba Fett likes JS