建站
咨询
售后
建站咨询
这篇文章主要介绍“Retry重试机制是什么意思”，在日常操作中，相信很多人在Retry重试机制是什么意思问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Retry重试机制是什么意思”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
十年专注建站、设计、互联网产品定制制作服务，业务涵盖成都品牌网站建设、商城开发、成都微信小程序、软件系统开发、成都app软件开发公司等。凭借多年丰富的经验，我们会仔细了解每个客户的需求而做出多方面的分析、设计、整合，为客户设计出具风格及创意性的商业解决方案，创新互联公司更提供一系列网站制作和网站推广的服务，以推动各中小企业全面信息数字化，并利用创新技术帮助各行业提升企业形象和运营效率。
1.前言
在项目开发中，有的时候，总是避免不了调用第三方服务接口，有的时候可能因为网络等情况的因素，我们需要重试几次才能调用成功，所以就需要一重试机制来保证接口的正常访问。
2.guava-retrying
这是谷歌guava提供的工具包，我们可以在项目中引入相应的包，很轻松实现重试访问。guava-retrying中大量运用的策略模式，可以自定义各种执行重试策略。下面是简单实用步骤。
①. pom引入
com.google.guava guava 19.0 com.github.rholder guava-retrying 2.0.0
②. 基础业务代码
我这里实现一个对接口的简单访问，以此来模拟访问第三方接口。
@GetMapping("/retrytest")
public Map retrytest(){
Map resultMap = Maps.newHashMap();
resultMap.put("id", 1001L);
resultMap.put("msg", "测试");
Map tokenMap = Maps.newHashMap();
tokenMap.put("token", UUID.randomUUID().toString());
resultMap.put("data", tokenMap);
return resultMap;
} ③.Retryer Bean
Retryer中定义重试的各种策略，在执行call方法的时候，会将这些重试策略一一使用。
RetryListener是重试监听器，可以监听每次重试的过程。
BlockStrategy是自定义阻塞策略。
@Bean public Retryerretry(){ RetryListener retryListener = new RetryListener() { @Override public void onRetry(Attempt attempt) { try { if(attempt.hasException()){ log.error("---"+ Arrays.toString(attempt.getExceptionCause().getStackTrace())); }else { log.info("---"+ attempt.get().toString()); } } catch (Exception e) { e.printStackTrace(); } } }; BlockStrategy blockStrategy = new BlockStrategy() { @Override public void block(long sleepTime) throws InterruptedException { LocalDateTime startTime = LocalDateTime.now(); long start = System.currentTimeMillis(); long end = start; log.info("[SpinBlockStrategy]...begin wait."); while (end - start <= sleepTime) { end = System.currentTimeMillis(); } //使用Java8新增的Duration计算时间间隔 Duration duration = Duration.between(startTime, LocalDateTime.now()); log.info("[SpinBlockStrategy]...end wait.duration={}", duration.toMillis()); } }; Retryer retryer = RetryerBuilder. newBuilder() //retryIf 重试条件 .retryIfException() .retryIfRuntimeException() .retryIfExceptionOfType(Exception.class) .retryIfException(Predicates.equalTo(new Exception())) //等待策略：每次请求间隔1s // .withWaitStrategy(WaitStrategies.fixedWait(1, TimeUnit.SECONDS)) //停止策略 : 尝试请求3次 .withStopStrategy(StopStrategies.stopAfterAttempt(3)) //时间限制 : 某次请求不得超过2s , 类似: TimeLimiter timeLimiter = new SimpleTimeLimiter(); .withAttemptTimeLimiter(AttemptTimeLimiters.fixedTimeLimit(2, TimeUnit.SECONDS)) .withRetryListener(retryListener) .withBlockStrategy(blockStrategy) .build(); return retryer; }
④.Callable实现
编写retryer调用call方法的具体实现逻辑。
@Slf4j public class RetryCallable implements Callable{ private RestTemplate restTemplate; public RetryCallable(RestTemplate restTemplate) { this.restTemplate = restTemplate; } int times = 1; @Override public String call() { log.info("call times={}", times++); log.info("请求时间: {}", LocalDateTime.now()); //对远程地址的访问 return Objects.requireNonNull( restTemplate.getForObject("http://localhost:8080/retrytest", Object.class)).toString(); } }
⑤. 重试器 call调用
@GetMapping("/hello")
public Object hello(@RequestParam(required = false) String token){
log.info("hello "+ token);
Map result = null;
String msg = "";
try {
//定义请求实现 利用重试器调用请求
String callResult = retryer.call(new RetryCallable(restTemplate));
result = new Gson().fromJson(callResult, Map.class);
} catch (Exception e) {
e.printStackTrace();
msg = e.getMessage();
log.warn("请求失败：{}",e.getMessage());
}
HashMap resultData = Maps.newHashMap();
resultData.put("data",result);
resultData.put("token",token);
resultData.put("msg",msg);
return resultData;
} 调用接口测试
2019-10-12 13:46:23.863 INFO 68012 --- [nio-8080-exec-1] com.wj.retry.controller.HelloController : hello f5b78e95-87f7-435e-b9be-04bcb88ad056
2019-10-12 13:46:23.865 INFO 68012 --- [pool-1-thread-1] com.wj.retry.controller.RetryCallable : call times=1
2019-10-12 13:46:23.875 INFO 68012 --- [pool-1-thread-1] com.wj.retry.controller.RetryCallable : 请求时间: 2019-10-12T13:46:23.874
2019-10-12 13:46:24.068 INFO 68012 --- [nio-8080-exec-1] com.wj.retry.RetryApplication : ---{msg=测试, data={token=eacb4a99-9ef9-4581-b8e5-28fdabac1c52}, id=1001}若失败会调用多次（按照重试器中定义的策略）并，抛出异常
3.spring-retry
上面的实现会写相对较多的代码，若使用spring-retry则相对简单多了，可以基于注解实现
①. pom配置
org.springframework.retry spring-retry
②. 注解配置重试策略
@Retryable的参数说明：
value：抛出指定异常才会重试
include：和value一样，默认为空，当exclude也为空时，默认所以异常
exclude：指定不处理的异常
maxAttempts：最大重试次数，默认3次
backoff：重试等待策略，默认使用@Backoff，@Backoff的value默认为1000L，我们设置为2000L；multiplier（指定延迟倍数）默认为0，表示固定暂停1秒后进行重试，如果把multiplier设置为1.5，则第一次重试为2秒，第二次为3秒，第三次为4.5秒。
@Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 2000L, multiplier = 1.5))
public Object retry(@RequestParam(required = false) String token) {
String msg = "";
log.info("springretry");
log.info("请求时间: {}", LocalDateTime.now());
String resultStr = Objects.requireNonNull(
restTemplate.getForObject("http://localhost:8080/retrytest", Object.class)).toString();
Map result = new Gson().fromJson(resultStr, Map.class);
HashMap resultData = Maps.newHashMap();
resultData.put("data",result);
resultData.put("token",token);
resultData.put("msg",msg);
return resultData;
} 最后在启动类上加上@EnableRetry注解开启重试机制。ok，就这样两个步骤就完成了
4.举例重试机制的运用
除了上面调用第三方服务接口可能会用到重试机制，在微服务项目中，服务之间的通信，重试机制可以说是随处可见。
在springcloud中Ribbon，feign，Hystrix等组件都可以自己配置重试机制，来达到提高能正常通信的成功率。
此外，在各种消息中间件中也都有重试机制的体现，例如kafka，消息发送失败可以重新发送，消息消费失败了，也可以配置重试机制，可以最大程度达到消息的不丢失。
5.目标服务要考虑的问题
可以考虑这么一个事情，若目标逻辑执行时间过长，超出了重试的等待时间，客户端就要发起重试，那么服务端就会出现重复调用执行的问题，所以，有重试机制就要考虑幂等性的问题。
到此，关于“Retry重试机制是什么意思”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！
网站栏目：Retry重试机制是什么意思
当前路径：http://scpingwu.com/article/iggsos.html
