如何基于Multi实现返回Uni的异步方法顺序调用（失败仍执行）

针对你需要按顺序调用每个元素的异步方法、且单个调用失败不中断后续执行的需求，用Quarkus Reactive的Multi和Uni可以这样实现：

核心实现代码 #

// 将元素列表转为Multi流
Multi<String> sequentialResults = Multi.createFrom().iterable(elements)
    // 使用concatMap保证顺序执行：前一个Uni完成后才处理下一个元素
    .concatMap(element -> 
        asyncMetthod(element)
            // 容错处理：单个调用失败时返回自定义结果，不中断整个流
            .onFailure().recoverWithItem(failure -> {
                // 可选：记录失败日志，比如 log.error("处理元素{}失败", element, failure);
                return String.format("元素[%s]处理失败", element); // 自定义失败返回值
            })
    );

// 可选：收集所有执行结果到List
Uni<List<String>> allResults = sequentialResults.collect().asList();

关键细节说明 #

• concatMap的作用：和普通map不同，concatMap会严格按流的顺序订阅每个Uni，只有当前一个Uni执行完成（无论成功或失败），才会触发下一个元素的异步方法调用，完全符合你"顺序执行"的要求。
• 容错逻辑：onFailure().recoverWithItem() 会捕获单个asyncMethod调用的异常，返回预设值后让流继续向下执行，不会因为某一个元素处理失败而中断整个流程。
• 扩展选项：如果不需要保留失败记录，只想跳过失败的元素，可以把recoverWithItem换成onFailure().recoverWithUni(Uni.createFrom().nullItem())，之后再用.filter(Objects::nonNull)过滤掉空值。

内容的提问来源于stack exchange，提问作者user1549094