熔断器-Hystrix介绍和使用

迈不过友情╰ 2023-10-03 04:28 16阅读 0赞

1 为什么要使用熔断器  
2 什么是Hystrix  
3 在ribbon使用断路器  
4 Feign中使用断路器

熔断器

## 为什么要使用熔断器 ##

在微服务架构中通常会有多个服务层调用，基础服务的故障可能会导致级联故障，进而造成整个系统不可用的情况，这种现象被称为服务雪崩效应。服务雪崩效应是一种因“服务提供者”的不可用导致“服务消费者”的不可用,并将不可用逐渐放大的过程。  
如下图所示：A作为服务提供者，B为A的服务消费者，C和D是B的服务消费者。A不可用引起了B的不可用，并将不可用像滚雪球一样放大到C和D时，雪崩效应就形成了。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70]

如何避免产生这种雪崩效应呢？我们可以使用Hystrix来实现熔断器。

## 2 什么是Hystrix ##

Hystrix \[hɪst’rɪks\]的中文含义是豪猪, 因其背上长满了刺,而拥有自我保护能力  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70 1]  
Hystrix 能使你的系统在出现依赖服务失效的时候，通过隔离系统所依赖的服务，防止服务级联失败，同时提供失败回退机制，更优雅地应对失效，并使你的系统能更快地从异常中恢复。  
了解熔断器模式请看下图：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70 3]

较底层的服务如果出现故障，会导致连锁故障。当对特定的服务的调用的不可用达到一个阀值（Hystric 是5秒20次） 断路器将会被打开。

断路打开后，可用避免连锁故障，fallback方法可以直接返回一个固定值。

## 3 在ribbon使用断路器 ##

org.springframework.cloud spring-cloud-starter-netflix-hystrix

启动类增加注解  
@EnableHystrix

改造HelloService类，在hiService方法上加上@HystrixCommand注解。该注解对该方法创建了熔断器的功能，并指定了fallbackMethod熔断方法，如果“SERVICE-HI”服务无法访问，熔断方法直接返回了一个字符串，字符串为”hi,”+name+”,sorry,error!”，  
代码如下：  
@Service  
public class HelloService \{

@Autowired
    RestTemplate restTemplate;
    
    @HystrixCommand(fallbackMethod = "hiError")
    public String hiService(String name) {
        return restTemplate.getForObject("http://SERVICE-HI/hi?name="+name,String.class);
    }
    
    public String hiError(String name) {
        return "hi,"+name+",sorry,error!";
    }

## 4 Feign中使用断路器 ##

feign:  
hystrix:  
enabled: true  
application.yml中增加配置

@FeignClient(value = “service-hi”, fallback = SchedualServiceHiHystric.class)  
public interface SchedualServiceHi \{

@RequestMapping(value = "/hi", method = RequestMethod.GET)
    String sayHiFromClientOne(@RequestParam(value = "name") String name);

\}  
定义接口，远程注入SERVICE-HI/hi方法，SchedualServiceHiHystric为熔断实现类

@Component  
public class SchedualServiceHiHystric implements SchedualServiceHi \{

@Override
    public String sayHiFromClientOne(String name) {
    	return "sorry " + name;
    }

\}  
如果“SERVICE-HI/hi”无法访问，会执行实现类中的方法返回“sorry”+ name；

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/7f93fb8dca8e4d7f878722d1a66a2efe.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/86a7259db86a47c2a5df8f2b691ff588.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/84aa86afcfeb4cf9835cf7c09e55d6b3.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/af052510d9124e8f9299116f2f9e1813.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyMDMyMDY4Njg=,size_16,color_FFFFFF,t_70