导航：首页 > 互联网科技 >

Retry重试机制是什么意思

发表于：2025-12-03 作者：千家信息网编辑

千家信息网最后更新 2025年12月03日，这篇文章主要介绍"Retry重试机制是什么意思"，在日常操作中，相信很多人在Retry重试机制是什么意思问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"Retry重试机制

千家信息网最后更新 2025年12月03日Retry重试机制是什么意思

这篇文章主要介绍"Retry重试机制是什么意思"，在日常操作中，相信很多人在Retry重试机制是什么意思问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"Retry重试机制是什么意思"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

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是自定义阻塞策略。

@Beanpublic Retryer retry(){    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方法的具体实现逻辑。

@Slf4jpublic 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-04bcb88ad0562019-10-12 13:46:23.865  INFO 68012 --- [pool-1-thread-1] com.wj.retry.controller.RetryCallable    : call times=12019-10-12 13:46:23.875  INFO 68012 --- [pool-1-thread-1] com.wj.retry.controller.RetryCallable    : 请求时间: 2019-10-12T13:46:23.8742019-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，就这样两个步骤就完成了