spring retry and guava retry demo

从spring retry 官方copy: To make processing more robust and less prone to failure, it sometimes helps to automatically retry a failed operation, in case it might succeed on a subsequent attempt. Errors that are susceptible to this kind of treatment are transient in nature. For example, a remote call to a web service or an RMI service that fails because of a network glitch or a DeadLockLoserException in a database update may resolve itself after a short wait. To automate the retry of such operations, Spring Retry has the RetryOperations strategy.

为了使处理更加健壮，减少失败的可能性，有时候自动重试失败的操作。 目前有两个开源的类库 spring retry and guava retry 都支持编程式，spring retry 更加融合spring的aop 注解驱动，使用更加的方便。

模拟异常场景

为了实现demo，模拟了异常的场景

• 异常调用

http://localhost:8080/unstableApi/500

• 调用正常

http://localhost:8080/unstableApi/200

@RestController
public class MockApiController {

    /**
     * 模拟服务不正常
     *
     * @param status
     * @return
     */
    @GetMapping("/unstableApi/{status}")
    public ResponseEntity<Integer> unstableApi(@PathVariable int status) {
        if (INTERNAL_SERVER_ERROR.value() == status) {
            throw new ResponseStatusException(INTERNAL_SERVER_ERROR);
        }
        if (UNAUTHORIZED.value() == status) {
            throw new ResponseStatusException(UNAUTHORIZED);
        }
        return ResponseEntity.ok(status);
    }

}

实践

spring retry支持有状态和无状态两种方式。一般理解使用无状态。

• 无状态: 无状态就是当前线程继续处理，spring retry 通过获取到异常后继续在当前线程重试。

• 有状态: 类比http,http 调用是无状态的，为了增加访问状态可能增加cookie 标识一个人的访问，当前的多次访问是否是一个人; spring retry 中有状态我这么理解,多次调用不直接的在当前线程重试，将异常抛出,标识为【当前方法参数+方法名称】,记录下当前失败的key对应的记录。 下一次在继续调用对于相同的key可以进行失败统计，如果达到目标失败次数，会调用失败处理的兜底回调org.springframework.retry.RecoveryCallback 进行记录。 spring retry 中的 stateful 如何使用？

配置开关进行测试,要测试 将开关配置为true 即可观察日志!

#com.wangji92.retry.springretryexample.task.SchedulingTestRetryTask
#测试 retry的效果 是通过编程的方式 、还是通过 aop注解的方式测试

aopSpringRetry=true
programmingSpringRetry=false
programmingGuavaRetry=false

# 有状态的重试  com.wangji92.retry.springretryexample.task.SchedulingTestStateFullRetryTask
aopStateFullRetry=false
programmingStateFullRetry=false

所有的场景都是通过定时器进行调用模拟,具体使用可以参考链接

• aopSpringRetry aop 实践无状态重试 SchedulingTestRetryTask#AopSpringRetry
• programmingSpringRetry 编程实践spring retry SchedulingTestRetryTask#ProgrammingSpringRetry
• programmingGuavaRetry 编程实践guava retry SchedulingTestRetryTask#ProgrammingGuavaRetry
• aopStateFullRetry aop 实践spring retry 有状态 SchedulingTestStateFullRetryTask#AopStateFullRetry
• programmingStateFullRetry 编程实践spring retry 有状态 SchedulingTestStateFullRetryTask#ProgrammingStateFullRetry

配置

spring retry

@EnableRetry(proxyTargetClass = true)

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
    <version>1.3.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

guava retry

<dependency>
    <groupId>com.github.rholder</groupId>
    <artifactId>guava-retrying</artifactId>
    <version>2.0.0</version>
</dependency>

withAttemptTimeLimiter 会导致执行业务的线程和调用线程非一个线程执行，会带来事务问题、线程上下文传递问题 还有一个问题 guava-retrying 对于最新版本的guava 没有支持 rholder/guava-retrying#66 使用的时候一定要小心啦，默认使用最新版本的guava,不推荐使用。

 // RetryerBuilder 构建重试实例 guavaRetryer,可以设置重试源且可以支持多个重试源，可以配置重试次数或重试超时时间，以及可以配置等待时间间隔
Retryer<Integer> guavaRetryer = RetryerBuilder.<Integer>newBuilder()
        //设置异常重试源 根据异常 也可以 retryIfResult 根据结果
        .retryIfExceptionOfType(RemoteAccessException.class)

        // 【这里将会使用多线程执行(other 线程执行、会导致事务问题、线程上下文传递问题 一定要小心)】 还有这个框架 这个属性高版本不支持了.
        .withAttemptTimeLimiter(new FixedAttemptTimeLimit<Integer>(1, TimeUnit.MINUTES))
        //设置等待间隔时间
        .withWaitStrategy(WaitStrategies.fixedWait(5, TimeUnit.SECONDS))
        //设置最大重试次数
        .withStopStrategy(StopStrategies.stopAfterAttempt(2))
        .build();

spring retry 框架的理解

spring retry 框架的理解 博客

参考文档

• spring retry

• guava-retry