本文介绍如何在 quarkus 中基于运行时提供的服务列表，动态并发调用多个独立 rest 接口，容错处理失败请求，并统一聚合响应结果返回给客户端。
本文介绍如何在 quarkus 中基于运行时提供的服务列表，动态并发调用多个独立 rest 接口，容错处理失败请求，并统一聚合响应结果返回给客户端。
在 Quarkus 应用中实现「按需并发调用 N 个异构 REST API」是一个典型场景：请求体携带动态 provider 列表（如 ["weather", "news", "currency"]），每个 provider 对应一个专用客户端和端点，需并行发起调用、容忍单点失败、最终合并所有成功响应。关键挑战在于避免硬编码调用链，而是根据输入参数动态构建执行流。
Quarkus 原生集成 Mutiny（响应式编程库），其 Uni.combine().all().unis(...) 是并行组合多个 Uni<t></t> 的标准方式。但如问题所述，unis(...) 接收的是可变参数列表，无法直接传入 List<uni>></uni> —— 我们需借助 Stream + collect() 或 Multi 转换为数组。以下是推荐的生产级实现：
基于夸克网盘自动转存项目 QAS 的懒人追剧、追番 SKILL，内置 CLI 工具。即使 QAS 订阅失效，仍可重新搜索资源、遍历多级目录，在多个最新候选中按用户偏好（如更高清晰度）转存新集和缺失集。可交由本地 OpenClaw、Hermes Agent 或其他 Claude 客户端使用。
✅ 正确的动态并行调用模式
import io.smallrye.mutiny.Uni;
import io.smallrye.mutiny.tuples.Tuple2;
import io.smallrye.mutiny.tuples.Tuple3;
import java.util.List;
import java.util.stream.Collectors;
public class ApiOrchestrator {
// 根据 provider 名称动态选择并触发对应 Uni 调用
private Uni<Object> callProvider(String provider, String requestParam) {
return switch (provider.toLowerCase()) {
case "weather" -> weatherClient.getForecast(requestParam).onFailure().recoverWithItem(error -> {
log.error("Weather API failed", error);
return null; // 或返回空/占位对象，便于后续过滤
});
case "news" -> newsClient.getLatest(requestParam).onFailure().recoverWithItem(error -> {
log.error("News API failed", error);
return null;
});
case "currency" -> currencyClient.convert(requestParam).onFailure().recoverWithItem(error -> {
log.error("Currency API failed", error);
return null;
});
default -> Uni.createFrom().item(null)
.onItem().invoke(() -> log.warn("Unknown provider: {}", provider));
};
}
// 主入口：接收运行时 provider 列表，返回聚合结果
public Uni<List<Object>> fetchAllProviders(List<String> providers, String context) {
if (providers == null || providers.isEmpty()) {
return Uni.createFrom().item(List.of());
}
// ✅ 动态生成 Uni 列表，并转为数组供 combine 使用
List<Uni<Object>> unis = providers.stream()
.map(provider -> callProvider(provider, context))
.collect(Collectors.toList());
// 使用反射安全的 combine（支持任意长度）
return Uni.combine().all().unis(unis.toArray(new Uni[0]))
.combinedWith((Object... results) -> List.of(results));
}
}⚠️ 注意事项与最佳实践
-
容错必须显式声明：
.onFailure().recoverWithItem(...)是关键，否则任一Uni失败将导致整个combine流终止（默认行为）。建议返回null或领域特定的空值对象（如EmptyResponse），便于后续filter(Objects::nonNull)清洗。 -
避免阻塞操作：所有客户端调用（如
RestClient）必须使用 Mutiny 版本（@RegisterRestClient+Uni<t></t>返回类型），禁止在invoke()中调用.await().indefinitely()。 -
超时与熔断：为每个
Uni添加超时保护：callProvider(p, ctx).ifNoItem().after(Duration.ofSeconds(5)) .failWith(new TimeoutException("Provider " + p + " timed out")); -
结果语义一致性：若各 API 返回结构差异大，建议定义统一包装类（如
ApiResponse<t></t>），并在combinedWith中做类型安全映射。 -
性能提示：Quarkus 默认线程池已优化，无需手动指定
runSubscriptionOn()，除非有特殊调度需求。
✅ 总结
通过 providers.stream().map(this::callProvider).collect(...) 构建动态 Uni 列表，再交由 Uni.combine().all().unis(...) 并行执行，即可完美解耦编译期调用逻辑与运行时服务配置。配合细粒度错误恢复与超时控制，该方案兼具灵活性、健壮性与可观测性，是 Quarkus 微服务编排的推荐范式。
