3.1-Hystrix-概述

• Hystix 是 Netflix 开源的一个延迟和容错库，用于隔离访问远程服务、第三方库，防止出现级联失败（雪崩）。
• 雪崩：一个服务失败，导致整条链路的服务都失败的情形

Hystix 主要功能
• 隔离
线程池隔离
信号量隔离
• 降级:异常，超时
• 熔断
• 限流

1587542720216.png

1587542762104.png

3.2-Hystrix-降级

3.2.1-提供方降级

Hystix 降级：当服务发生异常或调用超时，返回默认数据

服务提供方降级

  1. 在服务提供方，引入 hystrix 依赖 

    1.     <!-- hystrix -->
    2.      <dependency>
    3.          <groupId>org.springframework.cloud</groupId>
    4.          <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    5.      </dependency>

  2. 定义降级方法 

  1.  /**
  2.      * 定义降级方法：
  3.      *  1. 方法的返回值需要和原方法一样
  4.      *  2. 方法的参数需要和原方法一样
  5.      */
  6.     public Goods findOne_fallback(int id){
  7.         Goods goods = new Goods();
  8.         goods.setTitle("降级了~~~");
  10.         return goods;
  11.     }
  1. 使用 @HystrixCommand 注解配置降级方法 
  1. /**
  2.      * 降级：
  3.      *  1. 出现异常
  4.      *  2. 服务调用超时
  5.      *      * 默认1s超时
  6.      *
  7.      *  @HystrixCommand(fallbackMethod = "findOne_fallback")
  8.      *      fallbackMethod：指定降级后调用的方法名称
  9.      */
  10.     @GetMapping("/findOne/{id}")
  11.     @HystrixCommand(fallbackMethod = "findOne_fallback",commandProperties = {
  12.             //设置Hystrix的超时时间，默认1s
  13.  @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value = "3000")
  14.     })
  15.     public Goods findOne(@PathVariable("id") int id){
  17.         //1.造个异常
  18.         int i = 3/0;
  19.         try {
  20.             //2. 休眠2秒
  21.             Thread.sleep(2000);
  22.         } catch (InterruptedException e) {
  23.             e.printStackTrace();
  24.         }
  25.         Goods goods = goodsService.findOne(id);
  27.         goods.setTitle(goods.getTitle() + ":" + port);//将端口号，设置到了 商品标题上
  28.         return goods;
  29.     }
  1. 在启动类上开启Hystrix功能：@EnableCircuitBreaker 
  1. package com.itheima.provider;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
  6. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  8. /**
  9.  * 启动类
  10.  */
  11. @EnableEurekaClient //该注解 在新版本中可以省略
  12. @SpringBootApplication
  13. @EnableCircuitBreaker // 开启Hystrix功能
  14. public class ProviderApp {
  15.     public static void main(String[] args) {
  16.         SpringApplication.run(ProviderApp.class,args);
  17.     }
  18. }

3.2.2-消费方降级

  1. feign 组件已经集成了 hystrix 组件。
  2. 定义feign 调用接口实现类，复写方法，即 降级方法
    GoodsFeignClientFallback 
  1. package com.itheima.consumer.feign;
  3. import com.itheima.consumer.domain.Goods;
  4. import org.springframework.stereotype.Component;
  6. /**
  7.  * Feign 客户端的降级处理类
  8.  * 1. 定义类 实现 Feign 客户端接口
  9.  * 2. 使用@Component注解将该类的Bean加入SpringIOC容器
  10.  */
  11. @Component
  12. public class GoodsFeignClientFallback implements GoodsFeignClient {
  13.     @Override
  14.     public Goods findGoodsById(int id) {
  15.         Goods goods = new Goods();
  16.         goods.setTitle("又被降级了~~~");
  17.         return goods;
  18.     }
  19. }
  1. 在 @FeignClient 注解中使用 fallback 属性设置降级处理类。
    GoodsFeignClient 
  1. package com.itheima.consumer.feign;
  4. import com.itheima.consumer.domain.Goods;
  5. import org.springframework.cloud.openfeign.FeignClient;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  9. @FeignClient(value = "HYSTRIX-PROVIDER",fallback = GoodsFeignClientFallback.class)
  10. public interface GoodsFeignClient {
  11.     @GetMapping("/goods/findOne/{id}")
  12.     public Goods findGoodsById(@PathVariable("id") int id);
  14. }
  1. 配置开启 feign.hystrix.enabled = true
    application.yml 
  1. # 开启feign对hystrix的支持
  2. feign:
  3.   hystrix:
  4.     enabled: true

