vlambda博客
学习文章列表

Hystrix微服务容错处理及回退方法源码分析(微服务)

前言

在 SpringCloud 微服务项目中,我们有了 Eureka 做服务的注册中心,进行服务的注册与发现和服务治理。使得我们可以摒弃硬编码式的 ip:端口 + 映射路径 来发送请求。我们有了 Feign 作为声明式服务调用组件,可以像调用本地服务一样来调用远程服务。基于 Ribbon 我们又实现了客户端负载均衡,轻松的在集群环境下选取合适的服务提供者。这样看来我们的微服务貌似很完善了。是这样的吗?

并非如此,想想我们在编码过程中进行的健壮性检查。类比一下服务与服务调用是否也应该更加健壮一些呢?我们目前的微服务在正常运行的时候是没有问题的,但若是某个偏下游的服务提供者不可用,造成服务积压,接连引起上游的服务消费者宕机,引法雪崩效应。是不是就显得我们的微服务不堪一击呢?因此我们需要一个组件来解决这样的问题,前辈们参考生活中保险丝的原理做出了微服务中的保险丝-Hystrix熔断器。下面让我们来一起使用一下

Hystrix简介

Hystrix主要实现了下面的功能:

  • 包裹请求:使用 HystrixCommand(或 HystrixObservableCommand) 包裹对依赖的调用逻辑。每个命令在独立的线程中执行,使用了设计模式中的‘命令模式’

  • 跳闸机制:当某微服务的错误率超过一定阈值时,可以自动跳闸,停止请求该服务一段时间

  • 资源隔离:Hystrix 为每个微服务都维护了一个小型的线程池(或信号量)如果该线程池已满,发往该依赖的请求就会被立即拒绝

  • 监控:Hystrix 可以近乎实时的监控运行指标和配置的变化,例如成功、失败、超时和被拒绝的请求等

  • 回退机制:当请求成功、失败、超时和被拒绝或者断路器打开时,执行回退逻辑。回退逻辑可由开发人员自行提供

  • 自我修复:断路器打开一段时间后,会进入‘半开’状态,允许一个请求访问服务提供方,如果成功。则关闭断路器


使用 Hystrix


引入依赖

<!-- 熔断器 hystrix --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency>

在启动类上添加 @EnableHystrix


两种情况下的回退方法

非 Feign 调用下的回退方法

编写回退方法
/** * getUserByAge 方法 Hystrix 回退方法 * @param age * @return */public User getUserByAgeFallBack(Integer age){ User user = new User(); user.setName("默认用户"); user.setAge(age);return user;}
在客户端的方法上声明
@HystrixCommand(fallbackMethod = "getUserByAgeFallBack")

测试:将服务提供方的代码打断点。调用服务消费方,会发现返回了默认用户

