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 简化异步流程。

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

延迟 (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