小伙伴是不是经常遇到接口调用异常，超时的场景？尤其网络抖动导致timeout超时的场景，我们一般产品就会叫我们要重试几次。,很多小伙伴的实现方式是写个循环调用；,这种实现方式是比较简单，但非常不灵活，不能针对很多种场景。今天老顾给大家带来一个retry重试组件，流行度很高，即是guava-retrying组件。功能简洁强大，是出门旅行的必备工具。,guava-retrying包中应用有相关的guava版本依赖，如果和自身项目冲突可以排除。,执行方法,里面定义了doExec方法,每次调用count加1，如果是2的倍数就抛异常。,调用方法,从上面代码中，我们就可以实现条件重试。,guava的retry的思想可分为重试条件、停止重试策略、重试间隔策略,表示在什么情况下，进行重试。retry组件中的RetryerBuilder的retryIfXXX()方法用来设置在什么情况下进行重试，总体上可以分为根据执行异常进行重试和根据方法执行结果进行重试两类。,1、retryIfException() 当方法执行抛出异常Exception时重试,2、retryIfRuntimeException()当方法执行抛出异常RuntimeException时重试,3、retryIfExceptionOfType(exceptionClass)当方法执行抛出异常具体哪个异常时重试,4、retryIfException(Predicate p)自定义异常什么情况下重试,retryIfResult(@Nonnull Predicate<V> resultPredicate)根据返回值判断是否重试。,上面的result代表的是返回值，判断返回值对3取余，返回true时则进行重试。,重试组件需要提供停止重试的策略withStopStrategy，最简单的方式就是重试几次,从字面上面就知道什么意思，即在执行次数达到指定次数之后停止重试。,此策略永远重试，一直重试,设定一个最长允许的执行时间；比如设定最长执行10s，无论任务执行次数，只要重试的时候与第一次执行的时间差，超出了最长时间，则任务终止，并返回重试异常RetryException,在重试场景中，我们最好有个重试的间隔，如果没有间隔，很有可能连续的重试都会失败。,1、FixedWaitStrategy,固定时长重试间隔。,上面即是重试间隔为1秒。,2、RandomWaitStrategy,随机的间隔时长,第1个参数是最小间隔时长，第二个参数最大间隔时长；介于两者之间随机取一个时长。,3、IncrementingWaitStrategy,递增间隔时长，即每次任务重试间隔时间逐步递增，越来越长,该策略输入一个起始间隔时间值和一个递增步长，然后每次等待的时长都递增increment时长。,4、ExceptionWaitStrategy,根据不同的异常，决定不同的间隔时长。,上面的代码 一看就知道了。,上面是常见的等待策略，还有几个不常用的等待策略，小伙伴们自行查阅。,到了这里，我们感觉还缺失了非常重要的一个模块；即是我们能否知道任务有没有经过重试？或者我们需要记录一下重试次数，或者重试的时候，弄一个error日志告警，帮助我们关注系统的稳健。,我们来介绍一下重试监听器。,当发送重试时，会调用RetryListener的onRetry方法，这样的话我们就可以做一些自定义的重试的额外任务。,定义一个类，继承RetryListener接口,在RetryerBuilder中加入；,这样就实现了监听业务,guava-retrying的组件功能还是比较强大的，我们可以看一下核心的代码
© 版权声明
文章版权归作者所有，未经允许请勿转载。
