API 请求条件式重试机制：实现与优化-js教程-PHP中文网

api 请求条件式重试机制：实现与优化

本文深入探讨了在 Node.js 环境下，如何利用 axios 实现对 API 请求的条件式重试机制。我们将从基础的递归重试方案入手，逐步引入延迟、最大重试次数和异步处理等概念，构建一个健壮且实用的重试函数。文章还将涵盖指数退避、熔断器等高级优化策略，旨在帮助开发者有效应对网络波动、异步操作等场景，确保系统稳定性和数据一致性。

引言：API 请求重试机制的必要性

在分布式系统和微服务架构中，应用程序通过网络调用外部 API 是常态。然而，网络环境的不稳定、服务瞬时过载、异步任务处理时间不确定等因素，都可能导致 API 请求失败或返回非最终状态。为了提高系统的鲁棒性和用户体验，实现一个智能的 API 请求重试机制显得尤为重要。特别是在需要轮询一个异步任务状态直至其完成的场景中，条件式重试更是不可或缺。

场景分析：轮询 API 直至特定状态

考虑这样一个场景：我们向一个文档处理服务发起请求，该服务会返回一个处理中的状态，并需要我们持续查询其状态，直到 response.data.status 字段的值变为 "done"。这要求我们的客户端代码能够：

发起初始请求。
检查响应状态。
如果状态不是 "done"，则等待一段时间后再次发起相同的请求。
重复步骤 2 和 3，直到状态满足条件或达到最大重试次数。

基础重试实现与局限性

最初的重试思路可能非常直接，例如使用递归函数。以下是一个基于 axios 的简化递归重试示例：

const axios = require("axios");
const qs = require("qs");

// 假设 apiKey 已定义
const apiKey = "YOUR_API_KEY"; 

let data = qs.stringify({
  document_key: "038A2E0792CE72020E9BB88380D002EB582A6B3AE5883C34DE53C9F17D415D99",
});

let config = {
  method: "post",
  maxBodyLength: Infinity,
  url: "https://api-free.deepl.com/v2/document/95BA71197AC66EE4745FF5269CF4399D",
  headers: {
    Authorization: apiKey,
    "Content-Type": "application/x-www-form-urlencoded",
  },
  data: data,
};

function retryUntilSuccess(requestConfig, callback) {
  axios
    .request(requestConfig)
    .then((response) => {
      // 检查特定条件
      if (response.data.status === "done") {
        console.log("任务完成:", response.data.status);
        callback(null, response.data); // 任务完成，返回结果
      } else {
        console.log("任务进行中，继续重试:", response.data.status);
        // 未完成，继续重试
        retryUntilSuccess(requestConfig, callback);
      }
    })
    .catch((error) => {
      console.error("请求失败，继续重试:", error.message);
      // 请求失败，直接重试
      retryUntilSuccess(requestConfig, callback);
    });
}

// 调用重试函数
// retryUntilSuccess(config, function(err, result) {
//   if (err) {
//     console.error("最终失败:", err);
//   } else {
//     console.log("最终成功结果:", result);
//   }
// });

这种基础实现存在几个显著局限性：

无延迟重试： 请求失败或状态未满足时会立即重试，可能导致服务器压力增大，或在瞬时故障时无法恢复。
无最大重试次数限制： 如果服务持续不可用或任务长时间未完成，程序会陷入无限重试循环，消耗资源并可能导致栈溢出。
错误处理不完善： 没有区分可重试错误和不可重试错误，所有错误都一概重试。
回调地狱： 使用回调函数可能导致代码可读性下降，尤其是在复杂逻辑中。

构建健壮的 API 重试策略

为了克服上述局限性，我们需要一个更完善的重试策略，包括引入延迟、设置最大重试次数以及利用 async/await 简化异步流程。

多奥淘宝客程序API免费版 F8.0

多奥淘宝客程序免费版拥有淘宝客站点的基本功能，手动更新少，管理简单等优点，适合刚接触网站的淘客们，或者是兼职做淘客们。同样拥有VIP版的模板引擎技术、强大的文件缓存机制，但没有VIP版的伪原创跟自定义URL等多项创新的搜索引擎优化技术，除此之外也是一款高效的API数据系统实现无人值守全自动化运行的淘宝客网站程序。4月3日淘宝联盟重新开放淘宝API申请，新用户也可使用了

下载

核心原理：延迟与最大重试次数

延迟 (Delay)： 在每次重试之间引入一个等待时间，给服务器或网络一个恢复的机会。
最大重试次数 (Max Retries)： 设置一个上限，防止无限重试，确保程序最终能够退出或报告失败。

代码示例：异步重试函数

以下是一个采用 async/await、支持延迟和最大重试次数的通用重试函数：

const axios = require("axios");
const qs = require("qs");

// 假设 apiKey 已定义
const apiKey = "YOUR_API_KEY"; 

let data = qs.stringify({
  document_key: "038A2E0792CE72020E9BB88380D002EB582A6B3AE5883C34DE53C9F17D415D99",
});

let config = {
  method: "post",
  maxBodyLength: Infinity,
  url: "https://api-free.deepl.com/v2/document/95BA71197AC66EE4745FF5269CF4399D",
  headers: {
    Authorization: apiKey,
    "Content-Type": "application/x-www-form-urlencoded",
  },
  data: data,
};

/**
 * 异步延迟函数
 * @param {number} ms - 延迟毫秒数
 */
const delay = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

/**
 * 执行带重试机制的 API 请求
 * @param {object} requestConfig - axios 请求配置
 * @param {function} conditionFn - 判断是否成功的函数，接收响应数据作为参数，返回布尔值
 * @param {object} options - 重试选项
 * @param {number} [options.maxRetries=5] - 最大重试次数
 * @param {number} [options.initialDelayMs=1000] - 初始重试延迟（毫秒）
 * @param {number} [options.backoffFactor=2] - 延迟因子，用于指数退避
 * @returns {Promise