Hystrix服务熔断机制

ゝ一纸荒年。 2023-10-11 10:19 25阅读 0赞

分布式系统的问题

在多个微服务之间相互调用的时候，假设微服务A调用微服务B和微服务C，

微服务B和微服务C又调用其他的微服务，这就是所谓的扇出。如果链路上的

某个微服务调用相应时间过长或者不可用，对微服务A的调用就会占用越来越多的

系统资源，进而崩溃，这就是所谓的雪崩效应（可以类比一辆车在路上坏了，停在路中间，就会

引起严重的堵车，交通瘫痪！）。

而Hystrix是一个用来处理分布式系统的有延迟和容错的一个库，hystrix可以保证在一个依赖出问题

的情况下，不会导致整体的服务失败，避免出现级联故障，以提高分布式系统的弹性。

断路器就像熔断保险丝，当某一个服务单元发生故障的时候，就像调用的方法返回一个符合我们

预期的，可以处理的备选响应（FallBack）,而不是一直长时间的等待或者抛出无法处理的异常，

这样就保证了服务调用方的线程不会被长时间的占用，从而避免了分布式系统中的故障或者雪崩

服务熔断  
熔断机制是应对雪崩效应的一种微服务链路保护机制。  
当扇出链路的某个微服务不可用或者响应时间太长时，会进行服务的降级，进而熔断该节点微服务的调用，快速返回"错误"的响应信息。当检测到该节点微服务调用响应正常后恢复调用链路。在SpringCloud框架里熔断机制通过Hystrix实现。Hystrix会监控微服务间调用的状况，当失败的调用到一定阈值，缺省是5秒内20次调用失败就会启动熔断机制。熔断机制的注解是@HystrixCommand。、。

服务熔断，就是在服务提供者使用。

我们建立一个新的服务提供者：

在pom文件中：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
     
      <parent>
       <groupId>com.atguigu.springcloud</groupId>
       <artifactId>microservicecloud</artifactId>
       <version>0.0.1-SNAPSHOT</version>
      </parent>
     
      <artifactId>microservicecloud-provider-dept-hystrix-8001</artifactId>
     
     
      <dependencies>
       
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-hystrix</artifactId>
       </dependency>
       
       <dependency>
         <groupId>com.atguigu.springcloud</groupId>
         <artifactId>microservicecloud-api</artifactId>
         <version>${project.version}</version>
       </dependency>
       
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-eureka</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-config</artifactId>
       </dependency>
       
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-actuator</artifactId>
       </dependency>
       <dependency>
         <groupId>junit</groupId>
         <artifactId>junit</artifactId>
       </dependency>
       <dependency>
         <groupId>mysql</groupId>
         <artifactId>mysql-connector-java</artifactId>
       </dependency>
       <dependency>
         <groupId>com.alibaba</groupId>
         <artifactId>druid</artifactId>
       </dependency>
       <dependency>
         <groupId>ch.qos.logback</groupId>
         <artifactId>logback-core</artifactId>
       </dependency>
       <dependency>
         <groupId>org.mybatis.spring.boot</groupId>
         <artifactId>mybatis-spring-boot-starter</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-jetty</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-test</artifactId>
       </dependency>
       
       <dependency>
         <groupId>org.springframework</groupId>
         <artifactId>springloaded</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-devtools</artifactId>
       </dependency>
      </dependencies>
     
    </project>

yaml配置文件：

server:
      port: 8001
      
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml  #mybatis所在路径
      type-aliases-package: com.atguigu.springcloud.entities #entity别名类
      mapper-locations:
      - classpath:mybatis/mapper/**/*.xml #mapper映射文件
        
    spring:
       application:
        name: microservicecloud-dept 
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: org.gjt.mm.mysql.Driver
        url: jdbc:mysql://localhost:3306/cloudDB01
        username: root
        password: 123456
        dbcp2:
          min-idle: 5
          initial-size: 5
          max-total: 5
          max-wait-millis: 200
          
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url: 
          defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
      instance:
        instance-id: microservicecloud-dept8001-hystrix   #自定义服务名称信息
        prefer-ip-address: true     #访问路径可以显示IP地址
          
    info:
      app.name: atguigu-microservicecloud
      company.name: www.atguigu.com
      build.artifactId: $project.artifactId$
      build.version: $project.version$

编写controller：

@RestController
    public class DeptController
    {
      @Autowired
      private DeptService service = null;
      
      @RequestMapping(value="/dept/get/{id}",method=RequestMethod.GET)
        @HystrixCommand(fallbackMethod = "processHystrix_Get")
      public Dept get(@PathVariable("id") Long id)
      {
       Dept dept =  this.service.get(id);
       if(null == dept)
       {
         throw new RuntimeException("该ID："+id+"没有没有对应的信息");
       }
       return dept;
      }
      
      public Dept processHystrix_Get(@PathVariable("id") Long id)
      {
       return new Dept().setDeptno(id)
               .setDname("该ID："+id+"没有没有对应的信息,null--@HystrixCommand")
               .setDb_source("no this database in MySQL");
      }
    }

主启动类：

@SpringBootApplication
    @EnableEurekaClient //本服务启动后会自动注册进eureka服务中
    @EnableCircuitBreaker//对hystrixR熔断机制的支持
    public class DeptProvider8001_Hystrix_App
    {
      public static void main(String[] args)
      {
       SpringApplication.run(DeptProvider8001_Hystrix_App.class, args);
      }
    }

这里就不写mybatis那些访问数据库的类了，可以见文末的链接的代码。[https://hn.devcloud.huaweicloud.com/codehub/project/db863c4dd09b44e1949853aa22197df3/codehub/7172321/home][https_hn.devcloud.huaweicloud.com_codehub_project_db863c4dd09b44e1949853aa22197df3_codehub_7172321_home]

[https_hn.devcloud.huaweicloud.com_codehub_project_db863c4dd09b44e1949853aa22197df3_codehub_7172321_home]: https://hn.devcloud.huaweicloud.com/codehub/project/db863c4dd09b44e1949853aa22197df3/codehub/7172321/home