Spring Cloud系列（四）：断路器Hystrix

上一篇介绍了负载均衡的配置方法，做负载均衡是为了保证高可用性，但是有时候服务提供者挂掉了，比如服务A调用了服务B，服务B又调用了服务C，然后有一天服务C的所有节点都挂掉了，这时服务B就会因为C异常而在不停地等待，服务A又会因为服务B没响应在不断地等待，结果请求来得越来越多，使得整个系统雪崩式地出现异常。

为了防止这种情况的出现，我们需要给服务做一些保护的措施，当服务B调用服务C在一定时间内出现同样的异常，比如在5秒内出现了20次，那么后面服务B就不要再去调用服务C了，它已经出现问题了，你自己另找办法吧（比如执行另一个方法或者直接返回错误）。

Hystrix就是用来做熔断的，它类似于我们家庭电路的保险丝，当服务提供者出现异常导致无法调用，就会把消费者到提供者这条链路给断掉，不让客户端一直等待，保护整个系统。

断路器功能是在服务消费者上实现的，上一篇介绍了ribbon和feign两种消费服务方式，本篇也会在分别在这两种方式上实现。我们仍然在之前的项目添加断路器的功能。

一、在Ribbon中使用断路器

1.1、添加ribbon依赖

在service-consumer-ribbon的pom文件添加Hystrix的依赖

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

1.2、开启断路器

在启动类添加@EnableHystrix注解

1.3、提供断路方法

修改RibbonConsumerService类如下

@Service
public class RibbonConsumerService {
    @Autowired
    private RestTemplate restTemplate;

    @HystrixCommand(fallbackMethod = "indexError")
    public String index(String uid) {
        return restTemplate.getForObject("http://SERVICE-PROVIDER/callServiceProvider?uid=" + uid, String.class);
    }

    public String indexError(String uid) {
        return uid + "，你好，服务提供者出错了，直接返回错误信息";
    }
}

就是添加了一个当断路后调用的方法，然后在原来的index方法加上@HystrixCommand注解，意思就是先调用远程的http方法，如果失败就会去调用indexError方法，起到了断路的作用

1.4、测试

分别启动单节点注册中心、单节点服务消费者和ribbon消费者三个项目，访问http://localhost:8080/index?uid=ribbon，可以看到返回了

服务8770的消息：用户ribbon调用了此服务

然后把服务提供者停止，再次访问http://localhost:8080/index?uid=ribbon，可以看到返回的是

ribbon，你好，服务提供者出错了，直接返回错误信息

说明断路器起作用了

二、在Feign中使用断路器

2.1、启动断路器功能

Feign自带断路器的，但是在Greenwich版本中默认是关闭的，先在service-consumer-feign的application.properties中添加以下配置

feign.hystrix.enabled=true

2.2、提供断路方法

创建一个类FeignConsumerServiceImpl实现FeignConsumerService接口

@Component
public class FeignConsumerServiceImpl implements FeignConsumerService {
    
    @Override
    public String index(String uid) {
        return uid + "，你好，服务提供者出错了，直接返回错误信息";
    }
}

然后在原来的接口的注解加上fallBack属性，值就是断路器类

@FeignClient(value = "service-provider", fallback = FeignConsumerServiceImpl.class)
public interface FeignConsumerService {

    @RequestMapping("/callServiceProvider")
    String index(@RequestParam("uid") String uid);
}

2.3、测试

测试方法和ribbon的一样，就不再赘述了

三、Hystrix Dashboard

Hystrix断路器还提供了实时监控后台给我们使用——Hystrix Dashboard。

3.1、创建看板module

新建一个module，名称为hystrix-dashboard，添加Spring Web和Hystrix DashBoard依赖，如下：

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

启动类添加@EnableHystrixDashboard注解

3.2、修改服务消费者

我们先在ribbon消费者中添加Spring Boot Actuator依赖，如下

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

接着在application.properties中添加一下配置

management.endpoints.web.exposure.include=*

因为在Spring Boot 2.X Actuator暴露的端口只有info和health两个端点，我们先把所有的端点都开放

3.3、启动&测试

依次启动注册中心、服务提供者、服务消费者和Hystrix Dashboard，然后访问http://localhost:8888/hystrix，就可以看到Hystrix的界面了

在界面上我们可以看到断路器支持默认集群、指定集群和单应用，我们这里只演示单应用的用法。

在中间输入http://localhost:8080/actuator/hystrix.stream，然后点击Monitor Stream按钮，可以看到当前的调用情况

因为我们还没有调用任何的服务提供者，所以这里没有数据显示。连续访问http://localhost:8080/index?uid=ribbon后可以看到监控页面出现调用的数据

比如这里的数据是8次成功，0次超时、错误率0.0%，这里的数字说明对应着右上角不同颜色的提示说明，Circult的状态为Closed。我们把服务提供者停止，然后连续访问http://localhost:8080/index?uid=ribbon，当服务提供者出错率达到一定程度（默认是5秒出错20次），断路器就会熔断，Circult的状态变为Open

feign中的用法也是一样的，就不再重复。

四、总结

断路器相关的内容介绍到这里，下一篇介绍网关。

源码已经上传到github：https://github.com/spareyaya/spring-cloud-demo/tree/master/chapter4