promisepool 通过维护运行中请求数组实现并发控制,不超过上限时发起新请求,否则排队;可借助 promise-pool-executor 库或手写简易版,设定最大并发数(如 3)并跟踪当前运行中的 promise。

用 PromisePool 控制并发请求数量
Fetch 本身不提供限流能力,但可以通过封装 Promise 来实现固定数量的并发执行。核心思路是维护一个“运行中请求数”,不超过上限时才发起新请求,否则排队等待。
推荐使用轻量库 promise-pool-executor 或手写简易版:
- 定义最大并发数(如 3),初始化一个空的 Promise 数组 tracking 当前运行中的请求
- 每次调用 fetch 时,先检查 running.length
- 每个 fetch 完成后从 running 中移除,触发下一个排队任务
手动实现队列 + 并发控制(无第三方依赖)
适合不想引入额外包的场景。关键在于把请求包装为可调度的 task,并用 async/await + 闭包管理状态:
class FetchQueue {
constructor(max = 3) {
this.max = max;
this.running = 0;
this.queue = [];
}
<p>add(url, options = {}) {
return new Promise((resolve, reject) => {
this.queue.push({ url, options, resolve, reject });
this.process();
});
}</p><p>async process() {
if (this.running >= this.max || this.queue.length === 0) return;
this.running++;
const { url, options, resolve, reject } = this.queue.shift();
try {
const res = await fetch(url, options);
resolve(res);
} catch (err) {
reject(err);
} finally {
this.running--;
this.process(); // 尝试处理下一个
}
}
}</p>
用法:const queue = new FetchQueue(2); queue.add('/api/a').then(...)
结合 AbortController 实现超时与取消排队请求
队列中的请求可能长时间等待,需支持主动取消或设置整体超时:
- 给每个 task 添加 signal 字段,在入队时创建 AbortController,超时后调用 controller.abort()
- fetch 调用时传入 signal: controller.signal,这样未发出的请求可在等待阶段被中断
- 注意:已进入 process 并开始 fetch 的请求仍会执行,但响应后会被忽略(靠 resolve/reject 状态判断是否已处理)
错误重试 + 指数退避(增强健壮性)
限流队列中加入失败重试逻辑,避免单点失败阻塞整个队列:
- 在 fetch catch 块中判断错误类型(如网络错误、503),满足条件则延迟后重新 add 到队列末尾
- 记录尝试次数,超过阈值(如 3 次)才 reject
- 延迟时间可用指数退避:Math.min(1000 * 2 ** attempt, 10000)
大量免费API接口:立即使用
涵盖生活服务API、金融科技API、企业工商API、等相关的API接口服务。免费API接口可安全、合规地连接上下游,为数据API应用能力赋能!











