Springcloud 集成 Hystrix

叁歲伎倆 2023-10-01 08:00 12阅读 0赞

## 1.熔断、降级介绍 ##

相同的目的：从可用性和可靠性出发，防止系统运行缓慢或者崩溃

相同的结果：用户发现某些功能暂时不可用

不同的触发点：熔断一般都是由于下游服务异常，系统自动监测触发；降级多是出于对系统整体负荷考虑的，可人工干预触发的（抢购活动时，部分非热点服务下线，【配置中心，服务开关】）

不同的实现的方式：熔断一般都是框架级别的，每个服务都需要的；降级需要考虑业务层次（降级都由最外层服务开始）

## 2.重试、阻塞、超时、幂等 ##

由于服务调用失败（超时，异常），可以配置失败重试策略，但同时需要考虑重试接口的类型与重试的次数；若是服务接口是查询类可以直接重试，若是服务接口是写入修改类需要考虑幂等问题，同时多次重试必然会导致热点接口的阻塞问题与超时问题，要根据具体的业务场景配置适当的重试策略。

--------------------

## **3.Hystrix熔断降级** ##

降级是指当请求超时、资源不足等情况发生时进行服务降级处理，不调用真实服务逻辑，而是使用快速失败（fallback\[退路\]）方式直接返回一个托底数据，保证服务链条的完整，避免服务雪崩。

### 3.1Nacos 注册中心 ###

参考： [Springcloud 集成 Nacos 注册中心][Springcloud _ Nacos]

### **3.2Provider 服务提供者** ###

参考：[ Springcloud 集成 Nacos简单服务调用][Springcloud _ Nacos 1]

### **3.3Consumer 消费者** ###

#### 3.3.1pom.xml ####

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
                <version>2.0.0.RELEASE</version>
            </dependency>

#### 3.3.2启动类 ####

@EnableCircuitBreaker 开启断路器，开启Hystrix容错能力

package com.lhy.cloud;
    
    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.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    // 开启断路器，开启Hystrix容错能力
    @EnableCircuitBreaker
    @SpringBootApplication
    @EnableDiscoveryClient
    public class CloudApiApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(CloudApiApplication.class, args);
        }
    
        @LoadBalanced
        @Bean
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
    }

#### 3.3.3测试类 ####

* HystrixCommand 开启Hystrix命令 当方法执行失败时，使用Hystrix逻辑处理
    * fallbackMethod 当方法执行失败时,调用此方法。

package com.lhy.cloud.controller;
    
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import javax.annotation.Resource;
    
    /**
     * Class description.
     *
     * @author ocean liu
     * @createTime 2021/11/29 - 10:57
     */
    @RequestMapping("/cloud")
    @RestController
    public class CloudController {
    
        @Resource
        private RestTemplate restTemplate;
    
        @GetMapping("/user/headPortrait")
        /**
         * HystrixCommand 开启Hystrix命令 当方法执行失败时，使用Hystrix逻辑处理
         * fallbackMethod 当方法执行失败时,调用此方法。
         */
        @HystrixCommand(fallbackMethod = "defaultHeadPortrait")
        public String headPortrait() {
            return restTemplate.getForObject("http://user-api/user/headPortrait", String.class);
        }
    
        private String defaultHeadPortrait() {
            return "default.png";
        }
    }

#### 3.3.4验证（停服验证） ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16][]

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16 1][] ![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

--------------------

## **4.配置熔断降级策略** ##

@GetMapping("/user/headPortrait")
        /**
         * HystrixCommand 开启Hystrix命令 当方法执行失败时，使用Hystrix逻辑处理
         * fallbackMethod 当方法执行失败时,调用此方法。
         */
        @HystrixCommand(fallbackMethod = "defaultHeadPortrait",
                commandProperties = {
                        // 10s内超过10个错误请求则熔断 默认20
                        @HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_REQUEST_VOLUME_THRESHOLD, value = "10"),
                        // 请求错误率大于40%则熔断     默认50%
                        @HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_ERROR_THRESHOLD_PERCENTAGE, value = "40"),
                        // 熔断5秒后尝试请求
                        @HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_SLEEP_WINDOW_IN_MILLISECONDS, value = "5000")
                })
        public String headPortrait() {
            return restTemplate.getForObject("http://user-api/user/headPortrait", String.class);
        }
    
        private String defaultHeadPortrait() {
            return "default.png";
        }

