<dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> </dependency>启用@Retryable
@EnableRetry @SpringBootApplication public class HelloApplication { public static void main(String[] args) { SpringApplication.run(HelloApplication.class, args); } }在方法上添加@Retryable
import com.mail.elegant.service.TestRetryService; import org.springframework.retry.annotation.Backoff; import org.springframework.retry.annotation.Retryable; import org.springframework.stereotype.Service; import java.time.LocalTime; @Service public class TestRetryServiceImpl implements TestRetryService { // 堆代码 duidaima.com @Override @Retryable(value = Exception.class,maxAttempts = 3,backoff = @Backoff(delay = 2000,multiplier = 1.5)) public int test(int code) throws Exception{ System.out.println("test被调用,时间:"+LocalTime.now()); if (code==0){ throw new Exception("情况不对头!"); } System.out.println("test被调用,情况对头了!"); return 200; } }来简单解释一下注解中几个参数的含义:
backoff:重试等待策略,默认使用@Backoff,@Backoff的value默认为1000L,我们设置为2000L;multiplier(指定延迟倍数)默认为0,表示固定暂停1秒后进行重试,如果把multiplier设置为1.5,则第一次重试为2秒,第二次为3秒,第三次为4.5秒。
@Recover public int recover(Exception e, int code){ System.out.println("回调方法执行!!!!"); //记日志到数据库 或者调用其余的方法 return 400; }可以看到传参里面写的是 Exception e,这个是作为回调的接头暗号(重试次数用完了,还是失败,我们抛出这个Exception e通知触发这个回调方法)。对于@Recover注解的方法,需要特别注意的是:
3.该回调方法与重试方法写在同一个实现类里面