Hi，大家好，我是编程小6，很荣幸遇见你，我把这些年在开发过程中遇到的问题或想法写出来，今天说一说
stupefy咒语怎么读_反弹一切诅咒的咒语,希望能够帮助你!!!。

1. 概览

在分布式场景中，Retry 和 Fallback 是最常见的容灾方案。

1. Retry 就是在调用远程接口失败时，Client 主动发起重试请求，以期待获得最终结果，从而完成整个流程
2. Fallback 是在调用远程接口失败时，Client 不进行重试而是调用一个特殊的 fallback 方法，从这个方法中获取结果，使流程能够继续下去

那 Retry 和 Fallback 该怎么抉择呢？

1.1. 背景

首先，先看下 Retry 和 Fallback 都是怎么帮助流程进行自我恢复的。

1.1.1. Retry

现在有一个生产流程：

image

核心流程如下：

1. 从商品服务中获取商品信息
2. 根据商品信息创建订单
3. 将订单保存到数据库

如果发生网络抖动，将导致生产失败。

image

1. 在调用商品服务获取商品时，由于网络异常，接口调用失败
2. 由于无法获取商品信息，生产流程被异常中断

由于上产流程太过重要，系统需尽最大努力保障用户能够完成下单操作，那针对网络抖动这个问题，可以通过 Retry 进行修复。

image

1. 在第一次获取商品信息时，由于网络问题导致获取失败
2. 系统不会直接抛出异常，而是在等待一段时间后，重新发起第二次请求，也就是 Retry 操作
3. 网络恢复，第二次请求成功获取商品信息
4. 流程继续运行，最终完成用户生产

Retry 机制非常适合服务短时间不可用，或某个服务节点异常 这类场景。

1.1.2. Fallback

一个生产验证接口，主流程如下：

image

1. 调用商品服务的接口获取商品信息
2. 根据商品和用户信息判断用户是否能够购买该商品

同样，假设在访问商品服务时出现网络异常：

image
由于无法获取商品信息，从而导致整个验证流程被异常中断，用户操作被迫终止。

聪明的你估计会说那就使用 Retry 呀，是的：

image
如果是短时不可用，通过 Retry 机制便可以恢复流程。

但，如果是商品服务压力过大，响应时间过长呢？比如，商品服务流量激增，导致 DB CPU 飙升，出现大量的慢 SQL，这时触发了系统的 Retry 会是怎样？

image

1. 在获取商品失败后，系统自动触发 Retry 机制
2. 由于是商品服务本身出了问题，第二次请求仍旧失败
3. 服务又触发了第三次请求，仍未获取结果
4. 达到最大重试次数，仍旧无法获取商品，只能通过异常中断用户请求

通过 Retry 机制未能将流程从异常中恢复过来，也给下游的 商品服务 造成了巨大伤害。

1. 商品服务压力大，响应时间长
2. 上游系统由于超时触发自动重试
3. 自动重试增大了对商品服务的调用
4. 商品服务请求量更大，更难以从故障中恢复

这就是常说的“读放大”，假设用户验证是否能够购买请求的请求量为 n，那极端情况下 商品服务的请求量为 3n （其中 2n 是由 Retry 机制造成）

此时，Retry 就不是一个好的方案。我们先退回业务场景进行思考，如果无法获取商品，验证接口是否可以直接放行，先让用户完成购买？

如果，这个业务假设能够接受的话，那就到了 Fallback 上场的时候了。

image

1. 调用商品服务获取商品信息失败
2. 系统不会进行重试，而是触发 fallback 机制
3. fallback 会调用指定的一个方法，并将返回值作为远程接口的返回值
4. 接下来的流程使用 fallback 方法的返回值完成业务逻辑

1.1.3. 场景思考

同样是对商品服务接口（同一个接口）的调用，在不同的场景需要使用不同的策略用以恢复业务流程，通常情况下：

1. Command 场景优先使用 Retry
2. 这种流量极为重要，最好能保障流程的完整性
3. 通常写流量比较小，小范围 Retry 不会对下游系统造成巨大影响
4. Query 场景优选使用 Fallabck
5. 大多数展示场景，哪怕部分信息没有获取到对整体的影响也比较小
6. 通常读场景流量较高，Retry 对下游系统的伤害不容忽视

那面对一个远程接口被多个场景使用，我们该怎么处理呢？

