如何为Spring WebClient配置全局重试逻辑以处理特定异常

你可以通过ExchangeFilterFunction实现全局统一重试规则，具体实现如下：

1. 实现自定义重试过滤器 #

import org.springframework.web.reactive.function.client.ExchangeFilterFunction;
import reactor.netty.http.client.PrematureCloseException;
import reactor.util.retry.Retry;
import java.time.Duration;

public ExchangeFilterFunction globalRetryFilter() {
    return (request, next) -> next.exchange(request)
            .retryWhen(
                // 配置重试规则：最多重试3次，每次间隔1秒
                Retry.fixedDelay(3, Duration.ofSeconds(1))
                    // 仅对指定异常触发重试
                    .filter(throwable -> throwable instanceof PrematureCloseException)
                    // 重试次数耗尽后抛出原始异常
                    .onRetryExhaustedThrow((spec, signal) -> signal.failure())
            );
}

2. 将过滤器注册到WebClient全局配置 #

import org.springframework.web.reactive.function.client.WebClient;
import org.springframework.context.annotation.Bean;

// 建议以Bean的方式注入全局WebClient实例
@Bean
public WebClient customWebClient() {
    return WebClient.builder()
            .baseUrl("你的业务服务基础地址")
            // 注册全局重试过滤器
            .filter(globalRetryFilter())
            // 其他全局配置（如超时、序列化、日志拦截等）
            .build();
}

常用扩展配置 #

• 适配更多重试异常：在filter方法中增加异常类型判断即可，可同时兼容连接超时、Socket超时等多种网络异常。
• 退避重试策略：将固定间隔fixedDelay替换为Retry.backoff(3, Duration.ofMillis(500))，重试间隔会逐次递增，降低下游服务压力。
• 非幂等请求兼容：如果存在POST等非幂等请求，可增加请求方法判断避免重复提交：

  .filter(throwable -> 
      // 仅对幂等请求触发重试
      request.method().isIdempotent() 
      && throwable instanceof PrematureCloseException
  )
  

• 局部规则覆盖：如果某一个请求需要自定义重试规则，直接在接口调用处添加retryWhen配置即可，局部配置优先级高于全局过滤器。

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