使用Mono重构WebClient代码时遇类型不匹配错误求助

问题说明 #

原本使用WebClient结合.block()实现同步接口，重构为非阻塞的响应式实现时，遇到类型错误：
Required type: List<Mono<CatalogItem>> Provided:Mono<Object>

原同步代码 #

@GetMapping("/user/{userId}")
public List<CatalogItem> getUserMoviesRating(@PathVariable String userId) {

    UserRating ratings = webClientBuilder.build()
            .get()
            .uri("http://localhost:8083/ratingsdata/users/" + userId)
            .retrieve()
            .bodyToMono(UserRating.class)
            .block();

    assert ratings != null;
    return ratings.getUserRating().stream().map(rating -> {

        Movies movie = webClientBuilder.build()
                .get()
                .uri("http://localhost:8082/movies/"  + rating.getMovieId())
                .retrieve()
                .bodyToMono(Movies.class)
                .block();

        assert movie != null;
        return new CatalogItem(movie.getName(), movie.getDesc(), rating.getRating());
    }).collect(Collectors.toList());
}

错误的重构尝试 #

@GetMapping("/user/{userId}")
public List<Mono<CatalogItem>> getUserMoviesRating(@PathVariable String userId) {

    Mono<UserRating> ratings = webClientBuilder.build()
            .get()
            .uri("http://localhost:8083/ratingsdata/users/" + userId)
            .retrieve()
            .bodyToMono(UserRating.class);

    return ratings.map(userRating -> userRating.getUserRating().stream().map(rating -> {
        Mono<Movies> movies = webClientBuilder.build()
                .get()
                .uri("http://localhost:8082/movies/" + rating.getMovieId())
                .retrieve()
                .bodyToMono(Movies.class);
        return movies.map(m -> new CatalogItem(m.getName(), m.getDesc(), rating.getRating()));
    }).collect(Collectors.toList()));
}

问题根源 #

1. 返回类型错误：WebFlux接口需要返回响应式类型（Mono/Flux）而非普通集合，直接返回List<Mono<CatalogItem>>不符合响应式编程规范，也会导致类型不匹配。
2. 映射方式错误：ratings.map(...)返回的是Mono<List<Mono<CatalogItem>>>，但方法声明要求返回List<Mono<CatalogItem>>，两者类型完全不兼容。

正确的非阻塞实现 #

@GetMapping("/user/{userId}")
public Mono<List<CatalogItem>> getUserMoviesRating(@PathVariable String userId) {
    return webClientBuilder.build()
            .get()
            .uri("http://localhost:8083/ratingsdata/users/" + userId)
            .retrieve()
            .bodyToMono(UserRating.class)
            // 异步处理UserRating，转换为CatalogItem列表的Mono
            .flatMap(userRating -> 
                // 将ratings集合转为Flux流，批量处理每个rating
                Flux.fromIterable(userRating.getUserRating())
                    // 对每个rating异步请求电影信息，转换为CatalogItem
                    .flatMap(rating -> webClientBuilder.build()
                            .get()
                            .uri("http://localhost:8082/movies/" + rating.getMovieId())
                            .retrieve()
                            .bodyToMono(Movies.class)
                            .map(movie -> new CatalogItem(movie.getName(), movie.getDesc(), rating.getRating())))
                    // 将Flux中的所有CatalogItem收集为List，包装成Mono返回
                    .collectList()
            );
}

关键说明 #

• 使用flatMap替代map：flatMap用于处理异步映射操作，获取电影信息是异步请求，必须用flatMap才能将Mono<Movies>合并到响应流中。
• 用Flux.fromIterable处理批量元素：将用户的rating集合转为响应式流，方便并行处理每个rating对应的电影请求。
• 最终返回Mono<List<CatalogItem>>：这是WebFlux期望的响应式返回类型，Spring会自动处理异步响应的序列化和返回。

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