for循环中的API调用

基础概念

在for循环中进行API调用是指在循环结构中执行异步或同步的网络请求操作。这是一种常见的编程模式，用于批量处理数据或获取多个资源。

常见类型

同步API调用：循环会等待每个API调用完成后再继续
异步API调用：循环不会等待API调用完成，可能并行发送多个请求
带并发控制的异步调用：限制同时进行的API调用数量

应用场景

批量获取用户信息
数据迁移或ETL处理
批量更新数据库记录
爬虫程序中的页面抓取
批量发送通知或消息

常见问题及解决方案

问题1：API速率限制

原因：短时间内发送过多请求触发了API提供方的限制

解决方案：

// 使用延迟或并发控制
async function processWithRateLimit(items, apiCall, delay = 200) {
  for (const item of items) {
    try {
      await apiCall(item);
      await new Promise(resolve => setTimeout(resolve, delay));
    } catch (error) {
      console.error(`Error processing ${item}:`, error);
    }
  }
}

问题2：循环中的异步调用顺序混乱

原因：异步调用不保证完成顺序

解决方案：

// 使用Promise.all确保所有调用完成
async function processInParallel(items, apiCall) {
  const promises = items.map(item => apiCall(item));
  return await Promise.all(promises);
}

问题3：内存泄漏

原因：未正确处理API响应导致内存无法释放

解决方案：

// 确保正确处理响应和错误
async function safeApiLoop(items, apiCall) {
  const results = [];
  for (const item of items) {
    try {
      const response = await apiCall(item);
      results.push(response);
      // 明确删除不再需要的大对象
      response.data = null;
    } catch (error) {
      console.error('API call failed:', error);
    }
  }
  return results;
}

最佳实践示例

// 带并发控制和错误处理的API循环调用
async function batchApiCalls(items, apiCall, concurrency = 5) {
  const results = [];
  const queue = [...items];
  
  async function worker() {
    while (queue.length > 0) {
      const item = queue.shift();
      try {
        const result = await apiCall(item);
        results.push(result);
      } catch (error) {
        console.error(`Failed to process ${item}:`, error);
        results.push({ error, item });
      }
    }
  }
  
  const workers = Array(concurrency).fill().map(worker);
  await Promise.all(workers);
  return results;
}