扒一扒@Retryable注解,很优雅,有点意思! (3)

简介: 扒一扒@Retryable注解,很优雅,有点意思! (3)

image.png

一眼就能看出来了,这里面就是应该非常熟悉的动态代理机制,这里的 invocation 就是我们的 callChannel 方法:


image.png

从代码我们知道,callChannel 方法抛出的异常,在 doWithRetry 方法里面会进行捕获,然后直接扔出去:

image.png

这里其实也很好理解的,因为需要抛出异常来触发下一次的重试。

但是这里也暴露了一个 Spring-retry 的弊端,就是必须要通过抛出异常的方式来触发相关业务。

听着好像也是没有毛病,但是你想想一下,假设渠道方说如果我给你返回一个 500 的 ErrorCode,那么你也可以进行重试。

这样的业务场景应该也是比较多的。

如果你要用 Spring-retry 会怎么做?

是不是得写出这样的代码:

if(errorCode==500){
    throw new Exception("手动抛出异常");
}

意思就是通过抛出异常的方式来触发重试逻辑,算是一个不是特别优雅的设计吧。

其实根据返回对象中的某个属性来判断是否需要重试对于这个框架来说扩展起来也不算很难的事情。

你想,它这里本来就能拿到返回。只需要提供一个配置的入口,让我们告诉它当哪个对象的哪个字段为某个值的时候也应该进行重试。

当然了,大佬肯定有自己的想法,我这里都是一些不成熟的拙见而已。其实另外的一个重试框架 Guava-Retry,它就支持根据返回值进行重试。

不是本文重点就不扩展了。

接着往下看 while 循环中捕获异常的部分。

里面的逻辑也不复杂,但是下面框起来的部分可以注意一下:

image.png

这里又判断了一次是否可以重试,是干啥呢?

是为了执行这行代码:

backOffPolicy.backOff(backOffContext);

它是干啥的?

我也不知道,debug 看一眼,最后会走到这个地方:

org.springframework.retry.backoff.ThreadWaitSleeper#sleep


image.png

在这里执行睡眠 1000ms 的操作。

我一下就懂了,这玩意在这里给你留了个抓手,你可以设置重试间隔时间的抓手。然后默认给你赋能 1000ms 后重试的功能。


image.png

然后我在 @Retryable 注解里面找到了这个东西:

image.png

这玩意一眼看不懂是怎么配置的,但是它上面的注解叫我看看 Backoff 这个玩意。

它长这样:

image.png

这东西看起来就好理解多了,先不管其他的参数吧,至少我看到了 value 的默认值是 1000。

我怀疑就是这个参数控制的指定重试间隔,所以我试了一下:

image.png

果然是你小子,又让我挖到一个彩蛋。

在 @Backoff 里面,除了 value 参数,还有很多其他的参数,他们的含义分别是这样的:

  • delay:重试之间的等待时间(以毫秒为单位)
  • maxDelay:重试之间的最大等待时间(以毫秒为单位)
  • multiplier:指定延迟的倍数
  • delayExpression:重试之间的等待时间表达式
  • maxDelayExpression:重试之间的最大等待时间表达式
  • multiplierExpression:指定延迟的倍数表达式
  • random:随机指定延迟时间

就不一一给你演示了,有兴趣自己玩去吧。

因为丰富的重试时间配置策略,所以也根据不同的策略写了不同的实现:

image.png

通过 Debug 我知道了默认的实现是 FixedBackOffPolicy。

其他的实现就不去细研究了,我主要是抓主要链路,先把整个流程打通,之后自己玩的时候再去看这些枝干的部分。

在 Demo 的场景下,等待一秒钟之后再次发起重试,就又会再次走一遍 while 循环,重试的主链路就这样梳理清楚了。

其实我把代码折叠一下,你可以看到就是在 while 循环里面套了一个 try-catch 代码块而已:

image.png

这和我们之前写的丑代码的骨架是一样的,只是 Spring-retry 把这部分代码进行扩充并且藏起来了,只给你提供一个注解。

当你只拿到这个注解的时候,你把它当做一个黑盒用的时候会惊呼:这玩意真牛啊。

但是现在当你抽丝剥茧的翻一下源码之后,你就会说:就这?不过如此,我觉得也能写出来啊。

image.png

到这里前面抛出的问题中的前两个已经比较清晰了:

问题一:找到它的 for 循环在哪里。

没有 for 循环,但是有个 while 循环,其中有一个 try-catch。

问题二:它是怎么判断应该要重试的?

判断要触发重试机制的逻辑还是非常简单的,就是通过抛出异常的方式触发。

但是真的要不要执行重试,才是一个需要仔细分析的重点。

Spring-retry 有非常多的重试策略,默认是 SimpleRetryPolicy,重试次数为 3 次。

但是需要特别注意的是它这个“3次”是总调用次数为三次。而不是第一次调用失败后再调用三次,这样就共计 4 次了。关于到底调用几次的问题,还是得分清楚才行。

而且也不一定是抛出了异常就肯定会重试,因为 Spring-retry 是支持对指定异常进行处理或者不处理的。

可配置化,这是一个组件应该具备的基础能力。

还是剩下最后一个问题:它是怎么执行到 @Recover 逻辑的?

接着怼源码吧。

目录
相关文章
|
SQL Java Apache
skywalking 搭建(apache-skywalking-apm-es7-7.0.0)
skywalking 搭建(apache-skywalking-apm-es7-7.0.0)
814 0
|
SQL Java 数据库连接
成功解决:was not registered for synchronization because synchronization is not active
这篇文章是关于解决Mybatis在同步过程中出现"was not registered for synchronization because synchronization is not active"错误的技术博客。
成功解决:was not registered for synchronization because synchronization is not active
|
安全 Java
java.security.InvalidKeyException: Illegal key size。
java.security.InvalidKeyException: Illegal key size。
418 0
|
缓存 NoSQL Java
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
192 3
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
|
分布式计算 DataWorks MaxCompute
DataWorks产品使用合集之怎么更改ODPS表的生命周期为永久
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
SQL 存储 数据库
MSSQL数据库性能调优实战:索引、查询与并发控制的深度剖析
在数据库管理领域,Microsoft SQL Server(MSSQL)的性能调优是保障业务高效运行的核心任务
|
Devops 测试技术 开发工具
devops| git hooks 实战: 防分支 merge
基于工作中 git 工作流遇到的问题, 实战 git hooks, 防止测试分支合并到开发分支
699 0
|
缓存 Java Maven
Google guava工具类库的介绍和使用
Google guava工具类库的介绍和使用
|
对象存储
使用流式下载从阿里OSS获取PDF文件
使用流式下载从阿里OSS获取PDF文件
1170 1
|
智能设计
阿里云产品体系分为6大分类——企业应用——分为11类——智能设计服务
阿里云产品体系分为6大分类——企业应用——分为11类——智能设计服务自制脑图
254 1