SpringCloud 入门教程(七)：熔断机制 -- 断路器

对断路器模式不太清楚的话，可以参看另一篇博文：断路器（Curcuit Breaker）模式，下面直接介绍Spring Cloud的断路器如何使用。

SpringCloud Netflix实现了断路器库的名字叫Hystrix. 在微服务架构下，通常会有多个层次的服务调用. 下面是微服架构下, 浏览器端通过API访问后台微服务的一个示意图：

一个微服务的超时失败可能导致瀑布式连锁反映，下图中，Hystrix通过自主反馈实现的断路器，防止了这种情况发生。

图中的服务B因为某些原因失败，变得不可用，所有对服务B的调用都会超时。当对B的调用失败达到一个特定的阀值(5秒之内发生20次失败是Hystrix定义的缺省值), 链路就会被处于open状态，之后所有所有对服务B的调用都不会被执行，取而代之的是由断路器提供的一个表示链路open的Fallback消息. Hystrix提供了相应机制，可以让开发者定义这个Fallbak消息.

open的链路阻断了瀑布式错误，可以让被淹没或者错误的服务有时间进行修复。这个fallback可以是另外一个Hystrix保护的调用, 静态数据，或者合法的空值. Fallbacks可以组成链式结构，所以，最底层调用其它业务服务的第一个Fallback返回静态数据.

下面，进入正题，在之前的两HELLO WORLD服务集群中加入断路器，防止其中一个Hello world挂掉后，导致系统发生连锁超时失败。

1. 在maven工程（前面章节中介绍的Ribbon或者Feign工程）的pom.xml中添加hystrix库支持断路器

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

2. 在Ribbon应用中使用断路器

1). 在Spring Boot启动类上添加@EnableCircuitBreaker注解

1 @SpringBootApplication
2 @EnableDiscoveryClient
3 @EnableCircuitBreaker
4 public class ServiceRibbonApplication {
5
6     public static void main(String[] args) {
7         SpringApplication.run(ServiceRibbonApplication.class, args);
8     }
。。。 。。。

2). 用@HystrixCommand注解标注访问服务的方法

 1 @Service2 public class HelloService {3     @Autowired RestTemplate restTemplate;4 5     @HystrixCommand(fallbackMethod = "serviceFailure")6     public String getHelloContent() {7         return restTemplate.getForObject("http://SERVICE-HELLOWORLD/",String.class);8     }9
10     public String serviceFailure() {
11         return "hello world service is not available !";
12     }
13 }

@HystrixCommand注解定义了一个断路器，它封装了getHelloContant()方法，当它访问的SERVICE-HELLOWORLD失败达到阀值后，将不会再调用SERVICE-HELLOWORLD，取而代之的是返回由fallbackMethod定义的方法serviceFailure（）。@HystrixCommand注解定义的fallbackMethod方法，需要特别注意的有两点：

第一， fallbackMethod的返回值和参数类型需要和被@HystrixCommand注解的方法完全一致。否则会在运行时抛出异常。比如本例中，serviceFailure（）的返回值和getHelloContant()方法的返回值都是String。

第二，当底层服务失败后，fallbackMethod替换的不是整个被@HystrixCommand注解的方法（本例中的getHelloContant), 替换的只是通过restTemplate去访问的具体服务。可以从中的system输出看到，即使失败，控制台输出里面依然会有“call SERVICE-HELLOWORLD”。

启动eureka服务，只启动两个Helloworld服务，然后中断其中一个（模拟其中一个微服务挂起），访问http://localhost:8901/然后刷新, 由于有负载均衡可以看到以下两个页面交替出现。可以看到第二个被挂起的服务，被定义在Ribbon应该里面的错误处理方法替换了。

4. 在Feign应用中使用断路器

1）. Feign内部已经支持了断路器，所以不需要想Ribbon方式一样，在Spring Boot启动类上加额外注解

2）. 用@FeignClient注解添加fallback类，该类必须实现@FeignClient修饰的接口。

1 @FeignClient(name = "SERVICE-HELLOWORLD", fallback = HelloWorldServiceFailure.class)
2 public interface HelloWorldService {
3     @RequestMapping(value = "/", method = RequestMethod.GET)
4     public String sayHello();
5 }

