Spring WebFlux中block()报错，如何从Mono<User>正确获取用户数据？

问题根源 #

你遇到的java.lang.IllegalStateException是因为在Reactor的IO线程（reactor-http-nio）上调用了阻塞方法block()。WebFlux基于Netty的非阻塞IO模型设计，IO线程属于事件循环线程，绝对不允许执行阻塞操作，否则会破坏整个非阻塞架构的性能和稳定性。

错误代码示例 #

你原来的代码大概是这样的（模拟）：

// 错误写法：在map里调用block()阻塞获取User
public Mono<List<Post>> findAllPosts() {
    return postRepository.findAll()
        .map(post -> {
            // 这里调用block()直接触发异常
            User user = userRepository.findById(post.getUserId()).block();
            post.setUser(user);
            return post;
        })
        .collectList();
}

正确实现方式 #

必须用响应式操作符替代阻塞调用，保持整个数据流的非阻塞特性。这里用flatMap来组合Post和对应的User数据流：

// 正确写法：用flatMap组合响应式流
public Flux<Post> findAllPosts() {
    return postRepository.findAll()
        // flatMap将每个Post转换成包含User的Post的Flux
        .flatMap(post -> 
            userRepository.findById(post.getUserId())
                .map(user -> {
                    post.setUser(user);
                    return post;
                })
        );
}

如果需要返回Mono<List<Post>>，只需在末尾加上collectList()：

public Mono<List<Post>> findAllPosts() {
    return postRepository.findAll()
        .flatMap(post -> 
            userRepository.findById(post.getUserId())
                .map(user -> {
                    post.setUser(user);
                    return post;
                })
        )
        .collectList();
}

更优方案：Repository层关联查询 #

如果Post和User是数据库关联关系，可以直接在PostRepository里定义关联查询，避免手动组合数据流：

// 在PostRepository中添加关联查询方法
public interface PostRepository extends ReactiveCrudRepository<Post, Long> {
    @Query("SELECT p FROM Post p JOIN FETCH p.user u")
    Flux<Post> findAllWithUser();
}

这样调用postRepository.findAllWithUser()就能直接获取包含User的Post数据，无需额外处理。

核心注意事项 #

• 禁止在响应式IO线程上调用block()、blockFirst()、blockLast()等阻塞方法
• 所有数据处理逻辑必须放在响应式操作符（map、flatMap、zip等）内部，保持数据流的非阻塞性
• 优先通过Repository层的关联查询减少业务代码中的数据流组合，提升代码简洁性和性能

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