循环调用Node API向不支持批量插入的外部API传数据时遇Promise回调重复调用错误

兄弟，我太懂这个坑了！你遇到的这个错误，90%的概率是你的myAPIFunction里异步逻辑没处理干净——尤其是在循环调用外部API时，混用了回调式异步工具（比如async.js）和Promise，导致同一个回调被触发了多次。

问题根源 #

你要循环给不支持批量的外部API发请求，原myAPIFunction大概率犯了这两个错误之一：

• 在循环里多次调用了Promise的resolve/reject（比如每处理一个用户就resolve一次），而Promise的状态一旦变更就不能再改，重复触发就会抛出这个错误。
• 混用了回调式的循环方法（比如async.each）和Promise，同时调用了回调函数和Promise的resolve/reject，导致回调被重复执行。

正确的解决方案 #

别再混用回调和Promise了，统一用async/await或者纯Promise来处理异步循环，下面给你两种常用的实现方式：

1. 串行调用（适合外部API有频率限制的情况）

如果外部API怕被刷限流，就一个接一个发请求：

// 修复后的myAPIFunction
async function myAPIFunction(userArray) {
  const successResults = [];
  
  for (const user of userArray) {
    try {
      // 替换成你调用外部API的实际代码，比如axios/fetch/request
      const apiResponse = await fetch('https://your-external-api.com/users', {
        method: 'POST',
        body: JSON.stringify(user),
        headers: { 'Content-Type': 'application/json' }
      });

      if (!apiResponse.ok) {
        throw new Error(`请求失败，状态码：${apiResponse.status}，用户ID：${user.id}`);
      }

      const result = await apiResponse.json();
      successResults.push(result);
    } catch (err) {
      // 这里可以选择继续执行或者直接抛出错误终止流程
      throw new Error(`发送用户数据失败：${err.message}`);
    }
  }

  return successResults;
}

2. 并行调用（适合外部API无频率限制的情况）

如果API扛得住，就同时发起所有请求，效率更高：

async function myAPIFunction(userArray) {
  // 把每个用户的请求包装成独立的Promise
  const requestPromises = userArray.map(user => {
    return fetch('https://your-external-api.com/users', {
      method: 'POST',
      body: JSON.stringify(user),
      headers: { 'Content-Type': 'application/json' }
    }).then(response => {
      if (!response.ok) {
        throw new Error(`用户${user.id}请求失败，状态码：${response.status}`);
      }
      return response.json();
    });
  });

  // 等待所有请求完成，只要有一个失败就会触发catch
  return Promise.all(requestPromises);
}

错误写法示例（避坑） #

给你看看最容易踩的错误写法，你对照下原代码是不是犯了类似的错：

// ❌ 错误示例！别这么写
function myAPIFunction(userArray) {
  return new Promise((resolve, reject) => {
    // 用了async.each循环，但内部又手动调用了resolve/reject
    async.each(userArray, (user, callback) => {
      request.post('https://external-api.com/users', user, (err, res) => {
        if (err) {
          callback(err);
          reject(err); // 错误：同时调用了async的回调和Promise的reject，导致重复触发
        } else {
          callback(null, res);
          resolve(res); // 错误：循环里每次都resolve，Promise状态被重复修改
        }
      });
    }, (err, results) => {
      if (err) reject(err);
      else resolve(results);
    });
  });
}

核心原则就是：Promise的resolve和reject只能被调用一次，要么用纯Promise/async-await，要么用纯回调式工具，别混着来。

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