用CompletableFuture.allOf搭配exceptionally构建自愈型异步网关，核心是批量等待、异常不中断、逐个降级：allOf仅标识全部结束但不聚合结果或传播异常，须为每个子任务单独挂exceptionally提供fallback，再统一join取值并组装响应。
用 CompletableFuture.allOf 搭配 exceptionally 构建自愈型异步网关，核心在于：**批量任务统一等待 + 异常不中断流程 + 逐个恢复或降级**。它不是让整个请求因单个服务失败而垮掉，而是让网关具备“容错编排”能力。
allOf 的本质与关键限制
CompletableFuture.allOf 只表示“全部已结束”，不关心成功或失败；返回类型固定为 CompletableFuture，不聚合结果，也不传播异常。这意味着：
- 它不能直接拿到每个子任务的返回值，需额外收集原始 future 列表
- 任一子任务抛异常，
allOf对应的 future 仍会完成，但状态为“异常完成” -
isCompletedExceptionally()可快速判断是否有失败，但具体是哪个、什么错，得遍历原始 futures 调用getNow(null)或join()（后者会重抛异常）
exceptionally 的定位：兜底拦截，非全局捕获
exceptionally 只作用于它所挂载的那个 future。对 allOf 返回的 future 使用 exceptionally，只能捕获“allOf 自身构造或触发过程中的异常”（极少发生），**无法捕获其内部任意子任务的异常**。
真正起自愈作用的 exceptionally，必须提前挂在每一个原始子任务上：
- 每个异步调用（如
supplyAsync）都单独加exceptionally，提供默认值或 fallback 结果 - 这样即使某个下游服务超时或报错，该 future 仍能正常完成并返回备用数据，保证
allOf后续能稳定获取所有结果
构建自愈网关的典型结构
假设网关需并行调用用户服务、订单服务、积分服务三个接口：
- 定义统一响应包装类，如
Result，含data、success、errorCode - 对每个服务调用，用
supplyAsync(..., executor)+exceptionally封装成CompletableFuture> - 收集所有封装后的 future 到 list，再用
allOf等待全部结束 - 结束后遍历原始 list，用
join()安全取结果（此时不会再抛异常，因已被exceptionally处理过） - 最后组装聚合响应，统计成功数、标记哪些服务降级，供监控和告警
超时与线程池必须显式控制
生产环境中，allOf 后的 join() 或 get(timeout) 必须带超时，否则一个慢依赖会拖垮整个网关。同时：
- 避免使用
ForkJoinPool.commonPool()，尤其在 IO 场景下；应为网关配置专用线程池（如ThreadPoolTaskExecutor） - 线程池大小建议参考：CPU 核心数 ×（1 + 平均等待时间 / 平均工作时间），通常设为 20~50 之间，并启用队列拒绝策略
- 每个子任务的
supplyAsync都传入该线程池，确保资源可控、可监控
