使用AbortPolicy 如何捕获异常

`AbortPolicy`是Spring框架中的一种决策策略，通常用于处理长时间运行的任务或者异步操作，例如WebFlux中的HTTP请求响应。当某个任务超时或者满足特定条件时，我们可以使用`AbortPolicy`来中断这个任务并抛出相应的异常。

在Spring WebFlux中，你可以通过以下步骤来使用`AbortPolicy`：

1. 首先，你需要创建一个自定义的`AbortPolicy`实例。例如，可以使用`Timeout Abort Policy`或`Retryableabort policy`等预定义的策略，也可以自定义一个实现了`AbortPolicy`接口的类。

import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
import reactor.util.context.Context;
import reactor.util.retry.RetrySupport;

// 自定义的AbortPolicy
public class CustomAbortPolicy extends RetrySupport.AbortPolicy {
    // 实现abortWhen方法...
}

2. 当发起一个长跑的HTTP请求时，使用`WebClient`的`retrieve()`方法，并将自定义的`AbortPolicy`作为参数传递给`exchange()`方法：

CustomAbortPolicy policy = new CustomAbortPolicy();
Mono<ServerResponse> response = WebClient.create("http://example.com")
    .retrieve()
    .toMono()
    .filter(response -> policy.isAborting(Context.of(), response.statusCode().getRawValue()))
    .doOnCancel(() -> System.out.println("Task has been aborted"))
    .switchIfEmpty(Mono.error(new RuntimeException("Request timed out")));

这里的`.filter()`方法会在每个响应到来时检查是否应触发中断，如果满足条件，`.switchIfEmpty()`会返回错误而不是等待下一个响应。