官方文档地址：[https://github.com/Netflix/Hystrix/wiki/Configuration\#execution.isolation.strategy][https_github.com_Netflix_Hystrix_wiki_Configuration_execution.isolation.strategy]

**执行配置【HystrixCommand.run()】**

<table style="width:700px;"> 
 <tbody> 
  <tr> 
   <td style="width:252px;">EXECUTION_ISOLATION_STRATEGY</td> 
   <td style="width:133px;">隔离策略</td> 
   <td style="width:288px;"> <p>默认值：THREAD</p> <p>THREAD：单独的线程上执行，受线程池中线程数的限制<br> SEMAPHORE：调用线程上执行，受信号量计数限制</p> </td> 
  </tr> 
  <tr> 
   <td style="width:252px;"> <p>EXECUTION_ISOLATION_THREAD</p> <p>_TIMEOUT_IN_MILLISECONDS</p> </td> 
   <td style="width:133px;">超时时间</td> 
   <td style="width:288px;"> <p>默认值：1000ms</p> <p>需要开启超时策略，在THREAD模式下超时可以直接中断；SEMAPHORE需要执行完成后判断</p> </td> 
  </tr> 
  <tr> 
   <td style="width:252px;">EXECUTION_TIMEOUT_ENABLED</td> 
   <td style="width:133px;">是否开启超时</td> 
   <td style="width:288px;">默认值：true</td> 
  </tr> 
  <tr> 
   <td style="width:252px;"> <p>EXECUTION_ISOLATION_THREAD</p> <p>_INTERRUPT_ON_TIMEOUT</p> </td> 
   <td style="width:133px;">线程超时中断</td> 
   <td style="width:288px;"> <p>默认值：true</p> <p>在THREAD模式下有效</p> </td> 
  </tr> 
  <tr> 
   <td style="width:252px;"> <p>EXECUTION_ISOLATION_SEMAPHORE</p> <p>_MAX_CONCURRENT_REQUESTS</p> </td> 
   <td style="width:133px;">最大并发数</td> 
   <td style="width:288px;"> <p>默认值：10</p> <p>在SEMAPHORE模式下有效</p> </td> 
  </tr> 
 </tbody> 
</table>

**回退配置【HystrixCommand.getFallback()】**

<table style="width:700px;"> 
 <tbody> 
  <tr> 
   <td style="width:276px;"> <p>FALLBACK_ISOLATION_SEMAPHORE</p> <p>_MAX_CONCURRENT_REQUESTS</p> </td> 
   <td style="width:134px;">FALLBACK最大数</td> 
   <td style="width:289px;"> <p>默认10</p> <p>在SEMAPHORE模式下有效</p> </td> 
  </tr> 
  <tr> 
   <td style="width:276px;">FALLBACK_ENABLED</td> 
   <td style="width:134px;">是否开FALLBACK</td> 
   <td style="width:289px;">默认值：true</td> 
  </tr> 
 </tbody> 
</table>

**短路器配置【HystrixCircuitBreaker】**

<table style="width:700px;"> 
 <tbody> 
  <tr> 
   <td style="width:281px;">CIRCUIT_BREAKER_ENABLED</td> 
   <td style="width:141px;">是否开启断路器</td> 
   <td style="width:282px;">默认值：true</td> 
  </tr> 
  <tr> 
   <td style="width:281px;"> <p>CIRCUIT_BREAKER_REQUEST</p> <p>_VOLUME_THRESHOLD&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;</p> </td> 
   <td style="width:141px;">断路触发阈值</td> 
   <td style="width:282px;"> <p>默认值：20</p> <p>10ms内超过20个异常响应后触发熔断</p> </td> 
  </tr> 
  <tr> 
   <td style="width:281px;"> <p>CIRCUIT_BREAKER_SLEEP</p> <p>_WINDOW_IN_MILLISECONDS</p> </td> 
   <td style="width:141px;">断路睡眠时间</td> 
   <td style="width:282px;"> <p>默认值：5000ms</p> <p>5000ms后尝试新的请求</p> </td> 
  </tr> 
  <tr> 
   <td style="width:281px;"> <p>CIRCUIT_BREAKER_ERROR</p> <p>_THRESHOLD_PERCENTAGE</p> </td> 
   <td style="width:141px;">断路触发%阈值</td> 
   <td style="width:282px;"> <p>默认值：50</p> <p>超过50%的异常响应后触发熔断</p> </td> 
  </tr> 
  <tr> 
   <td style="width:281px;">CIRCUIT_BREAKER_FORCE_OPEN &nbsp;</td> 
   <td style="width:141px;">强制开启短路器</td> 
   <td style="width:282px;"> <p>默认值：false</p> <p>强制开启后拒绝一切请求，优先级高于FORCE_CLOSED</p> </td> 
  </tr> 
  <tr> 
   <td style="width:281px;">CIRCUIT_BREAKER_FORCE_CLOSED &nbsp;&nbsp;</td> 
   <td style="width:141px;">强制关闭短路器</td> 
   <td style="width:282px;">默认值：false<br> 强制关闭后允许一切请求，关闭断路器，优先级低于FORCE_OPEN</td> 
  </tr> 
 </tbody> 
</table>

**指标配置【HystrixCommand和HystrixObservableCommand】**

<table style="width:700px;"> 
 <tbody> 
  <tr> 
   <td style="width:279px;"> <p>METRICS_ROLLING_PERCENTILE</p> <p>_ENABLED</p> </td> 
   <td style="width:142px;">已启用指标滚动百分比</td> 
   <td style="width:278px;">默认值：true</td> 
  </tr> 
  <tr> 
   <td style="width:279px;"> <p>METRICS_ROLLING_PERCENTILE</p> <p>_TIME_IN_MILLISECONDS</p> </td> 
   <td style="width:142px;">度量值滚动百分比时间毫秒</td> 
   <td style="width:278px;">默认值：10000ms</td> 
  </tr> 
  <tr> 
   <td style="width:279px;"> <p>METRICS_ROLLING_PERCENTILE</p> <p>_NUM_BUCKETS</p> </td> 
   <td style="width:142px;">指标滚动百分比数量桶</td> 
   <td style="width:278px;">默认值：6</td> 
  </tr> 
  <tr> 
   <td style="width:279px;"> <p>METRICS_ROLLING_PERCENTILE</p> <p>_BUCKET_SIZE</p> </td> 
   <td style="width:142px;">指标滚动百分比桶大小</td> 
   <td style="width:278px;">默认值：100</td> 
  </tr> 
  <tr> 
   <td style="width:279px;"> <p>METRICS_HEALTH_SNAPSHOT</p> <p>_INTERVAL_IN_MILLISECONDS</p> </td> 
   <td style="width:142px;">度量运行状况快照间隔</td> 
   <td style="width:278px;">默认值：500ms</td> 
  </tr> 
  <tr> 
   <td style="width:279px;"> <p>METRICS_ROLLING_STATS</p> <p>_NUM_BUCKETS</p> </td> 
   <td style="width:142px;">指标滚动统计数量桶</td> 
   <td style="width:278px;">默认值：10</td> 
  </tr> 
  <tr> 
   <td style="width:279px;"> <p>METRICS_ROLLING_STATS_TIME</p> <p>_IN_MILLISECONDS</p> </td> 
   <td style="width:142px;">度量滚动统计时间</td> 
   <td style="width:278px;">默认值：10000ms</td> 
  </tr> 
 </tbody> 
</table>

**请求配置【Request Context】**

<table style="width:700px;"> 
 <tbody> 
  <tr> 
   <td style="width:281px;">REQUEST_CACHE_ENABLED</td> 
   <td style="width:153px;">是否开启缓存</td> 
   <td style="width:281px;">默认值：true</td> 
  </tr> 
  <tr> 
   <td style="width:281px;">REQUEST_LOG_ENABLED</td> 
   <td style="width:153px;">是否开启日志</td> 
   <td style="width:281px;">默认值：true</td> 
  </tr> 
 </tbody> 
</table>

**折叠器配置【Collapser Properties】**

<table style="width:700px;"> 
 <tbody> 
  <tr> 
   <td style="width:281px;">MAX_REQUESTS_IN_BATCH</td> 
   <td style="width:153px;">批量中的最大请求数</td> 
   <td style="width:281px;">默认值：Integer.MAX_VALUE</td> 
  </tr> 
  <tr> 
   <td style="width:281px;">TIMER_DELAY_IN_MILLISECONDS</td> 
   <td style="width:153px;">&nbsp; &nbsp;计时器延迟</td> 
   <td style="width:281px;">默认值：10ms</td> 
  </tr> 
 </tbody> 
</table>

**线程池配置【ThreadPool Properties】**

<table style="width:700px;"> 
 <tbody> 
  <tr> 
   <td style="width:281px;">MAX_QUEUE_SIZE</td> 
   <td style="width:153px;">等待队列大小</td> 
   <td style="width:281px;"> <p>默认值：-1</p> <p>无限制队列SynchronizeQueue，若指定正整数则为LinkedBlockingQueue</p> </td> 
  </tr> 
  <tr> 
   <td style="width:281px;">CORE_SIZE</td> 
   <td style="width:153px;">核心线程数</td> 
   <td style="width:281px;">默认值：10</td> 
  </tr> 
  <tr> 
   <td style="width:281px;">MAXIMUM_SIZE</td> 
   <td style="width:153px;">最大线程数</td> 
   <td style="width:281px;">默认值：10</td> 
  </tr> 
  <tr> 
   <td style="width:281px;"> <p>ALLOW_MAXIMUM_SIZE_TO</p> <p>_DIVERGE_FROM_CORE_SIZE</p> </td> 
   <td style="width:153px;">是否允许线程扩容</td> 
   <td style="width:281px;"> <p>默认值：false</p> <p>核心线程数即最大线程数，当开启时可以将活跃线程数扩展至最大线程数</p> </td> 
  </tr> 
  <tr> 
   <td style="width:281px;">KEEP_ALIVE_TIME_MINUTES</td> 
   <td style="width:153px;">线程存活时间</td> 
   <td style="width:281px;">默认值：1m</td> 
  </tr> 
  <tr> 
   <td style="width:281px;"> <p>QUEUE_SIZE_REJECTION</p> <p>_THRESHOLD</p> </td> 
   <td style="width:153px;">队列拒绝阈值大小</td> 
   <td style="width:281px;"> <p>默认值：5</p> <p>当MAX_QUEUE_SIZE=-1时失效，非-1时队列大小达到此时后开始拒绝入队</p> </td> 
  </tr> 
 </tbody> 
</table>

[Springcloud _ Nacos]: https://blog.csdn.net/qq_34253002/article/details/121608128
[Springcloud _ Nacos 1]: https://blog.csdn.net/qq_34253002/article/details/121614212?spm=1001.2014.3001.5501
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/5268a0012b454e979ce7e8364d7ea3d0.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/166a6feab5924cc69906ab1e9f2afdf7.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/bd94c95ef81d41839c2ff81e93634d29.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/46e9690210a54d56822dc98eb6f4a8df.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAT2NlYW5A5LiK5rqQ56CB,size_20,color_FFFFFF,t_70,g_se,x_16
[https_github.com_Netflix_Hystrix_wiki_Configuration_execution.isolation.strategy]: https://github.com/Netflix/Hystrix/wiki/Configuration#execution.isolation.strategy