You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何捕获MonoError返回ErrorResponse,无需flatMap替代then的优化方案

问题根源分析

你最初的写法不符合预期,核心原因是 then(Mono other) 方法的参数是立即求值的:你写 then(getWordsFromText(text)) 时,getWordsFromText 会在整个流组装的时候就被调用,不管前面的checkText是否抛出错误,这就是为什么text为null时方法依然执行的原因。

最优实现方案(无需flatMap)

用 Mono.defer 把后续的操作包起来,实现延迟求值,只有前面的checkText正常完成后才会触发getWordsFromText的调用,写法完全贴合你最初的语义,也没有多余的无用参数:

return checkText(text)
        .then(Mono.defer(() -> getWordsFromText(text)))
        .map(keyWords -> new SuccessfulResponse(keyWords))
        .onErrorResume(throwable -> Mono.just(new ErrorResponse(throwable.getMessage())));

可选简化方案(仅适用于checkText为纯同步校验的场景)

如果你的checkText只是简单的同步参数校验,没有异步逻辑,那可以直接把校验前置,代码更直观,性能也更好:

if (text == null) {
    return Mono.just(new ErrorResponse("wrong text"));
}
return getWordsFromText(text)
        .map(keyWords -> new SuccessfulResponse(keyWords))
        .onErrorResume(throwable -> Mono.just(new ErrorResponse(throwable.getMessage())));

内容的提问来源于stack exchange,提问作者Julia

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.09.28 17:54:00