Spring WebFlux：如何根据Mono结果动态返回对应响应？

原代码核心问题 #

• 错误在subscribe()中尝试返回新Mono：subscribe()是触发流执行的终端操作，无法用来构建或修改响应式流的返回值，这也是IDE报错的根源。
• 字符串比较用==而非equals()：Java中==是引用比较，会导致状态判断逻辑失效。
• 手动订阅破坏响应式链式结构：不符合WebFlux“以流为中心”的最佳实践。

正确实现代码 #

@Slf4j
@Service
public class Compare {

    private final Myservice myService;

    // 推荐构造注入，符合Spring最佳实践
    public Compare(Myservice myService) {
        this.myService = myService;
    }

    public Mono<MyResponse> compute(String firstItem, String secondItem, String thirdItem) {
        // 第一次比较请求
        return myService.sendRequestToCompare(firstItem, secondItem)
                // 基于第一次结果决定后续逻辑
                .flatMap(firstResponse -> {
                    // 修正字符串比较逻辑，用equals做值比较
                    if ("NOT_SAME".equals(firstResponse.getResponse().getStatus().toString()) 
                        && firstResponse.getResponse().getErrorCode() == 201) {
                        // 满足条件时发起第二次比较
                        return myService.sendRequestToCompare(firstItem, thirdItem);
                    } else {
                        // 不满足条件时直接返回第一次结果
                        return Mono.just(firstResponse);
                    }
                })
                // 统一处理流中的异常
                .onErrorMap(error -> {
                    log.error("调用myService的sendRequestToCompare方法出错", error);
                    // 可转换为自定义异常，或直接返回原异常
                    return error;
                });
    }
}

关键实现要点 #

• 使用flatMap操作符：作为响应式流的核心组合工具，它能基于上游Mono的结果动态生成新的流，完美适配“条件触发二次调用”的场景。
• 链式调用风格：整个业务逻辑通过操作符串联，无分散的return语句，代码简洁易维护。
• 构造注入替代字段注入：提升代码可测试性，符合Spring官方推荐的依赖注入规范。
• 统一错误处理：通过onErrorMap在流中处理异常，替代终端订阅时的错误回调，保证异常能被下游正确捕获处理。
• 修正字符串比较：Java中字符串值相等判断必须用equals()，避免==带来的引用比较错误。

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