Spring WebFlux更新API编写：如何从Mono<UserRequest>获取请求体？

你遇到的核心问题是没掌握响应式编程中异步类型（Mono）的处理逻辑——不能像同步对象那样直接提取Mono内部的值，必须通过响应式操作符来异步处理。以下是两种正确的实现方式：

方式一：使用zipWith合并两个Mono #

通过zipWith操作符将查询到的用户（Mono<User>）和请求体（Mono<UserRequest>）合并为一个Tuple2，这样就能同时获取两个对象：

public Mono<User> updateUser(String userId, Mono<UserRequest> userRequestMono) {
    return userRepository.findById(userId)
        .switchIfEmpty(Mono.error(new NotFoundException("User not found")))
        .zipWith(userRequestMono)
        .flatMap(tuple -> {
            User foundUser = tuple.getT1();
            UserRequest userRequest = tuple.getT2();
            // 将请求体映射到已存在的用户对象
            modelMapper.map(userRequest, foundUser);
            // ReactiveCrudRepository的save方法本身返回Mono<User>，直接返回即可
            return userRepository.save(foundUser);
        });
}

方式二：嵌套flatMap展开Mono #

在查询到用户的flatMap内部，再对Mono<UserRequest>执行flatMap操作，从而获取内部的请求体对象：

public Mono<User> updateUser(String userId, Mono<UserRequest> userRequestMono) {
    return userRepository.findById(userId)
        .switchIfEmpty(Mono.error(new NotFoundException("User not found")))
        .flatMap(foundUser -> {
            return userRequestMono.flatMap(userRequest -> {
                modelMapper.map(userRequest, foundUser);
                return userRepository.save(foundUser);
            });
        });
}

关键注意事项 #

• 禁止使用block()方法直接提取Mono的值：这会阻塞线程，完全违背响应式编程的非阻塞设计原则，还可能引发线程池耗尽等问题。
• 原代码中Mono.just(userRepository.save(foundUser))是错误写法：因为userRepository.save()已经返回Mono<User>，包裹后会变成Mono<Mono<User>>，直接返回save的结果即可。

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