Promise中集成超时熔断需解耦超时控制与状态管理，用独立熔断器对象维护状态、计数、时间戳等，再通过工厂函数组合请求、熔断器和超时逻辑，并支持降级、半开试探及AbortController中断。
在 Promise 中集成复杂的超时熔断逻辑，核心是把「超时控制」和「熔断状态管理」解耦，再通过 Promise 链或 async/await 组合起来。不能只靠 setTimeout 简单拒绝，而要支持可重置、失败计数、半开状态、恢复策略等——这已超出原生 Promise 能力，需借助外部状态 + 封装函数实现。
用独立熔断器对象管理状态
Promise 本身无状态记忆能力，所以要把熔断逻辑抽成类或闭包，维护：
• 当前状态（关闭 / 打开 / 半开）
• 失败次数、窗口时间、阈值
• 下次允许尝试的时间戳（用于打开→半开过渡）
• 可选的降级回调和恢复检测机制
例如：
class CircuitBreaker {
constructor(options = {}) {
this.state = 'CLOSED'; // 'CLOSED' | 'OPEN' | 'HALF_OPEN'
this.failureThreshold = options.failureThreshold ?? 5;
this.timeoutMs = options.timeoutMs ?? 10000;
this.resetTimeoutMs = options.resetTimeoutMs ?? 60000;
this.failureCount = 0;
this.lastFailureTime = 0;
}
<p>canCall() {
if (this.state === 'CLOSED') return true;
if (this.state === 'OPEN') {
if (Date.now() - this.lastFailureTime > this.resetTimeoutMs) {
this.state = 'HALF_OPEN';
return true;
}
return false;
}
return this.state === 'HALF_OPEN';
}</p><p>recordSuccess() {
this.failureCount = 0;
this.state = 'CLOSED';
}</p><p>recordFailure() {
this.failureCount++;
this.lastFailureTime = Date.now();
if (this.failureCount >= this.failureThreshold) {
this.state = 'OPEN';
}
}
}</p>封装带熔断+超时的 Promise 工厂函数
把原始请求函数、熔断器实例、超时逻辑三者组合，返回一个可调用的 Promise 包装函数：
立即学习“Java免费学习笔记（深入）”；
- 每次调用先检查
canCall()，不通过则立即 reject（可带降级逻辑） - 通过后启动带超时的 Promise：用
Promise.race([original, timeout])控制响应时限 - 成功时调用
recordSuccess()，失败时调用recordFailure() - 支持传入自定义降级值（fallback），在熔断或超时时直接 resolve 它
示例：
function withCircuitBreaker(cb, breaker, fallback) {
return async function(...args) {
if (!breaker.canCall()) {
return fallback !== undefined ? fallback : Promise.reject(new Error('CIRCUIT_OPEN'));
}
<pre class='brush:php;toolbar:false;'>const timeout = new Promise((_, reject) =>
setTimeout(() => reject(new Error('TIMEOUT')), breaker.timeoutMs)
);
try {
const result = await Promise.race([
cb(...args),
timeout
]);
breaker.recordSuccess();
return result;
} catch (err) {
breaker.recordFailure();
if (fallback !== undefined && breaker.state !== 'OPEN') {
return fallback;
}
throw err;
}}; }
// 使用 const breaker = new CircuitBreaker({ failureThreshold: 3, resetTimeoutMs: 30000 }); const guardedApi = withCircuitBreaker(fetchUser, breaker, { id: -1, name: 'offline' });
处理半开状态下的试探性请求
当熔断器进入 HALF_OPEN，只允许一个请求“探路”。若成功，恢复服务；若失败，重置倒计时并保持 OPEN。这需要在 canCall() 和 recordSuccess/failure 中协同控制：
- 加一个
isAllowedToTry标志位，仅在 HALF_OPEN 且未被占用时设为 true - 执行前原子性地获取许可（可用简单锁变量或
tryAcquire模拟） - 无论成功失败，执行后清空许可，避免并发试探
不必引入完整锁机制，用一个布尔字段 + 条件判断即可满足大多数场景。
配合 AbortController 实现请求级中断（可选增强）
对于 fetch 或支持 signal 的 API，超时不应只靠 race 拒绝 Promise，还要真正中止网络请求，避免资源浪费：
- 在 race 超时分支中调用
abortController.abort() - 将
signal传入 fetch 等原生方法 - 注意：AbortError 是合法 rejection，需与业务错误区分，避免误触发熔断
例如：
const controller = new AbortController();
const timeoutId = setTimeout(() => controller.abort(), breaker.timeoutMs);
<p>try {
const res = await fetch(url, { signal: controller.signal });
clearTimeout(timeoutId);
return res.json();
} catch (err) {
if (err.name === 'AbortError') throw new Error('TIMEOUT');
throw err;
}</p>不复杂但容易忽略的是：熔断器必须是共享实例（比如单例或按服务维度复用），否则每个请求新建一个就完全失效；超时和熔断的错误类型也要明确区分，避免把超时当成业务异常反复计入失败计数。
