本文共 4600 字，大约阅读时间需要 15 分钟。

Hystrix服务熔断

熔断类型：

• 熔断打开：请求不再进行调用当前服务，内部设置时钟一般为MTTR（平均故障处理时间），当打开时长达到所设时钟则进入半熔断状态
• 熔断关闭：软缎关闭不会对服务进行熔断
• 熔断半开：部分请求根据规则调用当前服务，如果请求成功且符合规则认为当前服务恢复正常，关闭熔断

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

断路器开启或关闭的条件：

• 当满足一定的阀值的时候（默认10秒内超过20个请求次数）
• 当失败率达到一定的时候（默认10秒内超过50%的请求失败）
• 到达以上阀值，断路器将会开启
• 当开启的时候，所有请求都不会进行转发
• 一段时间之后（默认是5秒），这个时候断路器是半开状态，会让其中一个请求进行转发。如果成功，断路器会关闭，若失败，继续开启。重复4和5.

断路器打开之后：

• 再有请求调用的时候，将不会调用主逻辑，而是直接调用降级fallback，通过断路器实现了自动地发现错误并将降级逻辑切换为主逻辑，减少响应延迟的效果。

恢复主逻辑：

• 当断路器打开，对主逻辑进行熔断之后，hystrix会启动一个休眠时间窗，在这个时间窗内，降级逻辑临时成为主逻辑，当休眠时间窗到期，断路器将进入半开状态，释放一次请求到原来的主逻辑上，如果此次请求正常返回，那么断路器将继续闭合，主逻辑恢复，如果这次请求依然有问题，断路器继续进入打开状态，休眠时间窗重新计时。

所有配置：

cloud-provider-hystrix-payment8001模拟支付模块

依赖：

   
       
            
     
      cloud2020
             
     
      pers.zhang.springcloud
             
     
      1.0-SNAPSHOT
         
        
    
     4.0.0
        
    
     cloud-provider-hystrix-payment8001
        
            
             
                 
      
       org.springframework.cloud
                  
      
       spring-cloud-starter-netflix-hystrix
              
             
             
                 
      
       org.springframework.cloud
                  
      
       spring-cloud-starter-netflix-eureka-client
              
             
             
                 
      
       org.springframework.boot
                  
      
       spring-boot-starter-web
              
             
                 
      
       org.springframework.boot
                  
      
       spring-boot-starter-actuator
              
             
     
                  
      
       pers.zhang.springcloud
                  
      
       cloud-api-commons
                  
      
       ${project.version}
              
             
                 
      
       org.springframework.boot
                  
      
       spring-boot-devtools
                  
      
       runtime
                  
      
       true
              
             
                 
      
       org.projectlombok
                  
      
       lombok
                  
      
       true
              
             
                 
      
       org.springframework.boot
                  
      
       spring-boot-starter-test
                  
      
       test
              
         
    
   

配置：application.yml

server:  port: 8001spring:  application:    name: cloud-provider-hystrix-paymenteureka:  client:    register-with-eureka: true    fetch-registry: true    service-url:      defaultZone: http://eureka7001.com:7001/eureka      #defaultZone: http://eureka7001.com:7001/eureka,http://wureka7002.com:7002/eureka

Service：

@Servicepublic class PaymentService {
       //服务熔断    @HystrixCommand(fallbackMethod = "paymentCircuitBreeaker_fallback", commandProperties = {
               @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),//是否开启断路器            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),//请求次数            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"),//时间窗口期            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60")//失败率达到多少后断路    })    public String paymentCircuitBreeaker(@PathVariable("id") Integer id) {
           if (id < 0) {
               throw new RuntimeException("*******id 不能为负数");        }        String serialNumber = IdUtil.simpleUUID();        return Thread.currentThread().getName() + "\t" + "调用成功，流水号：" + serialNumber;    }    public String paymentCircuitBreeaker_fallback(@PathVariable("id") Integer id) {
           return "id 不能为负数，请稍后再试。 id：" + id;    }}

Controller:

@RestController@Slf4jpublic class PaymentController {
       @Resource    PaymentService paymentService;    //服务熔断    @GetMapping("/payment/circuit/{id}")    public String paymentCircuitBreaker(@PathVariable("id") Integer id) {
           String result = paymentService.paymentCircuitBreeaker(id);        log.info("****result: " + result);        return result;    }}

启动类：

@SpringBootApplication@EnableEurekaClient@EnableCircuitBreaker//开启熔断public class PaymentHystrixMain8001 {
       public static void main(String[] args) {
           SpringApplication.run(PaymentHystrixMain8001.class, args);    }}

测试：

启动Eureka，和8001模块:

访问：localhost:8001/payment/circuit/33，id为正数，成功

10秒内，快速调用id为负数的请求（最少6次），然后再调用id为正数的请求：失败，服务已经熔断

等待一会（默认空窗期5秒），再调用id为正的请求：成功，已经恢复调用链路