如何用Spring WebClient以响应式方式处理无需HTTP状态码判断的空响应

完全可以实现需求，Spring WebClient支持自定义响应体处理逻辑，结合Reactor的响应式API就能避免重复消费响应体，同时根据响应体是否为空区分成功/错误场景。

核心实现思路 #

由于目标接口始终返回HTTP 200，我们跳过状态码校验，直接对响应体做判断：

1. 尝试将响应体映射为目标POJO
2. 若响应体为空（错误场景），触发错误逻辑
3. 全程基于响应式流操作，确保响应体仅被消费一次

方案一：基于bodyToMono+switchIfEmpty的简洁实现 #

这是最常用的方式，利用bodyToMono在空响应时返回empty Mono的特性，结合switchIfEmpty处理错误：

// 初始化WebClient
WebClient webClient = WebClient.create("https://your-api-base-url");

// 构建请求并处理响应
Mono<YourTargetPojo> responseMono = webClient.get()
        .uri("/your-api-path")
        .retrieve()
        // 尝试将响应体映射为POJO，空响应会生成empty Mono
        .bodyToMono(YourTargetPojo.class)
        // 空响应时抛出自定义异常，上层可通过onError处理
        .switchIfEmpty(Mono.error(new IllegalStateException("接口返回空内容，判定为业务错误")))
        // 处理可能的解析错误（比如响应体格式不符合POJO定义）
        .onErrorResume(JsonProcessingException.class, ex -> 
            Mono.error(new RuntimeException("响应体解析失败", ex))
        );

方案二：底层DataBuffer校验（精确控制响应体） #

如果需要更精准地判断“空响应”（比如区分空JSON和零字节响应），可以直接读取原始DataBuffer来校验：

Mono<YourTargetPojo> responseMono = webClient.get()
        .uri("/your-api-path")
        .retrieve()
        .bodyToMono(DataBuffer.class)
        .flatMap(dataBuffer -> {
            // 检查响应体字节数是否为0
            if (dataBuffer.readableByteCount() == 0) {
                DataBufferUtils.release(dataBuffer); // 手动释放缓冲区，避免内存泄漏
                return Mono.error(new IllegalStateException("空响应，业务处理失败"));
            }
            // 将DataBuffer转换为目标POJO，确保仅消费一次
            return Mono.just(dataBuffer)
                    .transform(BodyExtractors.toMono(YourTargetPojo.class))
                    .doFinally(signalType -> DataBufferUtils.release(dataBuffer));
        });

关键注意事项 #

• 响应体仅消费一次：上述两种方案都是基于Reactor的Mono链式操作，响应体只会被读取一次，不会出现重复消费的问题。
• POJO反序列化配置：确保你的POJO适配接口的响应格式，比如如果接口返回空JSON对象（{}）而非零字节，需要调整判断逻辑（比如检查POJO的关键字段是否为null）。
• 异常处理：通过switchIfEmpty和onErrorResume可以统一处理空响应、解析错误等场景，上层业务代码只需订阅Mono并处理onNext（成功）和onError（失败）即可。

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