在WebFlux中，无功控制器onErrorResume不工作

在WebFlux中，onErrorResume 是一个非常有用的操作符，它允许你在发生错误时恢复到一个备用的响应流。如果你发现 onErrorResume 不起作用，可能是以下几个原因：

基础概念

onErrorResume 是 Reactor 框架中的一个操作符，用于处理流中的错误。当上游流发生错误时，它会切换到备用流，从而避免整个流的终止。

类型

onErrorResume 有两种重载形式：

onErrorResume(Function<Throwable, ? extends Publisher<T>> fallback)
onErrorResume(Publisher<T> fallback)

应用场景

当你需要根据不同的错误类型返回不同的响应时。
当你需要在发生错误时提供一个默认的响应。

可能的原因及解决方法

1. 错误类型不匹配

确保你捕获的错误类型与实际发生的错误类型匹配。例如，如果你只捕获了 RuntimeException，而实际发生的是 IOException，则 onErrorResume 不会触发。

return Mono.just("Hello")
    .map(value -> {
        if (value.equals("Hello")) {
            throw new IOException("Simulated error");
        }
        return value;
    })
    .onErrorResume(IOException.class, e -> Mono.just("Default response"));

2. 备用流未正确配置

确保备用流（fallback）正确配置并且能够正常工作。

return Mono.just("Hello")
    .map(value -> {
        if (value.equals("Hello")) {
            throw new RuntimeException("Simulated error");
        }
        return value;
    })
    .onErrorResume(e -> Mono.just("Default response"));

3. 异常被其他操作符捕获

如果在 onErrorResume 之前有其他操作符捕获了异常，onErrorResume 将不会触发。

return Mono.just("Hello")
    .doOnError(e -> System.out.println("Error caught by doOnError: " + e.getMessage()))
    .map(value -> {
        if (value.equals("Hello")) {
            throw new RuntimeException("Simulated error");
        }
        return value;
    })
    .onErrorResume(e -> Mono.just("Default response"));

示例代码

以下是一个完整的示例，展示了如何在 WebFlux 中使用 onErrorResume：

import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;

public class MyHandler {

    public Mono<ServerResponse> handleRequest(ServerRequest request) {
        return Mono.just("Hello")
            .map(value -> {
                if (value.equals("Hello")) {
                    throw new RuntimeException("Simulated error");
                }
                return value;
            })
            .onErrorResume(e -> Mono.just("Default response"))
            .flatMap(responseValue -> ServerResponse.ok().bodyValue(responseValue));
    }
}