如何为Spring 6.1 RestClient实现HTTP请求重试机制

要复刻RestTemplate结合RetryTemplate的全局重试行为，针对Spring 6.1的RestClient，推荐以下两种可行方案：

方案一：自定义请求拦截器（全局生效） #

利用RestClient的拦截器机制，将RetryTemplate的重试逻辑注入到所有请求流程中，这是最接近原RestTemplate重写方案的实现方式。

1. 实现重试拦截器 #

import org.springframework.http.HttpRequest;
import org.springframework.http.client.ClientHttpRequestExecution;
import org.springframework.http.client.ClientHttpRequestInterceptor;
import org.springframework.http.client.ClientHttpResponse;
import org.springframework.retry.support.RetryTemplate;

import java.io.IOException;

public class RetryHttpRequestInterceptor implements ClientHttpRequestInterceptor {

    private final RetryTemplate retryTemplate;

    public RetryHttpRequestInterceptor(RetryTemplate retryTemplate) {
        this.retryTemplate = retryTemplate;
    }

    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
        try {
            // 用RetryTemplate包裹请求执行逻辑
            return retryTemplate.execute(context -> execution.execute(request, body));
        } catch (IOException e) {
            throw e;
        } catch (Exception e) {
            // 转换非IO异常为IOException，适配拦截器方法签名
            throw new IOException("Retry failed for request to " + request.getURI(), e);
        }
    }
}

2. 配置RestClient时注入拦截器 #

import org.springframework.retry.support.RetryTemplate;
import org.springframework.web.client.RestClient;

// 复用原有的RetryTemplate配置
RetryTemplate retryTemplate = retryTemplate(retryProperties);

RestClient restClient = RestClient.builder()
        .requestFactory(requestFactory)
        // 添加重试拦截器，全局生效
        .interceptors(new RetryHttpRequestInterceptor(retryTemplate))
        .build();

效果说明：所有通过该RestClient发起的请求（包括get()、post()、exchange()等）都会自动触发RetryTemplate的重试逻辑，完全复刻原RestTemplate方案的行为。

方案二：包装RestClient方法（按需定制） #

如果需要对特定请求方法做精细化控制，可以封装一个重试版的RestClient包装类，手动将每个请求方法用RetryTemplate包裹。

import org.springframework.http.ResponseEntity;
import org.springframework.retry.support.RetryTemplate;
import org.springframework.web.client.RestClient;

public class RetryableRestClient {

    private final RestClient delegate;
    private final RetryTemplate retryTemplate;

    public RetryableRestClient(RestClient delegate, RetryTemplate retryTemplate) {
        this.delegate = delegate;
        this.retryTemplate = retryTemplate;
    }

    // 包装get请求
    public <T> ResponseEntity<T> getForEntity(String url, Class<T> responseType, Object... uriVariables) {
        return retryTemplate.execute(context -> 
            delegate.get().uri(url, uriVariables).retrieve().toEntity(responseType)
        );
    }

    // 包装post请求
    public <T> ResponseEntity<T> postForEntity(String url, Object requestBody, Class<T> responseType) {
        return retryTemplate.execute(context -> 
            delegate.post().uri(url).body(requestBody).retrieve().toEntity(responseType)
        );
    }

    // 按需包装其他需要重试的请求方法（如exchange、put等）
}

适用场景：当不需要全局拦截所有请求，仅需对特定方法启用重试时，这种方式更灵活。

注意事项 #

• 确保RetryTemplate的重试规则（重试次数、触发重试的异常类型、退避策略）与原RestTemplate方案完全一致，保证行为对齐。
• 拦截器方案中，若需要针对部分请求跳过重试，可以在intercept方法中通过判断请求的URI、Header等属性来动态控制。

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