发送响应并继续执行任务快递 |节点.js

Question

在 Node.js（我是新手）中，我在收到响应后尝试执行一系列任务。但是，我想让响应时间尽可能快。我不需要将这些任务的结果返回给客户端，所以我正在尝试立即返回响应。

我目前的实现大致是：

var requestTime = Date.now; 

app.post('/messages', function (req, res) {
  console.log("received request");

  // handle the response
  var body = res.body;
  res.send('Success');
  res.end();
  console.log("sent response");

  performComplexTasks(body)
})

function performComplexTasks(body){
   // perform data with body data here;
   console.log("finished tasks:", Date.now()-requestTime, "ms");
}

// -------LOG-----------
//    received request
//    POST /api/messages 200 3.685 ms - 59
//    sent response
//    finished tasks: 2500ms

发出请求的客户端似乎挂起，直到 performComplexTasks() 完成。 （POST 在 3.685 毫秒内完成，但响应需要 2500 毫秒才能完成。）

有没有办法在不让客户端等待/挂起的情况下立即发送响应并完成其他任务？ （在我的例子中，客户端不能进行多个 API 调用。）

Answer 1

如果您的工作不是超 CPU 密集型的，并且您可以容忍主服务器线程上的一些工作，那么只需使用 await 来中断执行，以便可以正确发送请求。您可以使用setTimeout 或await。

// This line is wrong too - ask a separate question if needed
var requestTime = Date.now; 

app.post('/messages', async function (req, res) {
  console.log("received request");

  // handle the response
  var body = res.body;
  res.status(200).send({ success: true });
  console.log("sent response");

  // Method 1:
  await performComplexTasks(body)

  // Method 2:
  setTimeout(() => performComplexTasks(body), 0);
})

async function performComplexTasks(body){
   // The line below is required if using the `await` method -
   // it breaks execution and allows your previous function to
   // continue, otherwise we will only resume the other function after
   // this function is completed.
   await new Promise(resolve => setTimeout(resolve, 1));

   // perform data with body data here;
   console.log("finished tasks:", Date.now()-requestTime, "ms");
}

这并不是一个很好的解决方案，您需要使用工作线程进行长时间操作。

Answer 2

您尝试在 performComplexTasks 中执行 CPU 密集型作业，我说得对吗？如果是这样，则事件循环被该任务锁定，并且新请求正在等待，直到作业完成。

在 node.js 中，在与 http 服务器相同的进程中执行此类“复杂”任务是一种不好的做法。考虑使用后台工作者、队列或类似的东西。

详见本主题：Node.js and CPU intensive requests