1. 提供两组接口，一个具有 Retry 能力，一个具有 Fallback 能力，由使用方根据业务场景进行选择？
2. 还是…

1.2. 目标

1. 远程接口具备 Retry 和 Fallback 能力
2. 能够根据上下文不同场景，在发生调用异常时动态选择 Retry 或 Fallback 进行流程恢复

2. 快速入门

2.1. 准备环境

项目主要依赖 spring retry 和 lego starter
首先，引入 spring-retry 依赖

<dependency>     <groupId>org.springframework.retry</groupId>     <artifactId>spring-retry</artifactId> </dependency> 

此次，引入 lego-starter 依赖

<dependency>     <groupId>com.geekhalo.lego</groupId>     <artifactId>lego-starter</artifactId>     <version>0.1.17</version> </dependency> 

最后新建 RetryConfiguration 以开启 Retry 能力

@EnableRetry @Configuration public class RetryConfiguration { } 

2.2. 构建 ActionTypeProvider

在完成基本配置后，需要准备一个 ActionTypeProvider 用以提供上下文信息。
ActionTypeProvider 接口定义如下：

public interface ActionTypeProvider {     ActionType get(); } public enum ActionType {     COMMAND, QUERY } 

通常情况下，我们会使用 ThreadLocal 组件将 ActionType 存储于线程上下文，在使用时从上下中获取相关信息。

public class ActionContext {     private static final ThreadLocal<ActionType> ACTION_TYPE_THREAD_LOCAL = new ThreadLocal<>();     public static void set(ActionType actionType){         ACTION_TYPE_THREAD_LOCAL.set(actionType);     }     public static ActionType get(){         return ACTION_TYPE_THREAD_LOCAL.get();     }     public static void clear(){         ACTION_TYPE_THREAD_LOCAL.remove();     } } 

有了上下文之后，ActionBasedActionTypeProvider 直接从 Context 中获取 ActionType 具体如下

@Component public class ActionBasedActionTypeProvider implements ActionTypeProvider {     @Override     public ActionType get() {         return ActionContext.get();     } } 

上下文中的 ActionType 又是怎么进行管理的呢，包括信息绑定和信息清理？
最常用的方式便是：

1. 提供一个注解，在方法上添加注解用于对 ActionType 的配置；
2. 提供一个拦截器，对方法调用进行拦截。方法调用前，从注解中获取配置信息并绑定到上下文；方法调用后，主动清理上下文信息；

核心实现为：

@Target({ ElementType.METHOD, ElementType.TYPE }) @Retention(RetentionPolicy.RUNTIME) public @interface Action {     ActionType type(); } @Aspect @Component @Order(Integer.MIN_VALUE) public class ActionAspect {     @Pointcut("@annotation(com.geekhalo.lego.faultrecovery.smart.Action)")     public void pointcut() {     }     @Around(value = "pointcut()")     public Object action(ProceedingJoinPoint joinPoint) throws Throwable {         MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();         Action annotation = methodSignature.getMethod().getAnnotation(Action.class);         ActionContext.set(annotation.type());         try {             return joinPoint.proceed();         }finally {             ActionContext.clear();         }     } } 

在这些组件的帮助下，我们只需在方法上基于 @Action 注解进行标记，便能够将 ActionType 绑定到上下文。

2.3. 使用 @SmartFault

在将 ActionType 绑定到上下文之后，接下来要做的便是对 远程接口 进行配置。远程接口的配置工作主要由 @SmartFault 来完成。
其核心配置项包括：

接下来，看一个 demo

