一、概念

(1)什么是服务熔断

熔断这一概念来源于电子工程中的断路器（Circuit Breaker）。在互联网系统中，当下游服务因访问压力过大而响应变慢或失败，上游服务为了保护系统整体的可用性，可以暂时切断对下游服务的调用。 在固定时间窗口内，接口调用超时比率达到一个阈值，会开启熔断。进入熔断状态后，后续对该服务接口的调用不再经过网络，直接执行本地的默认方法，达到服务降级的效果。

熔断不可能是永久的。当经过了规定时间之后，服务将从熔断状态回复过来，再次接受调用方的远程调用。

(2)熔断的三种状态

image.png

  • 熔断关闭状态（Closed） 服务没有故障时，熔断器所处的状态，对调用方的调用不做任何限制。
  • 熔断开启状态（Open） 在固定时间窗口内（Hystrix默认是10秒），接口调用出错比率达到一个阈值（Hystrix默认为50），会进入熔断开启状态，进入熔断状态后，后续对该服务接口的调用不再经过网络，直接执行本地的fallback方法。
  • 半熔断状态（half-open）哎进入熔断开启状态一段时间之后（Hystrix默认是5秒），熔断器会进入半熔断状态，所谓半熔断就是尝试恢复服务调用，允许有限的流量调用该服务，并监控调用成功率，如果成功率达到了预期，则说明服务已恢复，进入熔断关闭状态；如果成功率仍旧很低，则重新进入熔断关闭状态。

二、实现熔断

（1）POM

  1.  <dependencies>
  2.         <!--hystrix-->
  3.         <dependency>
  4.             <groupId>org.springframework.cloud</groupId>
  5.             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  6.         </dependency>
  7.         <!--eureka client-->
  8.         <dependency>
  9.             <groupId>org.springframework.cloud</groupId>
  10.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  11.         </dependency>
  12.         <!--web-->
  13.         <dependency>
  14.             <groupId>org.springframework.boot</groupId>
  15.             <artifactId>spring-boot-starter-web</artifactId>
  16.         </dependency>
  17.         <dependency>
  18.             <groupId>org.springframework.boot</groupId>
  19.             <artifactId>spring-boot-starter-actuator</artifactId>
  20.         </dependency>
  21.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  22.             <groupId>com.atguigu.springcloud</groupId>
  23.             <artifactId>cloud-api-commons</artifactId>
  24.             <version>${project.version}</version>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-devtools</artifactId>
  29.             <scope>runtime</scope>
  30.             <optional>true</optional>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>org.projectlombok</groupId>
  34.             <artifactId>lombok</artifactId>
  35.             <optional>true</optional>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>org.springframework.boot</groupId>
  39.             <artifactId>spring-boot-starter-test</artifactId>
  40.             <scope>test</scope>
  41.         </dependency>
  42.     </dependencies>

(2)YML

  1. server:
  2.   port: 8001
  4. spring:
  5.   application:
  6.     name: cloud-provider-hystrix-payment
  8. eureka:
  9.   client:
  10.     register-with-eureka: true
  11.     fetch-registry: true
  12.     service-url:
  13.       #defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
  14.       defaultZone: http://eureka7001.com:7001/eureka

(3)主启动

  1. @SpringBootApplication
  2. @EnableEurekaClient
  3. @EnableCircuitBreaker
  4. public class PaymentHystrixMain8001
  5. {
  6.     public static void main(String[] args) {
  7.             SpringApplication.run(PaymentHystrixMain8001.class, args);
  8.     }
  9. }

（4）业务

  1.     //====服务熔断
  2.     @GetMapping("/payment/circuit/{id}")
  3.     public String paymentCircuitBreaker(@PathVariable("id") Integer id)
  4.     {
  5.         String result = paymentService.paymentCircuitBreaker(id);
  6.         log.info("****result: "+result);
  7.         return result;
  8.     }
  1.     //=====服务熔断
  2.     @HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback",commandProperties = {
  3.             @HystrixProperty(name = "circuitBreaker.enabled",value = "true"),// 是否开启断路器
  4.             @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),// 请求次数
  5.             @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000"), // 时间窗口期
  6.             @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60"),// 失败率达到多少后跳闸
  7.     })
  8.     public String paymentCircuitBreaker(@PathVariable("id") Integer id)
  9.     {
  10.         if(id < 0)
  11.         {
  12.             throw new RuntimeException("******id 不能负数");
  13.         }
  14.         String serialNumber = IdUtil.simpleUUID();
  16.         return Thread.currentThread().getName()+"\t"+"调用成功，流水号: " + serialNumber;
  17.     }
  18.     public String paymentCircuitBreaker_fallback(@PathVariable("id") Integer id)
  19.     {
  20.         return "id 不能负数，请稍后再试，/(ㄒoㄒ)/~~   id: " +id;
  21.     }

涉及到断路器的三个重要参数：快照时间窗、请求总数阈值、错误百分比阈值

1：快照时间窗： 断路器确定是否打开需要统计一些请求和错误数据，而统计的时间范围就是快照时间窗，默认为最近的10秒。
2: 请求总数阈值： 在快照时间窗内，必须满足请求总数阈值才有资格熔断。默认为20，意味着在10秒内，如果该hystrix命令的调用次数不足20次，即使所有的请求都超时或其他原因失败，断路器都不会打开。
3： 错误百分比阈值：当请求总数在快照时间窗口内超过了阈值，比如发生了30次调用，如果在这30次调用中，有15次发生了超时异常，也就是超过50%的错误百分比，在默认设定50%阈值情况下，这时候就会将断路器打开。