Node/Express中间层API多调用异常：Promise.all()使用问题排查

问题根源 #

你的代码核心问题是混合使用回调式API、Promise和async/await，导致异步流程没有被正确串联，具体表现：

• createUserDir中使用fs.mkdir的回调版本，没有返回Promise，外层的.then()不会等待目录创建和后续的资产处理完成
• getAllAssetImages里的Promise.all只等待到utils.getAsset和fs.mkdir完成，但fs.writeFile和convertPPTS.convertPPTS是嵌套在回调里的异步操作，没有被纳入Promise链，导致Promise.all提前完成，直接返回了响应，后续转换操作还在运行时就去读取未生成的文件，抛出错误
• 错误处理不完整，回调中的错误没有传递到Promise链，无法被Express捕获

修正方案 #

1. 改用fs的Promise版本 #

Node.js 10+提供了fs.promises模块，所有回调式API都有对应的Promise版本，能直接配合async/await使用，避免回调嵌套。

2. 串联所有异步流程 #

确保每个异步操作（目录创建、文件下载、写入、转换）都被包裹进Promise，让Promise.all能等待每个资产的全流程完成，再返回响应。

3. 完善错误处理 #

将错误抛出，让Express的错误处理中间件捕获，避免静默失败。

修正后的完整代码 #

const fs = require('fs').promises; // 改用Promise版本的fs
const path = require('path');

const createUserDir = async (req, res) => {
  const userDir = path.join(__dirname, `../Users/${req.body.userID}`);
  // 等待用户目录创建完成
  await fs.mkdir(userDir, { recursive: true });
  // 等待所有资产处理完成
  await getAllAssetImages(req.body.assets, req.body.config, req.body.userID);
  // 所有流程完成后再返回响应
  res.send({ status: 200, body: 'assets available!' });
};

const getAllAssetImages = async (assets, config, userID) => {
  // 每个asset的处理流程都返回完整的Promise链
  const assetPromises = assets.map(async (asset) => {
    // 1. 下载资产文件
    const res = await utils.getAsset(asset, config);
    const assetDir = path.join(__dirname, `../Users/${userID}/${asset.assetId}`);
    const pptxPath = path.join(assetDir, `${asset.assetId}.pptx`);
    
    // 2. 创建资产子目录
    await fs.mkdir(assetDir, { recursive: true });
    // 3. 写入PPTX文件
    await fs.writeFile(pptxPath, res.data, { encoding: 'binary' });
    console.log(`File written successfully: ${pptxPath}`);
    
    // 4. 转换PPT为图片（等待转换完成）
    await convertPPTS.convertPPTS([pptxPath], assetDir);
  });

  // 等待所有资产的全流程处理完成
  await Promise.all(assetPromises);
  console.log('所有资产处理完成');
};

router.post('/', async (req, res, next) => {
  try {
    await createUserDir(req, res);
    console.log('all assets written');
  } catch (err) {
    // 把错误传递给Express的错误处理中间件
    next(err);
  }
});

export default { router };

关键改进点 #

• 用fs.promises替代回调式fs API，彻底消除回调嵌套，让async/await能正确等待每个操作
• createUserDir改为完全的async/await流程，确保目录创建和资产处理都完成后才返回响应
• getAllAssetImages中每个asset的处理都用async函数包裹，把下载、创建目录、写入文件、转换四个异步步骤全部用await串联，确保每个步骤完成后才进行下一步
• Promise.all等待所有asset的完整流程完成，而不是只等待下载和目录创建
• 路由处理中加入try/catch，捕获所有错误并传递给Express错误中间件，避免程序崩溃

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