Spring 6/Spring Boot 3 HTTP 接口实现请求重试机制

本文将深入探讨如何在 spring 6 和 spring boot 3 中为新的 http 接口实现请求重试机制。针对 http 接口不直接支持 `retrywhen()` 的挑战，我们将演示如何通过配置 `webclient` 的 `exchangefilterfunction` 来集成灵活的重试策略，从而提升服务调用的健壮性与容错能力。文章将提供详细的代码示例和实现步骤。

Spring HTTP 接口与重试挑战

Spring 6 和 Spring Boot 3 引入的 HTTP 接口（@HttpExchange）提供了一种声明式、类型安全的 HTTP 客户端编程模型，极大地简化了远程服务调用的开发。通过定义接口并使用注解，开发者可以像调用本地方法一样调用远程服务，底层由 WebClient 或其他 HTTP 客户端实现。

尽管 HTTP 接口带来了便利，但在处理服务调用的弹性方面，它与底层的 WebClient 存在一个显著差异：HTTP 接口本身并未直接暴露 WebClient 提供的 retryWhen() 等内置重试操作。这意味着如果直接使用 HTTP 接口，开发者无法像传统 WebClient 调用那样，在每个请求链上直接配置重试逻辑。当面对网络瞬时故障、下游服务暂时不可用等情况时，缺乏重试机制会导致请求失败，降低系统的健壮性。

WebClient 的重试机制回顾

在 Spring WebFlux 中，WebClient 是一个非阻塞的 HTTP 客户端，它通过 Reactor 提供的 Mono 和 Flux 来处理异步响应。WebClient 提供了一个强大的 retryWhen() 操作符，允许开发者定义复杂的重试策略。例如，经典的指数退避重试可以这样实现：

import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
import reactor.util.retry.Retry;
import java.time.Duration;

// 假设 webClient 实例已存在
// private WebClient webClient;

public Mono getData(String stockId) {
    return webClient.get()
            .uri("/stocks/{id}", stockId)
            .retrieve()
            .bodyToMono(String.class)
            .retryWhen(Retry.backoff(3, Duration.ofSeconds(2)) // 最多重试3次，初始间隔2秒，指数退避
                    .doAfterRetry(retrySignal -> System.out.println("Retrying stock data for id: " + stockId)));
}

这种方式的优点是重试逻辑与具体的业务请求紧密结合，易于理解和配置。然而，当通过 HTTP 接口代理 WebClient 时，我们无法直接在接口方法上应用这种链式操作。

ClipDrop

Stability.AI出品的图片处理系列工具（背景移除、图片放大、打光）

下载

解决方案：通过 ExchangeFilterFunction 实现通用重试

解决 HTTP 接口重试问题的关键在于利用 WebClient 的 ExchangeFilterFunction。ExchangeFilterFunction 是 WebClient 提供的扩展点，允许我们在请求被发送之前和响应被处理之后，注入自定义的逻辑。它本质上是一个拦截器，可以对所有通过该 WebClient 发送的请求进行统一处理，包括请求的修改、响应的检查以及错误重试。

通过将重试逻辑封装在一个 ExchangeFilterFunction 中，我们可以将其应用于构建 HTTP 接口所使用的 WebClient 实例，从而实现对所有 HTTP 接口方法的透明重试。

实现重试过滤器

首先，我们需要创建一个 ExchangeFilterFunction Bean，其中包含我们的重试逻辑。这个过滤器将拦截 WebClient 的请求，并在遇到错误响应时触发重试。

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.client.ExchangeFilterFunction;
import reactor.core.publisher.Mono;
import reactor.util