17370845950

本文介绍如何利用 quarkus mutiny 的 `multi` 与 `transformtouniandconcatenate`，对列表中的元素**逐个、顺序、异步**调用返回 `uni` 的方法，并在任一环节失败时自动降级继续执行后续项。

在响应式编程中，“顺序执行多个异步操作”是一个常见但易错的需求——尤其当每个操作返回 Uni（单值异步流）且需严格串行（前一个完成后再触发下一个）、同时要求失败不中断整体流程时，直接使用 flatMap 或 concatenate 易导致错误传播或并发失控。

Mutiny 提供了优雅的解决方案：借助 Multi.createFrom().iterable() 将元素列表转为多值流，再通过 onItem().transformToUniAndConcatenate(...) 实现串行化 Uni 转换——该操作符会等待前一个 Uni 完成（无论成功或失败），再启动下一个，天然满足“顺序 + 容错”双重要求。

✅ 正确实现如下：

import io.smallrye.mutiny.Multi;
import io.smallrye.mutiny.Uni;

// 假设 elements 非 null
Multi sequentialResults = Multi.createFrom()
    .iterable(elements)
    .onItem()
    .transformToUniAndConcatenate(element -> 
        asyncMethod(element)
            .onFailure() // 捕获任意异常（包括 RuntimeException）
            .recoverWithItem("fallback_" + element.getId()) // 自定义降级值（类型需匹配 String）
            // 或 .continueWith(() -> Uni.createFrom().item("default"))
    );

⚠️ 关键注意事项：

• transformToUniAndConcatenate 是唯一保证严格串行的转换算子；transformToUniAndFlatMap 会并发执行，transformToUniAndMerge 则无序合并。
• .onFailure().recoverWithItem(...) 必须返回与 Uni 类型一致的值（如 String），否则编译失败；若需更复杂错误处理（如日志+默认值），可用 .onFailure().invoke(log::error).recoverWithItem(...)。
• 若需收集全部结果，可追加 .collect().asList() 得到 Uni>；若需实时消费，用 .subscribe().with(System.out::println)。

? 总结：当面对“列表 → 逐个异步调用 → 顺序 + 失败继续”场景时，Multi.iterable(...).transformToUniAndConcatenate(...) 是 Mutiny 中最简洁、语义最清晰的标准模式——它将控制流逻辑完全声明化，无需手写递归或状态管理，兼顾可读性与健壮性。