JavaScript 中怎么用 Promise 实现一个带有限流重试的异步工具类-js教程-PHP中文网

promise实现的asynclimiter类支持限流（队列+并发计数）与重试（指数退避），add方法添加任务并自动调度，next释放槽位，二者正交组合。

javascript 中怎么用 promise 实现一个带有限流重试的异步工具类

用 Promise 实现带限流和重试的异步工具类，核心是封装请求逻辑，控制并发数（限流）+ 失败后按策略重试（指数退避更稳妥）。下面是一个轻量、可复用的实现。

限流：用队列 + 并发计数控制同时执行数

不依赖外部库，靠一个运行中计数器 running 和等待队列 queue 实现。每次任务开始前检查是否已达最大并发；未达则立即执行，否则入队，等有空位时从队列里取下一个。

关键点：

每个任务包装成 Promise，并在 resolve/reject 后调用 next() 释放槽位
next() 负责检查队列是否有待执行任务，有则取出并运行
限流只作用于“发起”，不影响重试内部的串行逻辑

重试：封装单次请求 + 可配置的重试策略

把原始异步函数（如 fetch）包一层，支持传入最大重试次数、基础延迟、是否启用指数退避。每次失败后计算下次延迟，用 setTimeout + Promise 模拟等待。

示例重试逻辑片段：

const retry = async (fn, options = {}) => {
  const { maxRetries = 3, baseDelay = 100, exponential = true } = options;
  let lastError;
<p>for (let i = 0; i </p><pre class="brush:php;toolbar:false;">  const delay = exponential ? baseDelay * Math.pow(2, i) : baseDelay;
  await new Promise(r => setTimeout(r, delay));
}

}

javascript-pro

专注现代 ECMAScript、异步编程、性能优化和全栈的 JavaScript 专家，适用于现代开发

下载

throw lastError; };

组合限流与重试：创建 AsyncLimiter 类

将两者结合，暴露 add() 方法添加任务，返回 Promise；内部自动调度并发 + 为每个任务独立应用重试策略。

使用示例：

class AsyncLimiter {
  constructor(maxConcurrency) {
    this.max = maxConcurrency;
    this.running = 0;
    this.queue = [];
  }
<p>add(asyncFn, retryOptions) {
return new Promise((resolve, reject) => {
const task = async () => {
try {
const result = await retry(asyncFn, retryOptions);
resolve(result);
} catch (err) {
reject(err);
}
};</p><pre class="brush:php;toolbar:false;">  this.queue.push({ task, resolve, reject });
  this.next();
});

}

next() { if (this.running 0) { this.running++; const { task } = this.queue.shift(); task().finally(() => { this.running--; this.next(); }); } } }

// 使用 const limiter = new AsyncLimiter(2); // 最多同时跑 2 个

const requests = urls.map(url => limiter.add( () => fetch(url).then(r => r.json()), { maxRetries: 2, baseDelay: 200 } ) );

Promise.all(requests).then(console.log).catch(console.error);