spring-retry主要是为了规范化请求重试的逻辑,主要应用于调用外部服务的场景,使用例子如下:
RetryTemplate template = new RetryTemplate(); // 重试策略:次数重试策略 SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(3, Collections.singletonMap(Exception.class, true)); template.setRetryPolicy(retryPolicy); // 退避策略:指数退避策略 ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy(); backOffPolicy.setInitialInterval(100); backOffPolicy.setMaxInterval(3000); backOffPolicy.setMultiplier(2); backOffPolicy.setSleeper(new ThreadWaitSleeper()); template.setBackOffPolicy(backOffPolicy);
主要的类说明如下:
1 重试策略: SimpleRetryPolicy policy = new SimpleRetryPolicy(5, Collections.singletonMap(Exception.class, true));
参数retrableExceptions表示哪些异常类需要重试,可以不填,不填时默认就是Collections.singletonMap(Exception.class, true)
2 退避策略:指数退避策略
ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy(),表示重试的间隔,为了防止固定间隔同时进行请求重试,最好使用非固定时间的重试间隔,等待
期间是Thread.sleep(backOffPeriod)实现的休眠
3 RetryContext上下文对象可以知道当前的重试次数,最近一次的异常对象等信息
4 RecoveryCallback对象是在重试次数达到最大值时兜底 *** 作,比如返回null值,或者一个默认值
5 spring-retry也实现了简单的熔断器的功能
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)