Node.js：从第三方API回调中解析Promise的更优方案

你的场景是典型的「异步请求+Webhook通知」模式，原代码里最大的问题是没有处理axios.post返回的Promise，会导致未捕获的Promise拒绝（在Node.js环境下甚至可能引发进程崩溃），同时整个流程缺乏状态跟踪和错误容错机制。下面是更优的实现方案：

1. 完善初始接口的Promise错误处理 #

首先要把异步调用的Promise处理好，用async/await让代码更易读，同时捕获所有可能的异常（比如网络故障、存储服务拒绝请求等）：

// 生产环境建议用数据库存储状态，这里先用Map做示例
const requestStatus = new Map();

app.post('/create/:requestId', async (req, res) => {
  const { requestId } = req.params;
  
  try {
    // 调用存储API，确保请求本身能成功发送（即使对方返回202）
    const storeResponse = await axios.post('/store', { id: requestId });
    
    // 额外校验存储服务的响应状态，确保它真的接受了请求
    if (storeResponse.status !== 202) {
      throw new Error(`存储服务未接受请求，返回状态码: ${storeResponse.status}`);
    }

    // 给客户端返回202，明确告知请求已接受，后续等待Webhook通知
    res.status(202).json({
      message: "请求已提交，正在存储数据",
      requestId,
      tip: "可通过 GET /status/:requestId 查询存储进度"
    });

    // 初始化该请求的状态为「待处理」
    requestStatus.set(requestId, "pending");
  } catch (error) {
    // 统一处理所有错误，给客户端返回友好提示
    console.error(`提交存储请求失败: ${error.message}`);
    res.status(503).json({
      message: "暂时无法处理请求，请稍后重试",
      requestId,
      error: error.message
    });
  }
});

2. 实现Webhook的幂等性处理 #

存储服务会通过Webhook通知结果，这里必须保证接口的幂等性（防止重复通知导致状态混乱），同时验证请求合法性：

app.post('/webhook/store-complete', async (req, res) => {
  const { requestId, status, data } = req.body;
  
  // 🔴 关键：必须验证Webhook的合法性（比如校验签名，防止恶意请求）
  // 示例逻辑：假设存储服务会发送签名头，我们需要校验签名是否匹配
  // const signature = req.headers['x-store-service-signature'];
  // if (!verifySignature(signature, req.body)) {
  //   return res.status(403).send("Invalid request signature");
  // }

  // 处理未知的requestId
  if (!requestStatus.has(requestId)) {
    console.warn(`收到未知requestId的Webhook通知: ${requestId}`);
    return res.status(404).send("Unknown requestId");
  }

  // 处理重复通知（幂等性核心）：如果状态已经不是待处理，直接返回成功
  const currentStatus = requestStatus.get(requestId);
  if (currentStatus !== "pending") {
    console.info(`requestId ${requestId}已处理过，当前状态: ${currentStatus}`);
    return res.status(200).send("Already processed");
  }

  try {
    // 更新请求状态
    const newStatus = status === "success" ? "completed" : "failed";
    requestStatus.set(requestId, newStatus);
    
    // 这里可以添加后续业务逻辑：比如通过WebSocket推送结果给客户端、触发下游流程等
    if (newStatus === "completed") {
      console.log(`requestId ${requestId}存储成功，数据: ${JSON.stringify(data)}`);
    } else {
      console.error(`requestId ${requestId}存储失败`);
    }

    res.status(200).send("Status updated successfully");
  } catch (error) {
    console.error(`处理Webhook通知失败: ${error.message}`);
    res.status(500).send("Internal server error");
  }
});

3. 提供状态查询接口 #

给客户端一个查询入口，方便他们主动了解存储进度：

app.get('/status/:requestId', (req, res) => {
  const { requestId } = req.params;
  const status = requestStatus.get(requestId) || "unknown";
  
  res.json({
    requestId,
    status,
    description: {
      "pending": "正在存储中，请稍候",
      "completed": "数据存储成功",
      "failed": "数据存储失败，请重新提交",
      "unknown": "请求不存在或未提交"
    }[status]
  });
});

进阶优化建议 #

• 状态持久化：生产环境不要用内存Map，改用Redis（适合键值对快速查询）或者关系型数据库，避免服务器重启后状态丢失
• 超时处理：给「pending」状态的请求设置超时时间（比如1小时），超时后自动标记为「timeout」，并触发重试逻辑
• Promise链式替代：如果不习惯async/await，可以用.then().catch()链式处理，但可读性稍差：

  app.post('/create/:requestId', (req, res) => {
    const { requestId } = req.params;
    axios.post('/store', { id: requestId })
      .then(storeResponse => {
        if (storeResponse.status !== 202) throw new Error("存储服务未接受请求");
        requestStatus.set(requestId, "pending");
        res.status(202).json({ message: "请求已提交", requestId });
      })
      .catch(error => {
        console.error(error);
        res.status(503).json({ message: "请求失败", requestId });
      });
  });
  

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