Hystrix-线程隔离，服务降级

墨蓝 2023-07-21 11:19 64阅读 0赞

### 文章目录 ###

*  一、线程隔离示意图：
 *  二、实践代码
 *   *   1、首先在itcast-service-consumer的pom.xml中引入Hystrix依赖：
     *  2、开启熔断
     *  3、编写降级逻辑
     *  4、默认FallBack
     *  5、设置超时

# 一、线程隔离示意图： #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x1Y2t5c3Rhcl85OQ_size_16_color_FFFFFF_t_70_pic_center]  
解读：

Hystrix为每个依赖服务调用分配一个小的线程池，如果线程池已满调用将被立即拒绝，默认不采用排队.加速失败判定时间。

用户的请求将不再直接访问服务，而是通过线程池中的空闲线程来访问服务，如果线程池已满，或者请求超时，则会进行降级处理，什么是服务降级？

> 服务降级：优先保证核心服务，而非核心服务不可用或弱可用

用户的请求故障时，不会被阻塞，更不会无休止的等待或者看到系统崩溃，至少可以看到一个执行结果（例如返回友好的提示信息） 。

服务降级虽然会导致请求失败，但是不会导致阻塞，而且最多会影响这个依赖服务对应的线程池中的资源，对其它服务没有响应。

触发Hystix服务降级的情况：

*  线程池已满
 *  请求超时

# 二、实践代码 #

##  1、首先在itcast-service-consumer的pom.xml中引入Hystrix依赖： ##

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

## 2、开启熔断 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x1Y2t5c3Rhcl85OQ_size_16_color_FFFFFF_t_70_pic_center 1]  
可以看到，我们类上的注解越来越多，在微服务中，经常会引入上面的三个注解，于是Spring就提供了一个组合注解：@SpringCloudApplication  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x1Y2t5c3Rhcl85OQ_size_16_color_FFFFFF_t_70_pic_center 2]  
因此，我们可以使用这个组合注解来代替之前的3个注解。

@SpringCloudApplication
    public class ItcastServiceConsumerApplication { 
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate(){ 
            return new RestTemplate();
        }
    
        public static void main(String[] args) { 
            SpringApplication.run(ItcastServiceConsumerApplication.class, args);
        }
    }

## 3、编写降级逻辑 ##

我们改造itcast-service-consumer，当目标服务的调用出现故障，我们希望快速失败，给用户一个友好提示。因此需要提前编写好失败时的降级处理逻辑，要使用HystixCommond来完成：

@Controller
    @RequestMapping("consumer/user")
    public class UserController { 
    
        @Autowired
        private RestTemplate restTemplate;
    
        @GetMapping
        @ResponseBody
        @HystrixCommand(fallbackMethod = "queryUserByIdFallBack")
        public String queryUserById(@RequestParam("id") Long id) { 
            String user = this.restTemplate.getForObject("http://service-provider/user/" + id, String.class);
            return user;
        }
    
        public String queryUserByIdFallBack(Long id){ 
            return "请求繁忙，请稍后再试！";
        }
    }

要注意，因为熔断的降级逻辑方法必须跟正常逻辑方法保证：相同的参数列表和返回值声明。失败逻辑中返回User对象没有太大意义，一般会返回友好提示。所以我们把queryById的方法改造为返回String，反正也是Json数据。这样失败逻辑中返回一个错误说明，会比较方便。

说明：

*  @HystrixCommand(fallbackMethod = “queryByIdFallBack”)：用来声明一个降级逻辑的方法

测试：

当itcast-service-provder正常提供服务时，访问与以前一致。但是当我们将itcast-service-provider停机时，会发现页面返回了降级处理信息：  
![在这里插入图片描述][2020040317105675.png_pic_center]

## 4、默认FallBack ##

我们刚才把fallback写在了某个业务方法上，如果这样的方法很多，那岂不是要写很多。所以我们可以把Fallback配置加在类上，实现默认fallback：

@Controller
    @RequestMapping("consumer/user")
    @DefaultProperties(defaultFallback = "fallBackMethod") // 指定一个类的全局熔断方法
    public class UserController { 
    
        @Autowired
        private RestTemplate restTemplate;
    
        @GetMapping
        @ResponseBody
        @HystrixCommand // 标记该方法需要熔断
        public String queryUserById(@RequestParam("id") Long id) { 
            String user = this.restTemplate.getForObject("http://service-provider/user/" + id, String.class);
            return user;
        }
    
        /** * 熔断方法 * 返回值要和被熔断的方法的返回值一致 * 熔断方法不需要参数 * @return */
        public String fallBackMethod(){ 
            return "请求繁忙，请稍后再试！";
        }
    }

*  @DefaultProperties(defaultFallback = “defaultFallBack”)：在类上指明统一的失败降级方法
 *  @HystrixCommand：在方法上直接使用该注解，使用默认的剪辑方法。
 *  defaultFallback：默认降级方法，不用任何参数，以匹配更多方法，但是返回值一定一致  
    ![在这里插入图片描述][20200403171558220.png_pic_center]

## 5、设置超时 ##

在之前的案例中，请求在超过1秒后都会返回错误信息，这是因为Hystix的默认超时时长为1，我们可以通过配置修改这个值：

我们可以通过hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds来设置Hystrix超时时间。该配置没有提示。

hystrix:
      command:
        default:
          execution:
            isolation:
              thread:
                timeoutInMilliseconds: 6000 # 设置hystrix的超时时间为6000ms

**改造服务提供者**

改造服务提供者的UserController接口，随机休眠一段时间，以触发熔断：

@GetMapping("{id}")
    public User queryUserById(@PathVariable("id") Long id) { 
        try { 
            Thread.sleep(6000);
        } catch (InterruptedException e) { 
            e.printStackTrace();
        }
        return this.userService.queryUserById(id);
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x1Y2t5c3Rhcl85OQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20230528/fa515c758a4743dbbc5b6e7d02a06568.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x1Y2t5c3Rhcl85OQ_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20230528/8026762a7fcb48d2b4f25d832477f92c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x1Y2t5c3Rhcl85OQ_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20230528/fa50715fdd7d4b5cbae52bc17e5cbe4e.png
[2020040317105675.png_pic_center]: /images/20230528/1beaa1090b064808a659be25656fe054.png
[20200403171558220.png_pic_center]: /images/20230528/4cbf2b0b809c4aee9e29912ecc4e8e49.png