SpringCloud学习笔记（六）Hystrix熔断器

红太狼 2021-01-22 05:54 642阅读 0赞

项目地址：[https://github.com/gongxianshengjiadexiaohuihui/SpringCloudDemo][https_github.com_gongxianshengjiadexiaohuihui_SpringCloudDemo]

我们知道Servlet容器的线程是有限的，当我们项目中的微服务多起来的时候，各个服务之间是存在依赖关系的，一旦一个服务挂掉，势必会影响其它服务，因为请求可能在挂掉的服务这里阻塞，导致线程资源得到释放，直至Servlet容器资源耗尽。

理解这个概念的时候，我想到了小时候家里老是跳闸，因为线路老化，经常漏电，有时直接把保险丝给烧了，那时小小的我就知道去换一根保险丝，可能当时没有什么概念，换的保险丝都很细，后来上了中学，学习了电路知识，知道，漏电是短路造成的，一旦发生短路，会使电路中电流激增，从而烧断保险丝，而且保险丝是越粗，电阻越大，可负载的电流也越大。这个熔断器的作用和保险丝很像，但是可比保险丝牛多了，

但大量的请求在某个服务阻塞，超过了熔断器的阈值，熔断器（可不会断掉）会执行预先写好的错误函数并返回，fallback,就是快速反馈给你，失败，别在我这里耗了，赶快去请求其它服务把。当然，设计者可不是想的这么简单，他还给予了一定的容错机制，它会让一部分请求去执行正常的逻辑，其它仍然执行快速失败，如果那部分执行正常的逻辑的请求成功了，说明服务正常了，就会关闭熔断器。

结合以前的笔记，在以前的demo里继续添加功能

首先是eureka-ribbon-client

引入Hystrix依赖

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

在启动类开启Hystrix

@SpringBootApplication
    @EnableEurekaClient
    @EnableHystrix
    public class EurekaRibbonClientApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(EurekaRibbonClientApplication.class, args);
        }
    }

在Service层添加快速失败的函数，并配置

@Service
    public class RibbonService {
    
        @Autowired
        RestTemplate restTemplate;
        @HystrixCommand(fallbackMethod = "Error")
        public String hi(String name){
            return restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class);
        }
        public String Error(String name){
            return "sorry "+name+" the statue is Error";
        }
    }

演示效果

![70][]

当关闭了一个eureka-client,就会快速执行我们写的Error函数，如果开启了多个eureka-client就不会再请求这个client.

重新启动这个eureka-client,就会恢复，交替访两个端口

![70 1][]

![70 2][]

下面配置eureka-feign-client的熔断器

因为feign集成了Hystrix,所以不需要引入依赖，只需要再配置文件中开启就好

eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    server:
      port: 8765
    spring:
      application:
         name: eureka-feign-client
    feign.hystrix.enabled: true

然后再接口指定fallback方法的引用

@FeignClient(value = "eureka-client" ,fallback = ErrorDemo.class)
    public interface FeignClientDemo {
        @GetMapping("/hi")
        String FeignClientTest(@RequestParam("name") String name);
    }

接着实现这个接口，重载的方法内容就是fallback的内容

@Component
    public class ErrorDemo implements FeignClientDemo {
        @Override
        public String FeignClientTest(String name) {
            return "sorry "+name+" the statue is Error";
        }
    }

演示效果和ribbon一样，因为请求的服务相同

[https_github.com_gongxianshengjiadexiaohuihui_SpringCloudDemo]: https://github.com/gongxianshengjiadexiaohuihui/SpringCloudDemo
[70]: /images/1611294796319.png
[70 1]: /images/1611294819739.png
[70 2]: /images/1611294841891.png