SpringBoot3中WebClient的GET/POST请求映射实现疑问

一、核心逻辑澄清 #

首先明确：你的Spring Boot应用是给React前端提供REST API，Controller层的@RequestMapping/@GetMapping/@PostMapping用法完全不需要改。WebClient是用来让你的应用调用外部HTTPS接口的工具，不是替代Controller的请求映射。如果只是操作MongoDB返回数据，根本不需要WebClient。

二、若需用WebClient调用外部HTTPS接口（带自签名证书） #

假设你的Service需要从外部HTTPS服务获取/验证电影数据，且已配置好带自签名证书的WebClient Bean，以下是具体实现：

1. Service层代码示例 #

@Service
public class MovieService {
    private final WebClient webClient;
    private final MovieRepository movieRepository; // 原MongoDB操作仓库

    // 构造注入依赖
    public MovieService(WebClient webClient, MovieRepository movieRepository) {
        this.webClient = webClient;
        this.movieRepository = movieRepository;
    }

    // 从外部API拉取电影列表
    public Flux<Movie> fetchMoviesFromExternalApi() {
        return webClient.get()
                .uri("/movies") // 外部API的具体路径
                .retrieve()
                // 处理外部API的错误状态码
                .onStatus(HttpStatus::isError, response -> 
                    Mono.error(new RuntimeException("外部API调用失败: " + response.statusCode()))
                )
                .bodyToFlux(Movie.class); // 自动转成Movie对象的Flux流
    }

    // 验证电影信息后存入MongoDB（POST场景）
    public Mono<Movie> saveValidatedMovie(Movie movie) {
        return webClient.post()
                .uri("/movies/validate")
                .bodyValue(movie)
                .retrieve()
                .onStatus(HttpStatus::isError, response -> 
                    Mono.error(new RuntimeException("电影信息验证失败"))
                )
                .bodyToMono(Movie.class)
                .flatMap(validatedMovie -> movieRepository.save(validatedMovie)); // 验证通过后存库
    }

    // 保留原MongoDB查询方法
    public Flux<Movie> getAllMoviesFromDb() {
        return movieRepository.findAll();
    }
}

2. Controller层代码示例（处理前端请求） #

Controller层依旧用常规注解，直接返回Mono/Flux即可——Spring Boot会自动将其序列化为JSON，并默认返回200 OK状态码：

@RestController
@RequestMapping("/api/movies")
public class MovieController {
    private final MovieService movieService;

    public MovieController(MovieService movieService) {
        this.movieService = movieService;
    }

    // 处理前端GET请求，返回电影列表（JSON格式，200 OK）
    @GetMapping
    public Flux<Movie> getAllMovies() {
        // 根据需求选择从DB或外部API取数
        return movieService.getAllMoviesFromDb();
        // return movieService.fetchMoviesFromExternalApi();
    }

    // 处理前端POST请求，返回保存后的电影对象（200 OK）
    @PostMapping
    public Mono<Movie> createMovie(@RequestBody Movie movie) {
        return movieService.saveValidatedMovie(movie);
    }

    // 自定义状态码示例：创建成功返回201 Created
    @PostMapping("/create")
    public Mono<ResponseEntity<Movie>> createMovieWithCustomStatus(@RequestBody Movie movie) {
        return movieService.saveValidatedMovie(movie)
                .map(savedMovie -> ResponseEntity.status(HttpStatus.CREATED).body(savedMovie));
    }
}

三、关键细节说明 #

• Mono/Flux自动序列化：Spring WebFlux会自动将Mono/Flux对象转换为JSON格式，无需手动处理。
• 默认状态码：成功返回Mono/Flux时，默认返回200 OK；创建资源时用ResponseEntity指定201 Created更符合REST规范。
• 异常处理：WebClient的onStatus会捕获外部API的错误状态，抛出的异常会被Spring自动转为500 Internal Server Error，也可通过@ControllerAdvice自定义异常响应格式。
• 自签名证书配置：已配置好的WebClient Bean直接注入使用即可，业务代码无需重复处理证书逻辑。

四、纯MongoDB场景的简化方案 #

如果你的业务只是前端调用你的API、你操作MongoDB返回数据，完全不需要WebClient，保留原来的Controller和Service逻辑，只需确保Spring Boot应用配置好自签名证书（让前端能通过HTTPS访问你的API）即可。

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