断路器
断路器模式源于Martin Fowler的Circuit Breaker一文。“断路器”本身是一种开关装置,用于在电路上保护线路过载,当线路中有电器发生短路时,“断路器”能够及时的切断故障电路,防止发生过载、发热、甚至起火等严重后果。
在分布式架构中,断路器模式的作用也是类似的,当某个服务单元发生故障(类似用电器发生短路)之后,通过断路器的故障监控(类似熔断保险丝),向调用方返回一个错误响应,而不是长时间的等待。这样就不会使得线程因调用故障服务被长时间占用不释放,避免了故障在分布式系统中的蔓延。
断路器监控
在微服务架构中为例保证程序的可用性,防止程序出错导致网络阻塞,出现了断路器模型。断路器的状况反应了一个程序的可用性和健壮性,它是一个重要指标。Hystrix Dashboard是作为断路器状态的一个组件,提供了数据监控和友好的图形化界面
改造项目
复制项目 spring-cloud-ribbon-consumer-hystrix
,修改名称 spring-cloud-ribbon-consumer-hystrix-dashboard
在它的基础上进行改造。 Feign
的改造和这一样。
在 pom
的工程文件引入相应的依赖:
<dependency>
<groupId>
org.springframework.cloud
</groupId>
<artifactId>
spring-cloud-starter-hystrix
</artifactId>
</dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-actuator
</artifactId>
</dependency>
<dependency>
<groupId>
org.springframework.cloud
</groupId>
<artifactId>
spring-cloud-starter-hystrix-dashboard
</artifactId>
</dependency>
开启 HD
修改 RibbonConsumerApplication.java
类
在程序的入口 RibbonConsumerApplication
类,加上 @EnableHystrix
注解开启断路器,这个是必须的,并且需要在程序中声明断路点 @HystrixCommand;
加上 @EnableHystrixDashboard
注解,开启 `HystrixDashboard
package io.ymq.example.ribbon.consumer.hystrix;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.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;import org.springframework.context.annotation.Bean;..import org.springframework.web.client.RestTemplate;@EnableHystrix@EnableDiscoveryClient@EnableHystrixDashboard@SpringBootApplicationpublic class RibbonConsumerApplication { @LoadBalanced @Bean RestTemplate restTemplate() { return new RestTemplate(); public static void main(String[] args) { SpringApplication.run(RibbonConsumerApplication.class, args);
声明断路点
声明断路点 @HystrixCommand(fallbackMethod="defaultStores")
package io.ymq.example.ribbon.consumer.hystrix;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
* 描述:调用提供者的 `home` 方法
* @author yanpenglei
@RestController
public class ConsumerController {
@Autowired
private RestTemplate restTemplate;
@HystrixCommand(fallbackMethod = "defaultStores")
@GetMapping(value = "/hello")
public String hello() {
return restTemplate.getForEntity("http://eureka-provider/", String.class).getBody();
public String defaultStores() {
return "feign + hystrix Dashboard ,提供者服务挂了";
}
@HystrixCommand
表明该方法为 hystrix
包裹,可以对依赖服务进行隔离、降级、快速失败、快速重试等等 hystrix
相关功能 该注解属性较多,下面讲解其中几个
fallbackMethod
降级方法
commandProperties
普通配置属性,可以配置 HystrixCommand
对应属性,例如采用线程池还是信号量隔离、熔断器熔断规则等等
ignoreExceptions
忽略的异常,默认 HystrixBadRequestException
不计入失败
groupKey()
组名称,默认使用类名称
commandKey
命令名称,默认使用方法名