Spring RestTemplate无法找到恢复方法的问题解决咨询

问题背景 #

旧版Spring Boot微服务从Eureka迁移至spring-cloud-kubernetes-client-discovery环境后，原有RestTemplate重试逻辑出现异常：目标服务返回预期的404响应时，未执行后续创建分组的代码，反而抛出org.springframework.retry.ExhaustedRetryException: Cannot locate recovery method错误。

原因分析 #

1. RestTemplate错误处理行为变更：迁移后RestTemplate的ResponseErrorHandler配置改变，4xx响应不再返回带状态码的ResponseEntity，而是抛出HttpClientErrorException，打断了原有流程。
2. 重试与恢复方法不匹配：
   • @Retryable仅配置重试ResourceAccessException（连接类异常），但HttpClientErrorException不在重试范围内，异常抛出后无对应处理逻辑。
   • @Recover方法的异常参数与实际抛出的异常类型不匹配，导致重试耗尽后找不到恢复方法。
3. 外层异常捕获范围不足：仅捕获DataIntegrityViolationException，未处理RestTemplate抛出的HTTP类异常，导致流程直接中断。

解决方案 #

1. 调整RestTemplate错误处理，保留4xx响应为ResponseEntity #

若希望404等4xx响应以ResponseEntity形式返回而非抛出异常，自定义ResponseErrorHandler：

@Bean
public RestTemplate restTemplate() {
    RestTemplate restTemplate = new RestTemplate();
    restTemplate.setErrorHandler(new DefaultResponseErrorHandler() {
        @Override
        protected boolean hasError(HttpStatus statusCode) {
            // 仅将5xx状态码视为错误，4xx返回正常ResponseEntity
            return statusCode.is5xxServerError();
        }
    });
    return restTemplate;
}

配置后，目标服务返回404时，exchange方法会返回带状态码的ResponseEntity，可正常执行后续创建逻辑。

2. 修正重试与恢复方法匹配 #

若需保留对4xx异常的重试逻辑，调整@Retryable和@Recover配置：

• 更新@Retryable异常范围：加入HttpClientErrorException（或指定具体子类型如HttpClientErrorException.NotFound）：

@Retryable(maxAttemptsExpression = "3",
           value = {ResourceAccessException.class, HttpClientErrorException.class},
           backoff = @Backoff(
               delayExpression = "1000",
               maxDelayExpression = "10000",
               multiplierExpression = "1")
)
public <T> ResponseEntity<T> exchange(String service, String url, HttpMethod method,
                                      HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables) {
    return clientRestTemplate.exchange(url, method, requestEntity, responseType, uriVariables);
}

• 确保@Recover参数完全匹配：恢复方法第一个参数需匹配重试异常类型（或其父类），后续参数与@Retryable方法参数顺序、类型一致：

@Recover
public <T> ResponseEntity<T> recoverExchange(Exception exception, String service, String url, HttpMethod method,
                                             HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables) {
    LOGGER.error("重试耗尽，请求失败: {}", url, exception);
    throw new RuntimeException("请求重试失败", exception);
}

3. 扩展外层异常捕获范围 #

修改外层try-catch，覆盖HTTP相关异常，确保流程能进入创建逻辑：

try {
    ResponseEntity<AccountGroup> response = connector.getAccountGroup(accountGroup.getValue());
    if (response != null && HttpStatus.NOT_FOUND.equals(response.getStatusCode())) {
        response = connector.exchange(............);
    }
    if (response == null || !response.getStatusCode().is2xxSuccessful()) {
        // 调用创建分组方法
        LOGGER.error("创建分组时出错 ", accountGroup.getValue());
    }
    return repository.save(accountGroup);
} catch (DataIntegrityViolationException e) {
    throw new BadRequestException();
} catch (HttpClientErrorException | ResourceAccessException e) {
    if (e instanceof HttpClientErrorException && ((HttpClientErrorException) e).getStatusCode() == HttpStatus.NOT_FOUND) {
        // 执行分组创建逻辑
        LOGGER.error("分组不存在，执行创建 ", accountGroup.getValue());
        return repository.save(accountGroup);
    }
    LOGGER.error("服务调用异常 ", e);
    throw new RuntimeException("服务调用失败", e);
}

4. 验证Kubernetes服务发现配置 #

确保服务发现配置正确，服务名可解析到Kubernetes端点：

spring:
  cloud:
    kubernetes:
      discovery:
        enabled: true
        service-labels:
          app: your-service-label

避免因服务发现失败触发不必要的重试。

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