Spring Retry优雅地实现方法重试机制

RetryTemplate retryTemplate = new RetryTemplate();

// 设置最多重试3次（包括第一次尝试）
retryTemplate.setRetryPolicy(new SimpleRetryPolicy(3));

// 设置固定间隔2秒再重试
retryTemplate.setBackOffPolicy(new FixedBackOffPolicy(2000L));

retryTemplate.execute(context -> {
    // 调用可能会失败的方法
    someService.doSomething();
    return null;
});

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
    <version>1.3.5</version>
</dependency>

<!-- 同时需要启用 AspectJ -->
<dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjweaver</artifactId>
    <version>1.9.7</version>
</dependency>

@SpringBootApplication
@EnableRetry
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

@Service
public class MyService {

    @Retryable(maxAttempts = 3, backoff = @Backoff(delay = 2000))
    public void doSomething() {
        // 可能抛出异常的方法体
        if (Math.random() < 0.7) {
            throw new RuntimeException("Temporary failure");
        }
        System.out.println("Success!");
    }
}

@Retryable(value = {IOException.class}, maxAttempts = 5)

@Retryable(exclude = {SQLException.class})

@Retryable(
    value = {IOException.class, TimeoutException.class},
    exclude = SQLException.class,
    maxAttempts = 5,
    backoff = @Backoff(delay = 2000, multiplier = 1.5, maxDelay = 10000),
    stateful = true
)
public void retryableMethod() {
    // 方法逻辑
}

@Component
public class MyRetryListener implements RetryListener {

    @Override
    public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
        System.out.println("Retry: Open");
        return true;
    }

    @Override
    public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
        System.out.println("Retry: Close");
    }

    @Override
    public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
        System.out.println("Retry: Error occurred, attempt " + context.getRetryCount());
    }
}

retryTemplate.registerListener(new MyRetryListener());