3). 创建HelloWorldServiceFailure类，必须实现被@FeignClient修饰的HelloWorldService接口。注意添加@Component或者@Service注解，在Spring容器中生成一个Bean

1 @Component
2 public class HelloWorldServiceFailure implements HelloWorldService {
3     @Override
4     public String sayHello() {
5         System.out.println("hello world service is not available !");
6         return "hello world service is not available !";
7     }
8 }

4）. Spring Cloud之前的Brixton版本中，Feign是缺省是自动激活了断路器的，但最近的Dalston版本已经将缺省配置修改为禁止。

原因参见： https://github.com/spring-cloud/spring-cloud-netflix/issues/1277，这一点要注意。所以要在Feign中使用断路器，必须在application.yml中添加如下配置：

feign:hystrix:enabled: true

5）. 启动Feign应用，访问http://localhost：8902/hello，可以一看到和Ribbon一样的效果。

SpringCloud 入门教程(七)：熔断机制 -- 断路器相关推荐

SpringCloud进阶-Hystrix的熔断机制+Hystrix的工作流程
提示:本文主要对SpringCloud中的Hystrix的熔断机制和工作流程进行总结文章目录前言一.简介 1.熔断是什么二.实操 1.实现 2.测试三.总结 1.大神结论 2.熔断类型 3. ...
SpringCloud 入门教程(五)： Ribbon实现客户端的负载均衡
接上节,假如我们的Hello world服务的访问量剧增,用一个服务已经无法承载, 我们可以把Hello World服务做成一个集群. 很简单,我们只需要复制Hello world服务,同时将原来的端 ...
SpringCloud 入门教程(十)：和RabbitMQ的整合 -- 消息总线Spring Cloud Netflix Bus
在本教程第三讲Spring Cloud 入门教程(三): 配置自动刷新中,通过POST方式向客户端发送/refresh请求, 可以让客户端获取到配置的最新变化.但试想一下, 在分布式系统中,如果存在很 ...
SpringCloud 入门教程(四)：分布式环境下自动发现配置服务
前一章, 我们的Hello world应用服务,通过配置服务器Config Server获取到了我们配置的hello信息"hello world". 但自己的配置文件中必须配置co ...
SpringCloud 入门教程(三)：配置自动刷新
Spring Cloud 入门教程(三): 配置自动刷新之前讲的配置管理, 只有在应用启动时会读取到GIT的内容, 之后只要应用不重启,GIT中文件的修改,应用无法感知, 即使重启Config Se ...
java熔断机制 breaker_Spring Cloud熔断机制 -- 断路器
1. 熔断机制介绍在介绍熔断机制之前,我们需要了解微服务的雪崩效应.在微服务架构中,微服务是完成一个单一的业务功能,这样做的好处是可以做到解耦,每个微服务可以独立演进.但是,一个应用可能会有多个微服 ...
SpringCloud微服务的熔断机制和熔断的意义？
什么是微服务的熔断机制在2017年2月1日,GitLab公司的运维人员就出现过这样的事故.当时运维人员在进行数据库维护时,通过执行rm -rf命令,删除了约300GB生产环境数据.由于数据备份失效, ...
图像设定阈值二值matlab,“图像类型转换II——使用“导入、导出和转换”中的“阈值法”转换为二值图像”,MATLABImageProcessingToolbox,入门教程,七,之...
1 imbinarize函数在 [MATLAB Image Processing Toolbox 入门教程二]快速入门之"亮度校正"和"目标识别" 中我们已经 ...
SpringCloud 入门教程(八)：断路器指标数据监控Hystrix Dashboard 和 Turbine
1. Hystrix Dashboard (断路器:hystrix 仪表盘) Hystrix一个很重要的功能是,可以通过HystrixCommand收集相关数据指标. Hystrix Dashboa ...

SpringCloud 入门教程(七)：熔断机制 -- 断路器

SpringCloud 入门教程(七)：熔断机制 -- 断路器相关推荐

最新文章

热门文章

SpringCloud 入门教程(七)： 熔断机制 -- 断路器

SpringCloud 入门教程(七)： 熔断机制 -- 断路器相关推荐

最新文章

热门文章

SpringCloud 入门教程(七)：熔断机制 -- 断路器

SpringCloud 入门教程(七)：熔断机制 -- 断路器相关推荐