Spring Cloud （7） —— Hystrix 熔断、降级、隔离

关于 Hystrix

1. 熔断

   • 熔断是 consumer 角色一侧的功能。
   • 当请求某一 provider 的失败状况达到某一阀值后，断路器会切换到 open 状态，请求将再也不发往这个 provider 。
   • 断路器打开一段时间后，会切换到 half-open 状态，此时断路器的状态将取决于下一次请求是否成功。若是成功，则切换到 closed 状态；若是失败，则切换到 open 状态。
2. 服务降级 Fallback
   当处理出现异常，或不具有处理能力时（负载太高、线程池用完），则会快速返回一个预先指定的值。
3. 资源隔离
   资源隔离主要用来预防雪崩的发生，限制某一资源不可用引发的全局资源挂起。可选的隔离方式有 线程隔离、信号量隔离。

熔断 和 降级

在通常方法上应用

1. 建立模块 spring-cloud.s05.store-hystrix

2. 在 pom 中添加依赖

   <dependencies>
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
       </dependency>
     </dependencies>

3. 添加配置文件

   server:
     port: 31003
   spring:
     application:
       name: store-hystrix
   eureka:
     client:
       serviceUrl:
         defaultZone: http://user:123123@localhost:34001/eureka/
     instance:
       instance-id: ${spring.cloud.client.ip-address}:${server.port}
       prefer-ip-address: true
       lease-renewal-interval-in-seconds: 10
       lease-expiration-duration-in-seconds: 30
   info:
     app.name: ${spring.application.name}
     compony.name: me.xhy
     build.artifactId: $project.artifactId$
     build.modelVersion: $project.modelVersion$

4. 建立启动类 ..StoreHystrix

   @SpringBootApplication
   @EnableEurekaClient
   // 开启降级
   @EnableHystrix
   public class StoreHystrix {
   
     public static void main(String[] args) {
       SpringApplication.run(StoreHystrix.class, args);
     }
   
     @Bean
     @LoadBalanced
     RestTemplate restTemplate() {
       return new RestTemplate();
     }
   }

   若是启动类中 不写 @EnableHystrix 注解，那么当方法失败时，是不会执行降级方法的；可是注解了 @HystrixCommand 的方法是能够有熔断功能的，默认值也依然是 3次， 当失败次数达到3次时，在 ribbon 中剔除该资源。

5. 建立程序访问入口..ConsumerCircuitController

   @RestController
   @RequestMapping("/hystrix")
   public class CircuitFallbackController {
   
     @Autowired
     RestTemplate restTemplate;
   
     /*
     新增了 @HystrixCommand
     @HystrixCommand(fallbackMethod = "getMoviesError") 默认键为 fallbackMethod
     表示当调用 provider 失败，调用的补偿方法
     默认状况下，发生3次错误（补偿方法调用了3次），该 provider 将被熔断
     当被熔断的 provider 从新上线，将被从新加回到服务列表
     */
     @RequestMapping("/cf/ribbon")
     @HystrixCommand(fallbackMethod = "getServerPortError")
     public String getServerPort() {
       return restTemplate.getForObject("http://album-provider/album/server-port", String.class);
     }
   
     public String getServerPortError() {
       return "ribbon method getMovies occur hystrix";
     }
   
     @RequestMapping("/cf/always-exception")
     @HystrixCommand(fallbackMethod = "getServerPortError")
     public String alwaysException() {
       if(true) throw new RuntimeException();
       return "hi";
     }
   }

   这个 Controller 中有两个访问入口， @RequestMapping("/circuit/always-exception") 始终都会发生异常；@HystrixCommand(fallbackMethod = "getServerPortError") 则须要在正常访问全部 provider 后，停掉至少一个 provider 来观察结果。

6. 验证熔断和降级

   • http://localhost:31003/hystrix/circuit/always-exception 因为该 Controller 始终报错，因此始终使用降级方法的返回值。
   • http://localhost:31003/hystrix/circuit/ribbon 使用 ribbon 的负载均衡访问 provider ，下线至少一个 provider 来观察效果。

   启动类注解了 @EnableHystrix 服务降级才会生效。 @HystrixCommand 只有在应用 ribbon 的方法上，才会有熔断效果。

在 Feign 上应用

Feign 是自带断路器的，可是它没有默认打开。须要在配置文件中配置打开它

1. pom 中引入 Feign

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

2. 在配置文件中打开断路器

   feign:
     hystrix:
       enabled: true

3. 启动类增长注解

   @EnableFeignClients // Feign 须要

4. 建立 Feign 接口

   @FeignClient(value = "album-provider", fallback = CircuitFallbackFeignServiceFallback.class)
   public interface CircuitFallbackFeignService {
   
     @RequestMapping("/album/server-port")
     String getServerPort();
   
   }
   
   /*
   该类提供发生异常时的补偿方法
   必需要有 @Component ， 能够是外部类
    */
   @Component
   class CircuitFallbackFeignServiceFallback implements CircuitFallbackFeignService {
     @Override
     public String getServerPort() {
       return "feign method getServerPort occur hystrix";
     }
   }

5. 建立访问程序入口 ..CircuitFallbackFeignController

   @RestController
   @RequestMapping("/hystrix")
   public class CircuitFallbackFeignController {
   
     @Autowired
     CircuitFallbackFeignService service;
   
     @RequestMapping("/cf/feign")
     public String getServerPort() {
       return service.getServerPort();
     }
   }

6. 访问 http://localhost:31003/hystrix/cf/feign 。

   若是配置文件中不开启断路器，降级方法是不会执行的
   若是配置文件中不设置重重试次数，feign 默认会重试 1 次

隔离

隔离能够防止雪崩的出现。当 provider 没有足够的处理能力时， consumer 的请求没法返回致使线程挂起，逐层影响，最终雪崩。若是限制 consumer 请求某个 provider 的 量 ， consumer 就不会由于 provider 丧失处理能力而挂起过多的线程， consumer 仍然能够保持服务能力，去作其余任务。

使用线程隔离

使用信号量隔离