04基于Hystrix的服务熔断和降级

一 Hystrix理解

用于隔离访问远程系统、服务或者第三方库，防止级联失败，从而提升系统的可用性与容错性。

二 基于RestTemplate的服务降级

2.1 某个业务方法上提供降级处理

当通过传统的restTemplate或者Ribbon的方式远程调用时，可以使用该方法实现服务降级

1. 引入hystrix的依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

2. 在启动类上开启熔断器的支持

@EnableCircuitBreaker //开启熔断器

3. 配置降级的服务逻辑

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/{id}")
    @HystrixCommand(fallbackMethod = "fallback") //配置该请求的服务降级方法
    public Product getProductById(@PathVariable Long id){
        Product product = restTemplate.getForObject("http://product/product/" + id, Product.class);
        return product;
    }

    //服务降级方法逻辑
    public Product fallback(Long id){
        Product product = new Product();
        product.setProductName("调用失败，触发熔断降级方法，id："+id);
        return product;
    }
}

2.2 类全局的服务降级方法

• 注：全局的降级方法要有同一的返回类型，否则不同方法的返回值不一致会出现问题

@RestController
@RequestMapping("/order")
@DefaultProperties(defaultFallback = "fallback") //类全局的服务降级方法
public class OrderController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/{id}")
    @HystrixCommand //表示需要使用Hystrix服务
    public Product getProductById(@PathVariable Long id){
        Product product = restTemplate.getForObject("http://product/product/" + id, Product.class);
        return product;
    }

    //全局服务降级方法逻辑
    public Product fallback(){
        Product product = new Product();
        product.setProductName("调用失败，触发全局的熔断降级方法");
        return product;
    }
}

2.3 Hystrix超时设置

请求默认超过1秒后还未获得调用服务的数据时，Hystrix将会直接调用服务降级方法。通过配置可以改变该参数

hystrix:
 command:
  default:
   execution:
    isolation:
     thread:
      timeoutInMilliseconds: 5000

三 基于Feign的服务降级

Fegin默认已为Feign整合了hystrix，所以添加Feign依赖后就不用在添加hystrix

1. Feign中已经内置了hystrix，但是默认是关闭，需要在yaml中配置开启hystrix的支持

feign:
 hystrix: #在feign中开启hystrix熔断
  enabled: true

2. 配置FeignClient接口的实现类

@Component //加入Spring容器
public class ProductFeignClientFallback implements ProductFeignClient {
    @Override
    public Product getProductById(Long id) { //编写降级的方法逻辑
        Product product = new Product();
        product.setProductName("调用失败，触发Feign的熔断降级方法,id:"+id);
        return product;
    }
}

3. 修改FeignClient接口添加hystrix熔断

//在@FeignClient注解中添加降级方法
@FeignClient(name = "product",fallback = ProductFeignClientFallback.class)
public interface ProductFeignClient {

    @GetMapping("/product/{id}")
    public Product getProductById(@PathVariable Long id);

}

四 Hystrix的监控平台

1. 导入依赖

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>

2. 在启动类上添加激活仪表盘的注解

@EnableHystrixDashboard

3. 开放actuator的端口

management: 
 endpoints: 
  web: 
   exposure: 
    include: '*'

3. 测试访问

# 仪表盘地址
http://localhost:8002/hystrix
# 输入监控点的数据流
http://localhost:8002/actuator/hystrix.stream

五 熔断器的配置使用

熔断器有三个状态 CLOSED 、 OPEN 、 HALF_OPEN 熔断器默认关闭状态，当触发熔断后状态变更为 OPEN ,在等待到指定的时间，Hystrix会放请求检测服务是否开启，这期间熔断器会变为 HALF_OPEN 半开启状态，熔断探测服务可用则继续变更为 CLOSED 关闭熔断器。

1. 修改基于restTemplate远程调用的controller中的方法，模拟除了调用id=1之外的其他id值均请求失败，抛出异常

@GetMapping("/{id}")
@HystrixCommand
public Product getProductById(@PathVariable Long id){
    if (id!=1){
        throw new RuntimeException("请求异常");
    }
    Product product = restTemplate.getForObject("http://product/product/" + id, Product.class);
    return product;
}

2. 熔断器的参数配置

hystrix:
  command:
    default:
      circuitBreaker:
        requestVolumeThreshold: 5 #触发熔断的最小请求次数，默认20
        sleepWindowInMilliseconds: 10000 #熔断多少秒后去尝试请求
        errorThresholdPercentage: 60 #触发熔断的失败请求最小占比，默认50%

六 熔断器的隔离策略

微服务使用Hystrix熔断器实现了服务的自动降级，让微服务具备自我保护的能力，提升了系统的稳定性，也较好的解决雪崩效应。其使用方式目前支持两种策略：

• 线程池隔离策略：使用一个线程池来存储当前的请求，线程池对请求作处理，设置任务返回处理超时时间，堆积的请求堆积入线程池队列。这种方式需要为每个依赖的服务申请线程池，有一定的资源消耗，好处是可以应对突发流量（流量洪峰来临时，处理不完可将数据存储到线程池队里慢慢处理）
• 信号量隔离策略：使用一个原子计数器（或信号量）来记录当前有多少个线程在运行，请求来先判 断计数器的数值，若超过设置的最大线程个数则丢弃改类型的新请求，若不超过则执行计数操作请 求来计数器+1，请求返回计数器-1。这种方式是严格的控制线程且立即返回模式，无法应对突发 流量（流量洪峰来临时，处理的线程超过数量，其他的请求会直接返回，不继续去请求依赖的服 务）

七 Hystrix核心流程

image-20201231172102570.png