需要注意:

  1. 回退方法的返回值类型需要和原来方法返回值类型相同(否则会报 FallbackDefinitionException: Incompatible return types)

  2. 回退方法的参数列表也要和原来方法相同(否则会报 FallbackDefinitionException: fallback method wasn't found: getUserByAgeFallBack([class java.lang.Integer]))

  3. 当我写下第二句时,发现书中下一节介绍说可以通过在回退方法中添加第二个参数:ThrowEable 来捕获异常,分析调用失败的原因,我就知道我错了。为了避免继续得到错误的结论,我决定读一读 Hystrix 处理回退方法的源码

加点料:Hystrix 对回退方法的封装的源码如下:
com.netflix.hystrix.contrib.javanica.utils.MethodProviderpublic FallbackMethod find(Class<?> enclosingType, Method commandMethod, boolean extended) {// 首先判断该方法的 HystrixCommand 注解上有没有 defaultFallback / fallbackMethod 配置回退方法名称if (this.canHandle(enclosingType, commandMethod)) {// 调用 doFind 方法return this.doFind(enclosingType, commandMethod, extended); } else {// 没有配置的化就接着下一个判断return this.next != null ? this.next.find(enclosingType, commandMethod, extended) : FallbackMethod.ABSENT; }}

find 方法在用户所请求的方法的 HystrixCommand 注解上有用 defaultFallback / fallbackMethod 配置回退方法名称的时候,会调用 doFind 方法来寻找回退方法。该方法的参数有两个,enclosingType 是用户所请求的方法的类字节码文件,commandMethod 是用户所请求的方法

首先通过 this.getFallbackName 获取回退方法名称,接着通过获取 commandMethod 的参数类型们

接着分两种情况:

  1. 回调方法继承于 commandMethod 且最后一个参数类型是 Throwable,则去掉回退方法参数列表中的 Throwable 类型进行匹配

  2. 回调方法不继承于 commandMethod ,则存在两个可能的参数类型列表:fallbackParameterTypes 和 extendedFallbackParameterTypes 前者是 commandMethod 是参数列表,后者是前者 + Throwable。然后两个都进行匹配。接着使用 Java8 Optional API,按顺序选取前者匹配到的方法 / 后者 / 空返回

private FallbackMethod doFind(Class<?> enclosingType, Method commandMethod, boolean extended) { String name = this.getFallbackName(enclosingType, commandMethod); Class<?>[] fallbackParameterTypes = null; if (this.isDefault()) { fallbackParameterTypes = new Class[0]; } else { fallbackParameterTypes = commandMethod.getParameterTypes(); }
if (extended && fallbackParameterTypes[fallbackParameterTypes.length - 1] == Throwable.class) { fallbackParameterTypes = (Class[])ArrayUtils.remove(fallbackParameterTypes, fallbackParameterTypes.length - 1); }
Class<?>[] extendedFallbackParameterTypes = (Class[])Arrays.copyOf(fallbackParameterTypes, fallbackParameterTypes.length + 1); extendedFallbackParameterTypes[fallbackParameterTypes.length] = Throwable.class; Optional<Method> exFallbackMethod = MethodProvider.getMethod(enclosingType, name, extendedFallbackParameterTypes); Optional<Method> fMethod = MethodProvider.getMethod(enclosingType, name, fallbackParameterTypes); Method method = (Method)exFallbackMethod.or(fMethod).orNull(); if (method == null) { throw new FallbackDefinitionException("fallback method wasn't found: " + name + "(" + Arrays.toString(fallbackParameterTypes) + ")"); } else { return new FallbackMethod(method, exFallbackMethod.isPresent(), this.isDefault()); }}

由源码可以得到结论:回退方法要么参数列表和原始方法相同,要么加且仅加一个类型为 Throwable 的参数。其他的都不行

Feign 客户端下的回退方法

  1. 设置:feign.hystrix.enabled: true

  2. Feign 客户端接口上的 @FeignClient 添加 fallback 属性,指向回退类

  3. 回退类实现客户端接口

# feign的配置feign: hystrix: enabled: true # 打开 feign 的 hystrix 支持

注意回退类加上 @Component 接口,避免因为 Spring 容器找不到该类而启动报错

// Feign 客户端接口上的 @FeignClient 添加 fallback 属性,指向回退类@FeignClient(name = "SERVICE-PROVIDER", fallback = UserServiceFeignClientFallBack.class)public interface UserServiceFeignClient {
@GetMapping("/api/v1/user/{age}") User getUser(@PathVariable("age") Integer age);
/** * 用户列表 * @return */ @GetMapping("/api/v1/users") List<User> getUsers();}// 回退类实现客户端接口@Component public class UserServiceFeignClientFallBack implements UserServiceFeignClient { @Override public User getUser(Integer age) { return null; }
@Override public List<User> getUsers() { return null; }}


当采用 Feign 客户端来实现回退的时候,前面的捕捉异常方法就不起作用了,那我们应该如何来处理异常呢?可以使用 @FeignClient 的 fallbackFactory 属性

@FeignClient(name = "SERVICE-PROVIDER", fallbackFactory = UserServiceFallbackFactory.class)
@Component@Slf4jpublic class UserServiceFallbackFactory implements FallbackFactory<UserServiceFeignClient> { @Override public UserServiceFeignClient create(Throwable t) { // 日志最好写在各个 fallback 方法中,而不要直接卸载 create方法中 // 否则引用启动时就会打印该日志
return new UserServiceFeignClient() { @Override public User getUser(Integer age) { log.info("调用User服务提供者失败", t); User user = new User(); user.setName("默认用户"); user.setAge(age); return user; }
@Override public List<User> getUsers() { return null; } }; }}

注意:**fallback 和 fallbackFactory 属性同时存在时,fallback 的优先级更高。因此开发中如果需要处理异常,只需配置 fallbackFactory 属性即可 **


避免业务异常走进回退方法

在某些场景下,当发生业务异常时,我们并不想触发 fallback。例如业务中判断年龄 age 不能小于 1,否则抛出异常

if(age < 1){ throw new KeatsException(ExceptionEnum.NUM_LESS_THAN_MIN);}


这时 Hystrix 会捕捉到异常然后执行 fallback 方法,我们可以通过下面两个方法来避免:
  1. 继承 HystrixBadRequestException 该类继承自 RunntimeException

  2. 在 @HystrixCommand 添加属性 ignoreExceptions = {KeatsException.class}


为 Feign 禁用 Hystrix

只要打开 feign 的 hystrix 支持开关,feign 就会使用断路器包裹 feign 客户端的所有方法,但很多场景并不需要这样。该如何禁用呢?
  • 为指定客户端禁用。需要借助 Feign 的自定义配置。首先添加一个自定义配置类,然后配置到 @FeignClient 的 configuration 属性中

@Configurationpublic class FeignDisableHystrixConfiguration { @Bean @Scope("prototype") public Feign.Builder feignBuilder(){ return Feign.builder(); }}
@FeignClient(name = "SERVICE-PROVIDER", configuration = {FeignDisableHystrixCon
    figuration.class})
  • 全局禁用:feign.hystrix.enabled: false

源码地址

原地址:  https://github.com/keatsCoder/cloud-cli
码云地址:https://gitee.com/code_to_attack/cloud-cli

https://www.cnblogs.com/keatsCoder/p/13028727.html