【SpringCloud总结】9. Hystrix断路器

一、简介

1. 分布式系统面临的问题 复杂分布式体系结构中的应用程序有数十个依赖关系，每个依赖关系在某些时候将不可避免地失败。服务雪崩 多个微服务之间调用的时候，假设微服务A调用微服务B和微服务C，微服务B和微服务C又调用其它的微服务，这就是所谓的“扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用，对微服务A的调用就会占用越来越多的系统资源，进而引起系统崩溃，所谓的“雪崩效应”. 对于高流量的应用来说，单一的后端依赖可能会导致所有服务器上的所有资源都在几秒钟内饱和。比失败更糟糕的是，这些应用程序还可能导致服务之间的延迟增加，备份队列，线程和其他系统资源紧张，导致整个系统发生更多的级联故障。这些都表示需要对故障和延迟进行隔离和管理，以便单个依赖关系的失败，不能取消整个应用程序或系统。

备注：一般情况对于服务依赖的保护主要有3中解决方案： （1）熔断模式：这种模式主要是参考电路熔断，如果一条线路电压过高，保险丝会熔断，防止火灾。放到我们的系统中，如果某个目标服务调用慢或者有大量超时，此时，熔断该服务的调用，对于后续调用请求，不在继续调用目标服务，直接返回，快速释放资源。如果目标服务情况好转则恢复调用。

（2）隔离模式：这种模式就像对系统请求按类型划分成一个个小岛的一样，当某个小岛被火少光了，不会影响到其他的小岛。例如可以对不同类型的请求使用线程池来资源隔离，每种类型的请求互不影响，如果一种类型的请求线程资源耗尽，则对后续的该类型请求直接返回，不再调用后续资源。这种模式使用场景非常多，例如将一个服务拆开，对于重要的服务使用单独服务器来部署，再或者公司最近推广的多中心。

（3）限流模式：上述的熔断模式和隔离模式都属于出错后的容错处理机制，而限流模式则可以称为预防模式。限流模式主要是提前对各个类型的请求设置最高的QPS阈值，若高于设置的阈值则对该请求直接返回，不再调用后续资源。这种模式不能解决服务依赖的问题，只能解决系统整体资源分配问题，因为没有被限流的请求依然有可能造成雪崩效应。

 

2. Hystrix断路器

Hystrix是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统里，许多依赖不可避免的会调用失败，比如超时、异常等，Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式系统的弹性。   “断路器”本身是一种开关装置，当某个服务单元发生故障之后，通过断路器的故障监控（类似熔断保险丝），向调用方返回一个符合预期的、可处理的备选响应（FallBack），而不是长时间的等待或者抛出调用方无法处理的异常，这样就保证了服务调用方的线程不会被长时间、不必要地占用，从而避免了故障在分布式系统中的蔓延，乃至雪崩。

 

3. 功能

（1）服务降级

（2）服务熔断

（3）服务限流

（4）接近实时监控

 

二、服务熔断

1. 简介

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

2. 参考microservicecloud-provider-dept-8001，新建新建 microservicecloud-provider-dept-hystrix-8001

       https://blog.csdn.net/FullStackDeveloper0/article/details/90473559

3. pom.xml

  <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>    <!--  hystrix -->    <dependency>      <groupId>org.springframework.cloud</groupId>      <artifactId>spring-cloud-starter-hystrix</artifactId>    </dependency>    <!-- 引入自己定义的api通用包，可以使用Dept部门Entity -->    <dependency>      <groupId>com.atguigu.springcloud</groupId>      <artifactId>microservicecloud-api</artifactId>      <version>${project.version}</version>    </dependency>    <!-- 将微服务provider侧注册进eureka -->    <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>    <!-- actuator监控信息完善 -->    <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>  

      其实只是添加了一个hystrix的依赖

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

4. yml文件

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$

    【提示】自定义微服务实例对象的名字，也就是instance-id

5. 修改DeptController

package com.atguigu.springcloud.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import com.atguigu.springcloud.entities.Dept; import com.atguigu.springcloud.service.DeptService; import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand; @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");   } }

  【提示】@HystrixCommand一旦调用服务方法失败并抛出了错误信息后，会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法

6. 修改主启动类DeptProvider8001_Hystrix_App并添加新注解@EnableCircuitBreaker

package com.atguigu.springcloud;   import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.eureka.EnableEurekaClient;   @SpringBootApplication @EnableEurekaClient //本服务启动后会自动注册进eureka服务中 @EnableDiscoveryClient //服务发现 @EnableCircuitBreaker//对hystrixR熔断机制的支持 public class DeptProvider8001_Hystrix_App {   public static void main(String[] args)   {    SpringApplication.run(DeptProvider8001_Hystrix_App.class, args);   } }

7. 测试

（1）3个eureka先启动

（2）主启动类DeptProvider8001_Hystrix_App

（3）启动microservicecloud-consumer-dept-80

  访问id=112的对象，数据库中不存在，所以请求返回的是null，根据上面的配置可以知道，当返回值是null时，手动抛出异常，然后熔断器捕捉到异常并调用想用的方法处理以返回错误信息！

     http://localhost/consumer/dept/get/112