Spring Retryable注解失效：连接超时未触发重试问题排查

核心问题排查 #

你的Spring Retry未生效，主要可能由以下几个原因导致：

1. 未开启Spring Retry功能 #

Spring Retry需要通过@EnableRetry注解显式开启，否则所有@Retryable注解都会被忽略。

2. @Retryable未明确指定需重试的异常类型 #

虽然ProcessingException属于RuntimeException，但默认情况下@Retryable的重试规则未覆盖嵌套的SocketTimeoutException（你的错误栈中是ProcessingException包裹了SocketTimeoutException），导致未触发重试。

3. AOP代理未生效 #

如果RetryService不是通过Spring容器注入，或者注入的是实现类而非接口，会导致AOP代理无法生成，重试逻辑不触发。

分步修复方案 #

步骤1：开启Spring Retry #

在你的Spring配置类中添加@EnableRetry注解：

import org.springframework.retry.annotation.EnableRetry;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableRetry
public class RetryConfig {
}

步骤2：明确指定重试的异常类型 #

修改RetryService接口的@Retryable注解，直接指定需要重试的异常：

import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;
import javax.ws.rs.ProcessingException;
import java.net.SocketTimeoutException;
import java.util.function.Supplier;

@Service
public interface RetryService {

    @Retryable(
            maxAttempts = 4,
            backoff = @Backoff(delay = 1000),
            include = {ProcessingException.class, SocketTimeoutException.class}
    )
    <T> T run(Supplier<T> supplier);
}

步骤3：确保AOP代理生效 #

检查你的retryService注入方式，必须通过接口类型注入，而非实现类：

// 正确方式：注入接口
@Autowired
private RetryService retryService;

// 错误方式：直接注入实现类（会绕过AOP代理）
// @Autowired
// private RetryImpl retryService;

步骤4：添加重试失败兜底逻辑（可选） #

在RetryImpl实现类中添加@Recover方法，处理所有重试失败的情况：

import com.service.RetryService;
import org.springframework.retry.annotation.Recover;
import org.springframework.stereotype.Service;
import javax.ws.rs.ProcessingException;
import java.net.SocketTimeoutException;
import java.util.function.Supplier;

@Service
public class RetryImpl implements RetryService {
    @Override
    public <T> T run(Supplier<T> supplier) {
        return supplier.get();
    }

    @Recover
    public <T> T recoverProcessingException(ProcessingException e, Supplier<T> supplier) {
        throw new RuntimeException("调用外部服务重试失败", e);
    }

    @Recover
    public <T> T recoverSocketTimeoutException(SocketTimeoutException e, Supplier<T> supplier) {
        throw new RuntimeException("调用外部服务超时重试失败", e);
    }
}

优化方案：解决根源连接超时问题 #

你提到服务闲置30分钟后调用超时，这大概率是客户端连接池中的连接因闲置过久被服务端关闭导致。建议配置Resteasy客户端的连接池参数，避免使用无效连接：

import org.jboss.resteasy.client.jaxrs.ResteasyClient;
import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
import javax.ws.rs.client.Client;
import java.util.concurrent.TimeUnit;

// 初始化客户端时配置连接池
public Client createClient() {
    return new ResteasyClientBuilder()
            .connectTimeout(5, TimeUnit.SECONDS)       // 连接超时时间
            .readTimeout(10, TimeUnit.SECONDS)         // 读取超时时间
            .connectionPoolSize(10)                    // 连接池大小
            .idleConnectionTimeout(25, TimeUnit.MINUTES) // 闲置连接超时（小于服务端超时时间）
            .build();
}

这个配置会自动清理闲置过久的连接，从根源减少超时异常的发生。

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