3.3-Hystrix-熔断

3.3.1-熔断-概念

• Hystrix 熔断机制，用于监控微服务调用情况，当失败的情况达到预定的阈值（5秒失败20次），会打开
断路器，拒绝所有请求，直到服务恢复正常为止。

断路器三种状态：打开、半开、关闭、

1587543649656.png

3.3.2-熔断-代码演示

修改服务提供方的方法，演示熔断机制

熔断配置

• circuitBreaker.sleepWindowInMilliseconds：监控时间
• circuitBreaker.requestVolumeThreshold：失败次数
• circuitBreaker.errorThresholdPercentage：失败率

GoodsController

  1. package com.itheima.provider.controller;
  3. import com.itheima.provider.domain.Goods;
  4. import com.itheima.provider.service.GoodsService;
  5. import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
  6. import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.beans.factory.annotation.Value;
  9. import org.springframework.web.bind.annotation.GetMapping;
  10. import org.springframework.web.bind.annotation.PathVariable;
  11. import org.springframework.web.bind.annotation.RequestMapping;
  12. import org.springframework.web.bind.annotation.RestController;
  14. import java.util.Date;
  16. /**
  17.  * Goods Controller 服务提供方
  18.  */
  20. @RestController
  21. @RequestMapping("/goods")
  22. public class GoodsController {
  24.     @Autowired
  25.     private GoodsService goodsService;
  27.     @Value("${server.port}")
  28.     private int port;
  30.     /**
  31.      * 降级：
  32.      *  1. 出现异常
  33.      *  2. 服务调用超时
  34.      *      * 默认1s超时
  35.      *
  36.      *  @HystrixCommand(fallbackMethod = "findOne_fallback")
  37.      *      fallbackMethod：指定降级后调用的方法名称
  38.      */
  40.  @GetMapping("/findOne/{id}")
  41. @HystrixCommand(fallbackMethod = "findOne_fallback",commandProperties = {
  42.          //设置Hystrix的超时时间，默认1s
  43. @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value = "3000"),
  44.             //监控时间 默认5000 毫秒
  45. @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds",value = "5000"),
  46.             //失败次数。默认20次
  47.  @HystrixProperty(name="circuitBreaker.requestVolumeThreshold",value = "20"),
  48.             //失败率 默认50%
  49.  @HystrixProperty(name="circuitBreaker.errorThresholdPercentage",value = "50") })
  50.     public Goods findOne(@PathVariable("id") int id){
  51.         //如果id == 1 ，则出现异常，id != 1 则正常访问
  52.         if(id == 1){
  53.             //1.造个异常
  54.             int i = 3/0;
  55.         }
  56.         /*try {
  57.             //2. 休眠2秒
  58.             Thread.sleep(2000);
  59.         } catch (InterruptedException e) {
  60.             e.printStackTrace();
  61.         }*/
  62.         Goods goods = goodsService.findOne(id);
  64.         goods.setTitle(goods.getTitle() + ":" + port);//将端口号，设置到了 商品标题上
  65.         return goods;
  66.     }
  69.     /**
  70.      * 定义降级方法：
  71.      *  1. 方法的返回值需要和原方法一样
  72.      *  2. 方法的参数需要和原方法一样
  73.      */
  74.     public Goods findOne_fallback(int id){
  75.         Goods goods = new Goods();
  76.         goods.setTitle("降级了~~~");
  78.         return goods;
  79.     }
  81. }

3.3.3-熔断监控

• Hystrix 提供了 Hystrix-dashboard 功能，用于实时监控微服务运行状态。
• 但是Hystrix-dashboard只能监控一个微服务。
• Netflix 还提供了 Turbine ，进行聚合监控。
1587544649322.png

熔断器监控安装 请查看Turbine搭建步骤.md

1587544516031.png