NodeJS Express多异步完成时

Node.js Express 中处理多个异步操作的完成通常涉及到回调函数、Promises 或者 async/await 语法。下面我将详细介绍这些概念以及它们的优势、类型、应用场景，并提供示例代码来解决可能出现的问题。

基础概念

异步操作：在Node.js中，异步操作是指那些不会阻塞事件循环的操作，它们允许程序在等待某些操作完成时继续执行其他任务。

回调函数：回调函数是一种使异步操作完成后能够执行特定代码的机制。

Promises：Promises 是一种更现代的处理异步操作的方式，它们代表了一个尚未完成的操作的结果，可以以成功（fulfilled）或失败（rejected）结束。

async/await：这是基于Promises的语法糖，使得异步代码看起来更像同步代码，提高了代码的可读性和可维护性。

优势

非阻塞I/O：Node.js的非阻塞特性允许服务器处理大量并发请求。
事件驱动：通过事件循环机制，Node.js可以高效地处理异步操作。
提高性能：异步编程模型可以提高应用程序的响应性和吞吐量。

类型

并行执行：多个异步操作同时开始，不等待前一个完成。
串行执行：一个异步操作完成后才开始下一个。
混合执行：某些操作并行，某些操作串行。

应用场景

Web服务器：处理HTTP请求时，通常需要执行数据库查询或其他I/O操作。
实时应用：如聊天应用或游戏服务器，需要处理大量的并发连接和消息传递。
批处理作业：需要按顺序或并行执行多个任务的任务调度系统。

示例代码

使用回调函数

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

app.get('/async', (req, res) => {
  asyncOperation1((err, result1) => {
    if (err) return res.status(500).send(err);
    asyncOperation2(result1, (err, result2) => {
      if (err) return res.status(500).send(err);
      res.send(result2);
    });
  });
});

function asyncOperation1(callback) {
  // 模拟异步操作
  setTimeout(() => callback(null, 'result1'), 1000);
}

function asyncOperation2(input, callback) {
  // 模拟异步操作
  setTimeout(() => callback(null, input + ' result2'), 1000);
}

app.listen(3000, () => console.log('Server running on port 3000'));

使用Promises

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

app.get('/async', (req, res) => {
  asyncOperation1()
    .then(result1 => asyncOperation2(result1))
    .then(result2 => res.send(result2))
    .catch(err => res.status(500).send(err));
});

function asyncOperation1() {
  return new Promise((resolve) => {
    setTimeout(() => resolve('result1'), 1000);
  });
}

function asyncOperation2(input) {
  return new Promise((resolve) => {
    setTimeout(() => resolve(input + ' result2'), 1000);
  });
}

app.listen(3000, () => console.log('Server running on port 3000'));

使用async/await

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

app.get('/async', async (req, res) => {
  try {
    const result1 = await asyncOperation1();
    const result2 = await asyncOperation2(result1);
    res.send(result2);
  } catch (err) {
    res.status(500).send(err);
  }
});

function asyncOperation1() {
  return new Promise((resolve) => {
    setTimeout(() => resolve('result1'), 1000);
  });
}

function asyncOperation2(input) {
  return new Promise((resolve) => {
    setTimeout(() => resolve(input + ' result2'), 1000);
  });
}

app.listen(3000, () => console.log('Server running on port 3000'));