Spring Boot 3中OAuth2RestTemplate已废弃，有哪些带自动重试机制的替代方案？

官方推荐替代组件及扩展实现 #

Spring Boot 3 中官方推荐用 RestClient 或 WebClient 替代已废弃的 OAuth2RestTemplate，要实现类似的401 invalid_token 自动刷新重试逻辑，可以通过以下两种方式落地：

1. WebClient + OAuth2 客户端过滤器 + 重试逻辑 #

WebClient 原生集成 OAuth2 客户端支持，配合自定义过滤器和重试操作符可实现需求：

• 先在配置文件中完成 OAuth2 客户端信息配置，让 WebClient 具备自动获取令牌的能力。
• 自定义 ExchangeFilterFunction，捕获401响应后做判断：
  • 若响应体包含 invalid_token 错误码，触发令牌刷新并标记可重试。
  • 若响应无内容，解析 WWW-Authenticate 请求头，确认含 invalid_token 后同样触发重试。
  • 借助 Reactor 的 retryWhen 操作符或 Spring Retry 组件控制重试次数与间隔。

示例代码片段：

@Bean
public WebClient oauth2WebClient(ClientRegistrationRepository clientRegRepo,
                                 OAuth2AuthorizedClientService authClientService) {
    OAuth2AuthorizedClientExchangeFilterFunction oauth2Filter =
            new OAuth2AuthorizedClientExchangeFilterFunction(clientRegRepo, authClientService);
    oauth2Filter.setDefaultClientRegistrationId("your-client-id");

    return WebClient.builder()
            .filter(oauth2Filter)
            .filter((request, next) -> next.exchange(request)
                    .flatMap(clientResponse -> {
                        if (HttpStatus.UNAUTHORIZED.equals(clientResponse.statusCode())) {
                            // 优先解析响应体判断错误类型
                            return clientResponse.bodyToMono(OAuth2Error.class)
                                    .flatMap(error -> handleInvalidToken(error, authClientService))
                                    .onErrorResume(e -> {
                                        // 响应体为空时解析请求头
                                        String wwwAuthHeader = clientResponse.headers()
                                                .header("WWW-Authenticate")
                                                .stream()
                                                .findFirst()
                                                .orElse("");
                                        if (wwwAuthHeader.contains("invalid_token")) {
                                            return authClientService.refreshAuthorizedClient("your-client-id", "principal-name")
                                                    .then(Mono.error(new RetryableOAuth2Exception("Invalid token, retrying")));
                                        }
                                        return Mono.error(new OAuth2AuthenticationException(new OAuth2Error("invalid_request")));
                                    });
                        }
                        return Mono.just(clientResponse);
                    }))
            .build();
}

private Mono<Void> handleInvalidToken(OAuth2Error error, OAuth2AuthorizedClientService authClientService) {
    if ("invalid_token".equals(error.getErrorCode())) {
        return authClientService.refreshAuthorizedClient("your-client-id", "principal-name")
                .then(Mono.error(new RetryableOAuth2Exception("Invalid token, retrying")));
    }
    return Mono.error(new OAuth2AuthenticationException(error));
}

2. RestClient + 自定义拦截器 + 重试注解 #

RestClient 是 Spring Boot 3 新增的同步 HTTP 客户端，可通过拦截器结合重试注解实现需求：

• 实现 ClientHttpRequestInterceptor，在拦截器中捕获401响应，解析错误类型。
• 调用 OAuth2 客户端服务手动刷新令牌，更新请求头后重新发起请求。
• 用 @Retryable 注解标记需要重试的方法，简化重试规则配置。

关键注意事项 #

• 令牌刷新逻辑要保证线程安全，避免并发场景下重复刷新令牌。
• 必须限制重试次数，防止因令牌刷新失败导致无限循环。
• 不同外部服务的401响应格式可能存在差异，需根据实际返回调整错误判断逻辑。

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