• hystrix 熔断器

    源码： https://gitee.com/GXQ205153964/Hystrix-parent.git

    Hystrix概述：

    •  hystrix是Netflix开源的一个延迟和容错库，用于隔离访问远程服务、第三方库，防止出现级联失败（雪崩）
    • 级联失败: 当C服务出现问题（硬盘烧了，网络断了）不可用了，B依旧会不停的调用C，B的资源耗尽，导致B也出现问题，同理A。这种现象被称为雪崩。

    预防雪崩

     Hystix主要功能：

    问题:

    这里有一个线程池对应3个服务，当哪个服务被调用时，线程池会分配一个线程运行。当C发生故障后线程池的线程依旧会执行C服务，从而导致线程池线程用完，从而导致BD服务也无法使用。

     

    解决: 

    • 隔离：

    线程池隔离：把A分成3个线程池分别对应三个服务，C坏了后，BD不会收到影响。

    信号量隔离:对BCD加一个阀门，只允许一定的数量的人经行访问，超过就不能访问了，从而阻止C将所有的线程池资源耗尽。

    • 降级 （异常，超时等）自己写个降级方案，在服务调用方和提供方都要写，网络不通时。降级就是执行自己B计划，预案。
    • 熔断   当C服务出现错误频率较高时，Hystrix直接将C的所有服务全部拒绝，C修复后，熔断器会自动将C恢复成原来样子，正常运行。熔断机制，用于监控微服务调用情况，当失败的情况打到预定的阀值（5秒失败20次），会打开短路器，拒绝所有请求，知道服务回复正常为止。
    • 限流   限制多少人/服务访问 

    降级：

     降级——服务提供方

    （c降级方案）

    流程:

    1. 在服务提供方，引入hystrix依赖
    2. 定义降级方法
    3. 使用@HystrixCommand注解配置降级方法
    4. 在启动类上开启Hystrix功能：@EnableCircuitBreker

     基础代码构建

    SpringCloud EurekeServer Consumer和provider

    C降级方案搭建

     provider:

    pom.xml

    1.   
    2.         <dependency>
    3.             <groupId>org.springframework.cloudgroupId>
    4.             <artifactId>spring-cloud-starter-netflix-hystrixartifactId>
    5.         dependency>

    ProviderApp启动类（开启熔断器）

    1. //启动类
    2. @EnableEurekaClient
    3. @SpringBootApplication
    4. @EnableCircuitBreaker//开启Hystrix熔断器
    5. public class ProviderApp {
    6.     public static void main(String[] args){
    7.         SpringApplication.run(ProviderApp.class,args);
    8.     }
    9. }

     GoodsController

    1. package com.gao.controller;
    2.  
    3. import com.gao.domain.Goods;
    4. import com.gao.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;
    13.  
    14.  
    15. //服务提供方
    16. @RestController
    17. @RequestMapping("/goods")
    18. public class GoodsController {
    19.     @Autowired
    20.     private GoodsService goodsService;
    21.  
    22.     /**/
    23.     //这里注入port可时刻监控哪个服务被调用
    24.     @Value("${server.port}")
    25.     private int port;
    27.     /**
    28.      *降级：
    29.      * 出现异常
    30.      * 服务调用超时
    31.      */
    32.     @GetMapping("/findOne/{id}")
    33.     //指定降级后调用的方法
    34.     @HystrixCommand(fallbackMethod = "findOne_fallback",commandProperties ={
    35.             //修改几秒后超时
    36.             @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="3000")
    37.     })
    38.     public Goods findOne(@PathVariable("id") int id){
    39.         Goods goods = goodsService.findOne(id);
    40.         //造个异常
    41.         //int i =3/0;
    42.         //超时
    43.         try{
    44.             //休眠两秒
    45.             Thread.sleep(2000);
    46.         }catch (InterruptedException e){
    47.             e.printStackTrace();
    48.         }
    49.         //将端口号，设置到了商品标题上方便监控
    50.         goods.setTitle(goods.getTitle()+"  "+"port" + ":" + port);
    51.  
    52.         return goods;
    53.     }
    54.     /**
    55.      * 定义降级方法
    56.      *方法的返回值需要和原方法一样
    57.      * 方法的参数需要和原方法一样
    58.      */
    59.     public Goods findOne_fallback(int id){
    60.         Goods goods = new Goods();
    61.         goods.setTitle("降级了~~~");
    62.         return goods;
    63.     }
    64. }

    降级——Hystrix降级-服务提供方

    1. 在服务提供方，引入hystrix依赖（consumer使用了feign，而feign里已经集成了Hystrix，不用再引入feign依赖了，如果没有过使用feign，按照provider写）
    2. 定义降级方法
    3. 使用@HystrixCommand注解配置降级方法
    4. 在启动类上开启Hystrix功能：@EnableCircuitBreaker

     consumer使用了feign，而feign里已经集成了Hystrix，不用再引入feign依赖了

    A级降级方案搭建

     开启feign对hystrix的支持

    1. #开启feign对hystrix的支持
    2. feign:
    3.   hystrix:
    4.     enabled: true

    pom.xml

    1. <dependencies>
    2.  
    3.         <dependency>
    4.             <groupId>org.springframework.bootgroupId>
    5.             <artifactId>spring-boot-starter-webartifactId>
    6.         dependency>
    7.         <dependency>
    8.             <groupId>org.springframework.bootgroupId>
    9.             <artifactId>spring-boot-starter-actuatorartifactId>
    10.         dependency>
    11.         
    12.         <dependency>
    13.             <groupId>org.springframework.cloudgroupId>
    14.             <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
    15.         dependency>
    16.         
    17.         <dependency>
    18.             <groupId>org.springframework.cloudgroupId>
    19.             <artifactId>spring-cloud-starter-openfeignartifactId>
    20.         dependency>
    21.  
    22.     dependencies>

    GoodsFeignClient

    1. package com.gao.feign;
    2.  
    3. @FeignClient(value = "HYSTRIX-PROVIDER",fallback = GoodsFeignClientFallback.class)
    4. public interface GoodsFeignClient {
    5.     @GetMapping("/goods/findOne/{id}")
    6.     public Goods findGoodById(@PathVariable("id") int id);
    7. }

    GoodsFeignClientFallback

    1. package com.gao.feign;
    2.  
    3. @Component
    4. public class GoodsFeignClientFallback implements GoodsFeignClient {
    5.  
    6.     @Override
    7.     public Goods findGoodById(int id) {
    8.         Goods goods = new Goods();
    9.         goods.setTitle("又被降级了~~~");
    10.         return goods;
    11.     }
    12. }

    启动类上加

    @EnableFeignClients//启动feign

    测试结果

     当服务C坏掉后，启动了降级方案，返回给A是好的值，所以A不会启动降级方案。在A和C之间不能通信时（例如断网,或者直接关掉C），A会启动降级方案

     熔断

     

     在provider里的GoodsController里添加

    1.  当id=1时，出现异常id=2时正常       
    2.         //熔断
    3.         //如果id==1，则出现异常，id ！=1 则正常访问
    4.         if(id == 1){
    5.             //造个异常
    6.             int i =3/0;
    7.         }

    启动ProviderApp，5秒失败20次，刷新，当达到这个情况下，当id变为2时也会降级。说明启动了熔断，等五秒后会自动启动，id=2时又可以用了。

    1. package com.gao.controller;
    2.  
    3. import com.gao.domain.Goods;
    4. import com.gao.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;
    13.  
    14.  
    15. //服务提供方
    16. @RestController
    17. @RequestMapping("/goods")
    18. public class GoodsController {
    19.     @Autowired
    20.     private GoodsService goodsService;
    21.  
    22.     /**/
    23.     //这里注入port可时刻监控哪个服务被调用
    24.     @Value("${server.port}")
    25.     private int port;
    27.     /**
    28.      *降级：
    29.      * 出现异常
    30.      * 服务调用超时
    31.      */
    32.     @GetMapping("/findOne/{id}")
    33.     //指定降级后调用的方法
    34.     @HystrixCommand(fallbackMethod = "findOne_fallback",commandProperties ={
    35.             //修改几秒后超时
    36.             @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="3000"),
    37.             //监控时间 默认5000 毫秒
    38.             @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds",value = "5000"),
    39.             //失败次数。默认20次
    40.             @HystrixProperty(name="circuitBreaker.requestVolumeThreshold",value = "20"),
    41.             //失败率 默认50%
    42.             @HystrixProperty(name="circuitBreaker.errorThresholdPercentage",value = "50")
    43.     })
    44.     public Goods findOne(@PathVariable("id") int id){
    45.         Goods goods = goodsService.findOne(id);
    46.  
    47.         //熔断
    48.         //如果id==1，则出现异常，id ！=1 则正常访问
    49.         if(id == 1){
    50.             //造个异常
    51.             int i =3/0;
    52.         }
    53.  
    54.         //降级
    55.         //造个异常
    56.         int i =3/0;
    57.         //超时
    58.         /*
    59.         try{
    60.             //休眠两秒
    61.             Thread.sleep(2000);
    62.         }catch (InterruptedException e){
    63.             e.printStackTrace();
    64.         }
    65.         */
    66.  
    67.         //将端口号，设置到了商品标题上方便监控
    68.         goods.setTitle(goods.getTitle()+"  "+"port" + ":" + port);
    69.  
    70.         return goods;
    71.     }
    72.     /**
    73.      * 定义降级方法
    74.      *方法的返回值需要和原方法一样
    75.      * 方法的参数需要和原方法一样
    76.      */
    77.     public Goods findOne_fallback(int id){
    78.         Goods goods = new Goods();
    79.         goods.setTitle("降级了~~~");
    80.         return goods;
    81.     }
    82. }

    修改熔断基础属性

    //监控时间 默认5000 毫秒 @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds",value = "5000"), //失败次数。默认20次 @HystrixProperty(name="circuitBreaker.requestVolumeThreshold",value = "20"), //失败率 默认50% @HystrixProperty(name="circuitBreaker.errorThresholdPercentage",value = "50")

     provider GoodsController

    1. package com.gao.controller;
    2.  
    3. //服务提供方
    4. @RestController
    5. @RequestMapping("/goods")
    6. public class GoodsController {
    7.     @Autowired
    8.     private GoodsService goodsService;
    9.  
    10.     /**/
    11.     //这里注入port可时刻监控哪个服务被调用
    12.     @Value("${server.port}")
    13.     private int port;
    15.     /**
    16.      *降级：
    17.      * 出现异常
    18.      * 服务调用超时
    19.      */
    20.     @GetMapping("/findOne/{id}")
    21.     //指定降级后调用的方法
    22.     @HystrixCommand(fallbackMethod = "findOne_fallback",commandProperties ={
    23.             //修改几秒后超时
    24.             @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="3000"),
    25.             //监控时间 默认5000 毫秒
    26.             @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds",value = "5000"),
    27.             //失败次数。默认20次
    28.             @HystrixProperty(name="circuitBreaker.requestVolumeThreshold",value = "20"),
    29.             //失败率 默认50%
    30.             @HystrixProperty(name="circuitBreaker.errorThresholdPercentage",value = "50")
    31.     })
    32.     public Goods findOne(@PathVariable("id") int id){
    33.         Goods goods = goodsService.findOne(id);
    34.  
    35.         //熔断
    36.         //如果id==1，则出现异常，id ！=1 则正常访问
    37.         if(id == 1){
    38.             //造个异常
    39.             int i =3/0;
    40.         }
    41.  
    42.         //降级
    43.         //造个异常
    44.         int i =3/0;
    45.         //超时
    46.         /*
    47.         try{
    48.             //休眠两秒
    49.             Thread.sleep(2000);
    50.         }catch (InterruptedException e){
    51.             e.printStackTrace();
    52.         }
    53.         */
    54.  
    55.         //将端口号，设置到了商品标题上方便监控
    56.         goods.setTitle(goods.getTitle()+"  "+"port" + ":" + port);
    57.  
    58.         return goods;
    59.     }
    60.     /**
    61.      * 定义降级方法
    62.      *方法的返回值需要和原方法一样
    63.      * 方法的参数需要和原方法一样
    64.      */
    65.     public Goods findOne_fallback(int id){
    66.         Goods goods = new Goods();
    67.         goods.setTitle("降级了~~~");
    68.         return goods;
    69.     }
    70. }

    熔断监控

    简介

     

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

     搭建：

     搭建监控模块：

    创建监控模块：

    创建hystrix-monitor模块，使用Turbine聚合监控多个Hystrix dashboard功能

    引入Turbine聚合监控起步依赖：

    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <parent>
    6.         <artifactId>spring_cloud_parentartifactId>
    7.         <groupId>com.gaogroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>hystrix-monitorartifactId>
    13.  
    14.     <properties>
    15.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    16.         <project.reporting.outputEncoding>UTF-8project.reporting.outputEncoding>
    17.         <java.version>1.8java.version>
    18.     properties>
    19.  
    20.     <dependencies>
    21.         <dependency>
    22.             <groupId>org.springframework.cloudgroupId>
    23.             <artifactId>spring-cloud-starter-netflix-hystrix-dashboardartifactId>
    24.         dependency>
    25.  
    26.         <dependency>
    27.             <groupId>org.springframework.cloudgroupId>
    28.             <artifactId>spring-cloud-starter-netflix-turbineartifactId>
    29.         dependency>
    30.  
    31.         <dependency>
    32.             <groupId>org.springframework.bootgroupId>
    33.             <artifactId>spring-boot-starter-actuatorartifactId>
    34.         dependency>
    35.  
    36.         <dependency>
    37.             <groupId>org.springframework.cloudgroupId>
    38.             <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
    39.         dependency>
    40.  
    41.  
    42.         <dependency>
    43.             <groupId>org.springframework.bootgroupId>
    44.             <artifactId>spring-boot-starter-testartifactId>
    45.             <scope>testscope>
    46.         dependency>
    47.     dependencies>
    48.  
    49.     <build>
    50.         <plugins>
    51.             <plugin>
    52.                 <groupId>org.springframework.bootgroupId>
    53.                 <artifactId>spring-boot-maven-pluginartifactId>
    54.             plugin>
    55.         plugins>
    56.     build>
    57.  
    58. project>

    application.yml

    1. spring:
    2.   application.name: hystrix-monitor
    3. server:
    4.   port: 8769
    5. turbine:
    6.   combine-host-port: true
    7.   # 配置需要被监控的服务名称列表
    8.   app-config: hystrix-provider,hystrix-consumer
    9.   cluster-name-expression: "'default'"
    10.   aggregator:
    11.     cluster-config: default
    12.   #instanceUrlSuffix: /actuator/hystrix.stream
    13. eureka:
    14.   client:
    15.     serviceUrl:
    16.       defaultZone: http://localhost:8761/eureka/

    启动类：

    1. package com.itheima;
    2.  
    3.  
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    7. import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
    8. import org.springframework.cloud.netflix.turbine.EnableTurbine;
    9.  
    10. @SpringBootApplication
    11. @EnableEurekaClient
    12.  
    13. @EnableTurbine //开启Turbine 很聚合监控功能
    14. @EnableHystrixDashboard //开启Hystrix仪表盘监控功能
    15. public class HystrixMonitorApp {
    16.  
    17.     public static void main(String[] args) {
    18.         SpringApplication.run(HystrixMonitorApp.class, args);
    19.     }
    20.  
    21. }

    分别修改hystrix-provider和hystrix-consumer模块

    添加依赖

    2.  
    3.         <dependency>
    4.             <groupId>org.springframework.bootgroupId>
    5.             <artifactId>spring-boot-starter-actuatorartifactId>
    6.         dependency>
    7.  
    8.         <dependency>
    9.             <groupId>org.springframework.cloudgroupId>
    10.             <artifactId>spring-cloud-starter-netflix-hystrixartifactId>
    11.         dependency>
    12.  
    13.         <dependency>
    14.             <groupId>org.springframework.cloudgroupId>
    15.             <artifactId>spring-cloud-starter-netflix-hystrix-dashboardartifactId>
    16.         dependency>

    启动类里配置Bean再添加启动注解

    1. //启动类
    2. @EnableEurekaClient
    3. @SpringBootApplication
    4. @EnableCircuitBreaker//开启Hystrix熔断器
    5. @EnableHystrixDashboard//开启Hystrix仪表盘监控功能
    6. public class ProviderApp {
    7.     public static void main(String[] args){
    8.         SpringApplication.run(ProviderApp.class,args);
    9.     }
    10.     @Bean
    11.     public ServletRegistrationBean getServlet() {
    12.         HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
    13.         ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
    14.         registrationBean.setLoadOnStartup(1);
    15.         registrationBean.addUrlMappings("/actuator/hystrix.stream");
    16.         registrationBean.setName("HystrixMetricsStreamServlet");
    17.         return registrationBean;
    18.     }
    19. }

    consumer OrderController这里注入的goodsFeignClient会报红，可以忽略。

    1. //服务的调用方
    2. @RestController
    3. @RequestMapping("/order")
    4. public class OrderController {
    5.  
    6.     @Autowired
    7.     private GoodsFeignClient goodsFeignClient;
    8.  
    9.     @GetMapping("/goods/{id}")
    10.     public Goods findGoodsById(@PathVariable("id") int id){
    11.        
    12.          //3.调用方法
    13.         //Goods goods = restTemplate.getForObject(url,Goods.class);
    14.         Goods goods = goodsFeignClient.findGoodById(id);
    15.         return goods;
    16.     }
    17. }

    web界面输入Url地址：

    http://localhost:8769/turbine.stream                监控所有监管的服务

    http://localhost:9000/actuator/hystrix.stream  监控单个服务consumer

    http://localhost:8000/actuator/hystrix.stream  监控provider

    • ​​

     图像注释：

    ​

     实心圆：他有颜色大小区分，分别代表实例的监控程序和流量大小。他从上图所示健康度从绿色 黄色 橙色 红色递减。通过实心球的展示我们可以在大量的实例中快速的发现故障实例和高压力实例

    曲线: 用来记录两分钟内流量的相对变化，我们可以通过它来观察到流量的上升和下降趋势。 

  • 相关阅读:
    Object.preventExtensions vs Object.seal vs Object.freeze
    HarmonyOS NEXT应用开发案例——自定义TabBar
    Posgresql数据库项目sql实操1
    初探Hessian利用链为Dubbo-CVE占坑
    Rust所有权及引用
    C++ 内联函数的作用
    UE5 官方案例LyraStarter 全特性详解 5.LyraPlayerStart
    Qt实现生成唯一标识ID
    PEG包裹上转换荧光纳米颗粒
    论Orchestration和Choreography
  • 原文地址：https://blog.csdn.net/qq_51497041/article/details/126243229