如何捕获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
相关产品推荐
相关产品推荐

