SpringBoot整合Spring Retry优雅实现接口重试的示例代码

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
</dependency>
<dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjweaver</artifactId>
</dependency>

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

@Service
public class PaymentService {

    private static final Logger log = LoggerFactory.getLogger(PaymentService.class);

    @Retryable(
        value = {RemoteAccessException.class, TimeoutException.class},
        maxAttempts = 3,
        backoff = @Backoff(delay = 1000, multiplier = 2)
    )
    public boolean refund(String orderNo) {
        log.info("退款请求: {}", orderNo);
        // 调用第三方支付接口
        return thirdPartyRefund(orderNo);
    }

    @Recover
    public boolean recover(RemoteAccessException e, String orderNo) {
        log.error("退款失败，记录到异常表: {}", orderNo, e);
        // 记录到失败表，人工处理
        return false;
    }
}

@Configuration
public class RetryConfig {

    @Bean
    public RetryTemplate retryTemplate() {
        RetryTemplate template = new RetryTemplate();

        // 重试策略：最多重试5次，间隔递增
        ExponentialBackOffPolicy backOff = new ExponentialBackOffPolicy();
        backOff.setInitialInterval(1000);
        backOff.setMultiplier(2);
        backOff.setMaxInterval(10000);
        template.setBackOffPolicy(backOff);

        // 异常判断：哪些异常需要重试
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        retryPolicy.setMaxAttempts(5);
        template.setRetryPolicy(retryPolicy);

        return template;
    }
}

@Service
public class OrderService {

    @Autowired
    private RetryTemplate retryTemplate;

    public boolean processOrder(Long orderId) {
        return retryTemplate.execute(context -> {
            log.info("处理订单，第{}次尝试", context.getRetryCount() + 1);
            return doProcess(orderId);
        }, context -> {
            log.error("最终失败", context.getLastThrowable());
            return false;
        });
    }
}

spring:
  retry:
    max-attempts: 3    # 全局最大重试次数

@Service
public class SeckillService {

    @Retryable(
        value = OptimisticLockException.class,
        maxAttempts = 3,
        backoff = @Backoff(delay = 200)
    )
    public boolean deductStock(Long productId) {
        // 乐观锁失败时自动重试
        return productMapper.updateStock(productId) > 0;
    }
}