SpringCloud 熔断器 Hystrix 实现

雨点打透心脏的1/2处 2022-03-15 12:20 309阅读 0赞

背景：在实际的微服务系统中，是有众多的服务的，并且经常一个服务需要依赖另一个服务，例如大的电商系统中，切分的订单服务和支付的服务就会有互相依赖的情况，而如果其中一个服务挂掉了，另一个服务一直请求，是肯定拿不到返回的，这样长时间的请求就会堆积，造成服务的崩溃，这样造成整个系统的瘫痪，这样的架构相较于传统架构更加不稳定。而为了解决和应对这个问题就出现了熔断器Hystrix。

**目录**

（一）简介

（二）实现方式

1.Ribbon

2.使用feign的方式

# （一）简介 #

Netflix的创造了一个调用的库[Hystrix][]实现了熔断器[图案][Link 1]。在微服务架构中，通常有多层服务调用。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70][]

较低级别的服务中的服务故障可能导致用户级联故障。当对特定服务的呼叫达到一定阈值时（Hystrix中的默认值为5秒内的20次故障），电路打开，不进行通话。在错误和开路的情况下，开发人员可以提供后备。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 1][]

开放式电路会停止级联故障，并允许不必要的或失败的服务时间来愈合。回退可以是另一个Hystrix保护的调用，静态数据或一个正常的空值。回退可能被链接，所以第一个回退使得一些其他业务电话又回到静态数据。

# （二）实现方式  #

springCloud中可以通过Ribbon和Feign两种方式实现熔断器，下面的依旧是基于之前的工程：[eureka实现][eureka]，[Ribbon实现][Ribbon]，[feign实现][feign]

## 1.Ribbon ##

在之前Ribbon项目pom.xml中加入[Hystrix][]依赖

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

在ribbon启动类上加上hystrix注解@EnableHystrix

package com.cloud.ribbonservice;
    
    import com.netflix.loadbalancer.IRule;
    import com.netflix.loadbalancer.RandomRule;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.cloud.netflix.hystrix.EnableHystrix;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableHystrix
    public class RibbonserviceApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(RibbonserviceApplication.class, args);
        }
    
        @Bean
        @LoadBalanced
        RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
        @Bean
        public IRule ribbonRule() {
            return new RandomRule();	//这里配置策略，和配置文件对应
        }
    
    }

然后再调用方法上加上@HystrixCommand(fallbackMethod = "portFallback")注解，并加上断路之后的回调方法portFallback。

package com.cloud.ribbonservice.service;
    
    import com.cloud.ribbonservice.controller.Controller;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
    import org.springframework.core.ParameterizedTypeReference;
    import org.springframework.http.*;
    import org.springframework.stereotype.Service;
    import org.springframework.web.client.ResourceAccessException;
    import org.springframework.web.client.RestTemplate;
    
    import java.util.HashMap;
    import java.util.Map;
    
    @Service
    public class RibbonService implements IRibbonService {
    
        private static final Logger logger = LoggerFactory.getLogger(IRibbonService.class);
    
        @Autowired
        RestTemplate restTemplate;
    
        @Autowired
        LoadBalancerClient loadBalancerClient;
    
        @HystrixCommand(fallbackMethod = "portFallback")
        public String port() {
            this.loadBalancerClient.choose("SPRING-CLIENT-01");
            String info = restTemplate.getForObject("http://SPRING-CLIENT-01/getInfo/port", String.class);
            return restTemplate.getForObject("http://SPRING-CLIENT-01/getInfo/port", String.class);
    
        }
    
        private String portFallback()
        {
            logger.error("The service is Down");
            System.err.println("The service is Down");
            return "Service down";
        }
    
       
    
    }

这样基础就配置好了。

然后启动注册中心，SPRING-CLIENT-01服务，ribbon服务。

在浏览器或者postman中输入

http://localhost:11000/getInfo/hellol

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 2][]

关闭 SPRING-CLIENT-01服务，刷新浏览器

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 4][]

触发熔断成功。

## 2.使用feign的方式  ##

1.在之前的feign工程中pom.xml中加入[Hystrix][]依赖

2.feign的配置文件application.properties文件中打开[Hystrix][]的开关 feign.hystrix.enabled=true

server.port = 10010
    
    eureka.client.serviceUrl.defaultZone= http://localhost:12345/eureka/
    spring.application.name= SPRING-FEIGN-SERVICE
    
    
    spring.datasource.url=jdbc:mysql://127.0.0.1:3306/testmysql
    spring.datasource.username=root
    spring.datasource.password=123456
    spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    spring.datasource.max-idle=10
    spring.datasource.max-wait=10000
    spring.datasource.min-idle=5
    spring.datasource.initial-size=5
    
    feign.hystrix.enabled=true

在调用接口中加入一个熔断的类，这个类要实现之前调用其他服务的接口

package com.springcloudfeign.feign.service;
    
    import org.springframework.stereotype.Component;
    
    @Component
    public class ErrorHystrix implements FeignDemoService {
    
        @Override
        public String getPort() {
            return "sorry, it's error!";
        }
    
        @Override
        public String getPortTwo() {
            return "sorry, it's also error!";
        }
    
    
    }

然后再FeignDemoService接口注解中加入熔断回调的类的注解@FeignClient(value = "SPRING-CLIENT-01" ,fallback = ErrorHystrix.class)

package com.springcloudfeign.feign.service;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    
    @FeignClient(value = "SPRING-CLIENT-01" ,fallback = ErrorHystrix.class)
    public interface FeignDemoService {
    
        @RequestMapping(value = "port" , method = RequestMethod.GET)
        String getPort();
    
        @RequestMapping(value = "getInfo/show" , method = RequestMethod.GET)
        String getPortTwo();
    }

这样就可以了。

SPRING-SERVICE-01没有关调用feign中接口的方式和返回是：

浏览器中输入：

http://localhost:10010/getInfoTwo

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 5][]

断开 SPRING-SERVICE-01服务，刷新浏览器返回：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 6][]

说明熔断器调用成功。

以上代码github地址： [源码地址][Link 2]

[Hystrix]: https://github.com/Netflix/Hystrix
[Link 1]: http://martinfowler.com/bliki/CircuitBreaker.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70]: /images/20220315/6dc53769d9564a909ecafb42e6798e90.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 1]: /images/20220315/ab6782db937b413ea2fc33f9a90ce5b6.png
[eureka]: https://blog.csdn.net/harryptter/article/details/88064849
[Ribbon]: https://blog.csdn.net/harryptter/article/details/88075239
[feign]: https://blog.csdn.net/harryptter/article/details/88076608
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 2]: /images/20220315/ca4671a572bd47e4bf5b41b3094c0b5a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 3]: /images/20220315/98318050d0eb45838ffd3e1402a9812d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 4]: /images/20220315/91dc0f5dc5464a26938f1b7a1d556e07.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 5]: /images/20220315/fba5c2524758486fa2e9618718c5786b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhcnJ5cHR0ZXI_size_16_color_FFFFFF_t_70 6]: /images/20220315/9cc6e37ff37746bab52fec7cb396832c.png
[Link 2]: https://github.com/harrypitter/springCloudDemo.git