Spring WebFlux：WebClient调用中途抛异常时onErrorResume未触发

核心问题 #

你的单元测试写法有误，导致异常是同步抛出的，而onErrorResume只能捕获响应式流（Flux/Mono）内部的异步异常，无法处理构建WebClient调用链阶段的同步异常。

具体来说，你在Mock时直接让retrieve()抛出异常：

Mockito.when(webClient.get().uri(URI.create(uri)).retrieve()).thenThrow(new RuntimeException("Hello world exception thrown"));

这会在调用retrieve()方法时立刻同步抛出异常，此时还没走到bodyToFlux生成Flux的阶段，自然触发不了后续的onErrorResume。

正确的解决方案 #

1. 正确Mock WebClient的响应式异常 #

需要Mockretrieve()返回的ResponseSpec，并让bodyToFlux返回一个包含异常的Flux，这样异常才会进入响应式流中，被onErrorResume捕获：

// 先Mock ResponseSpec
ResponseSpec mockResponseSpec = Mockito.mock(ResponseSpec.class);
// 让bodyToFlux返回一个错误的Flux
when(mockResponseSpec.bodyToFlux(Some.class)).thenReturn(Flux.error(new RuntimeException("Hello world exception thrown")));

// 再Mock WebClient的调用链
when(webClient.get().uri(URI.create(uri)).retrieve()).thenReturn(mockResponseSpec);

2. 补充WebClient的HTTP错误处理（可选） #

如果你的场景需要处理HTTP错误状态码（比如4xx、5xx），默认retrieve()会抛出WebClientResponseException，你可以在retrieve()后添加onStatus来提前处理这类错误，再让异常流入后续的onErrorResume：

webClient
    .get()
    .uri(someUri)
    .retrieve()
    .onStatus(HttpStatus::isError, response -> 
        Mono.error(new RuntimeException("HTTP error: " + response.statusCode()))
    )
    .bodyToFlux(Some.class)
    .onErrorResume(throwable -> {
        log.error("Error occurred when calling other service: {}", throwable.getMessage());
        return Flux.error(new RuntimeException("Exception type: " + throwable.getClass() + " Exception message: " + throwable.getMessage()));
    });

3. 区分同步异常与响应式流异常 #

要明确：

• 同步异常：在构建调用链时（比如uri()传参错误、Mock时同步抛异常）抛出的异常，无法被onErrorResume捕获，需要用常规的try-catch处理。
• 响应式流异常：在Flux/Mono执行阶段（比如HTTP请求失败、序列化错误）抛出的异常，才能被onErrorResume、doOnError等响应式操作符捕获。

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