Spring Boot集成 Spring Retry 实现容错重试机制教程配套源码

package com.toher.project.retry; import org.springframework.retry.RetryContext; import org.springframework.retry.RetryPolicy; /** * @Author 李怀明 * @Date 2024/6/13 8:19 PM * @Version 1.0 */ public class CustomRetryPolicy implements RetryPolicy { private final int maxAttempts; public CustomRetryPolicy(int maxAttempts) { this.maxAttempts = maxAttempts; } @Override public boolean canRetry(RetryContext context) { // 检查重试次数 int retryCount = context.getRetryCount(); if (retryCount >= maxAttempts) { return false; // 如果重试次数达到最大值，不再重试 } // 检查异常类型 Throwable lastException = context.getLastThrowable(); if (lastException instanceof MyCustomException) { // 如果是我们关心的特定异常类型，允许重试 return true; } // 其他情况下不允许重试 return false; } //MyCustomException 是你定义的异常类型 public class MyCustomException extends Exception { /* ... */ } @Override public RetryContext open(RetryContext retryContext) { return null; } @Override public void close(RetryContext retryContext) { } @Override public void registerThrowable(RetryContext retryContext, Throwable throwable) { } }