@Service @Slf4j @Getter public class RetryService3 {     private int count = 0;     private int retryCount = 0;     private int fallbackCount = 0;     private int recoverCount = 0;     public void clean(){         this.retryCount = 0;         this.fallbackCount = 0;         this.recoverCount = 0;     }     /**     * Command 请求，启动重试机制     */     @Action(type = ActionType.COMMAND)     @SmartFault(recover = "recover")     public Long retry(Long input) throws Throwable{         this.retryCount ++;         return doSomething(input);     }     /**     * Query 请求，启动Fallback机制     */     @Action(type = ActionType.QUERY)     @SmartFault(recover = "recover")     public Long fallback(Long input) throws Throwable{         this.fallbackCount ++;         return doSomething(input);     }     @Recover     public Long recover(Throwable e, Long input){         this.recoverCount ++;         log.info("recover-{}", input);         return input;     }     private Long doSomething(Long input) {         // 偶数抛出异常         if (count ++ % 2 == 0){             log.info("Error-{}", input);             throw new RuntimeException();         }         log.info("Success-{}", input);         return input;     } } 

测试代码如下：

@SpringBootTest(classes = DemoApplication.class) public class RetryService3Test {     @Autowired     private RetryService3 retryService;     @BeforeEach     public void setup(){         retryService.clean();     }     @Test     public void retry() throws Throwable{         for (int i = 0; i < 100; i++){             retryService.retry(i + 0L);         }         Assertions.assertTrue(retryService.getRetryCount() > 0);         Assertions.assertTrue(retryService.getRecoverCount() == 0);         Assertions.assertTrue(retryService.getFallbackCount() == 0);     }     @Test     public void fallback() throws Throwable{         for (int i = 0; i < 100; i++){             retryService.fallback(i + 0L);         }         Assertions.assertTrue(retryService.getRetryCount() == 0);         Assertions.assertTrue(retryService.getRecoverCount() > 0);         Assertions.assertTrue(retryService.getFallbackCount() > 0);     } } 

运行 retry 测试，日志如下：

[main] c.g.l.c.f.smart.SmartFaultExecutor       : action type is COMMAND [main] c.g.l.faultrecovery.smart.RetryService3  : Error-0 [main] c.g.l.c.f.smart.SmartFaultExecutor       : Retry method public java.lang.Long com.geekhalo.lego.faultrecovery.smart.RetryService3.retry(java.lang.Long) throws java.lang.Throwable use [0] [main] c.g.l.faultrecovery.smart.RetryService3  : Success-0 

可见，当 action type 为 COMMAND 时：

1. 第一次调用时，触发异常，打印： Error-0
2. 此时 SmartFaultExecutor 主动进行重试，打印： Retry method xxxx
3. 方法重试成功，RetryService3 打印： Success-0

方法主动进行重试，流程从异常中恢复，处理过程和效果符合预期。

运行 fallback 测试，日志如下：

[main] c.g.l.c.f.smart.SmartFaultExecutor       : action type is QUERY [main] c.g.l.faultrecovery.smart.RetryService3  : Error-0 [main] c.g.l.c.f.smart.SmartFaultExecutor       : recover From ERROR for method ReflectiveMethodInvocation: public java.lang.Long com.geekhalo.lego.faultrecovery.smart.RetryService3.fallback(java.lang.Long) throws java.lang.Throwable; target is of class [com.geekhalo.lego.faultrecovery.smart.RetryService3] [main] c.g.l.faultrecovery.smart.RetryService3  : recover-0 

可见，当 action type 为 QUERY 时：

1. 第一次调用时，触发异常，打印： Error-0
2. SmartFaultExecutor 执行 Fallback 策略，打印：recover From ERROR for method xxxx
3. 调用RetryService3的 recover 方法，获取最终返回值。RetryService3 打印：recover-0

异常后自动执行 fallback，将流程从异常中恢复过来，处理过程和效果符合预期。

3. 设计&扩展

3.1 核心设计

image

整体流程如下：

1. ActionAspect 从 @Action 中读取配置信息，将请求类型绑定到线程上下文
2. 然后执行正常业务逻辑
3. 当调用 @SmartFault 注解的方法时，会被 SmartFaultMethodInterceptor 拦截器拦截
1. 拦截器通过 ActionTypeProvider 获取当前的 ActionType
2. 根据 ActionType 对请求进行路由
3. 如果是 COMMAND 操作，将使用 RetryTemplate 执行请求，在发生异常时，通过重试配置进行请求重发，从而最大限度的获得远程结果
4. 如果是 QUERY 操作，将使用 FallbackTemplate（重试次数为0的 RetryTemplate）执行请求，当发生异常时，调用 fallback 方法，执行配置的 recover 方法，直接使用返回结果
4. 获取远程结果后，执行后续的业务逻辑
5. 最后，ActionAspect 将 ActionType 从线程上下文中移除

4. 项目信息

项目仓库地址：https://gitee.com/litao/lego

项目文档地址：https://gitee.com/litao/lego/wikis/support/smart-fault

今天的分享到此就结束了，感谢您的阅读，如果确实帮到您，您可以动动手指转发给其他人。