SpringCloud 基础教程(八)-Hystrix熔断器（上）

  个人博客：兰陵笑笑生,欢迎浏览博客！

 上一章 SpringCloud基础教程(七)-声明式服务调用Fegign当中，咱们介绍了使用Fegin更加简化的实现服务间的调用.本章节我将继续探索Hystrix组件的使用。

1、前言

 在分布式的环境中，服务之间得依赖不可避免的会失败，Hystrix是Netfilx的库，主要是经过添加延迟和容错的逻辑帮助控制分布式服务之间的交互，Hystrix经过隔离服务之间的访问点，中止他们之间的级联故障以及提供备选的选项来实现这一点。

2、Hystrix简介

2.1 服务雪崩

 假设在分布式的环境中，全部的一切都正常，请求流以下图所示：

当许多后端服务变的一个故障时，会致使某一个、多个调用不可用，而且占用系统的线程，I/O等资源：

 随着请求数的变大，就能致使全部服务器上的资源几秒钟内饱和，又称为雪崩状态：

 经过客户端执行网络访问时，这些问题会更加的严重，第三方依赖就至关于一个"黑夹子"，封装操做的细节，并且还能够随时的修改，每一个客户端的网络和资源配置都不一样，一般也难以监控可修改。全部的问题都表明了须要对故障和延迟作隔离，单个依赖的故障不能关闭整个系统：

2.2 Hypstrix 设计原则：

• 防止单个依赖耗尽全部容器用户线程
• 提供降级服务，以保护用户请求失败
• 使用隔离技术，阻断一个依赖故障的传播
• 近实时的指标、监控

2.3 Hystrix 设计原理

• 对外部系统或者依赖的调用都封装在HystrixCommand 或者HystrixObservableCommand 对象中，该对象一般单独的在一个线程中执行
• 可自定义设置服务调用超时时间
• 为每个依赖调用维护一个小线程池，若是它满了，则调用会被拒绝，而不是排队阻塞

3、快速开始

3.1 准备工做

 在以前的章节当中，咱们都搭建了如下的模块：

• 注册中心Eureka
• 服务提供者server-provider
• 服务调用者server-consumer

3.2 引入Hystrix

 咱们在服务调用者server-consumer引入hystrix依赖，而且改造原来的服务调用接口：

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

 Fegin的调用接口HelloApi

@FeignClient(name = "server-provider",configuration = MyFeignConfig.class)
public interface HelloApi {
    @RequestMapping("/sayHello")
    public String sayHello(@RequestParam("name") String name);
}

 新建控制器HystrixController，注入Feign接口，调用服务提供者,添加 @HystrixCommand注解，当服务调用失败时，咱们经过fallbackMethod指定失败后调用的本地的方法名称，注意参数必须带上：

@RestController
@RequestMapping("/hystrix")
public class HystrixController {
    @Autowired
    HelloApi helloApi;

    @RequestMapping("/sayHello")
    @HystrixCommand(fallbackMethod = "sayError")
    public String sayHello(String name) {
        return helloApi.sayHello(name);
    }

    public String sayError(String name){
        return "sayError!";
    }

 服务提供端server-provider改造，让接口有通常的概率调用失败：

@RestController
public class RibbonController {
    @Value("${server.port}")
    private String port;

    @RequestMapping("/sayHello")
    public String sayHello(String name) {
        Random random = new Random();
        if (random.nextInt(10) < 5) {
            throw new RuntimeException("erroe");
        }
        return "from:" + port + ",hello!," + name;
    }

 接下来咱们启动Eureka注册中心，两个服务提供者，一个服务调用者：

 

使用浏览器调用接口：http://localhost:5168/hystrix/sayHello?name=name，有一半 概率是 返回"sayError!".

这样就简单的实现了熔断、降级的功能。

 注意：上一章咱们整合了Feign和Hystrix，Feign在配置的时候咱们能够指定@FeignClient注解中的fallback，从这里咱们能够看出来，Feign默认是集成了Hystrix的。若是咱们同时配置了Feign的fallback，同时也配置了 @HystrixCommand(fallbackMethod = "sayError")，那么Feign的配置优先。

3.3 Hystrix更多配置

 咱们能够在@HystrixCommand注解中添加属性，自定义配置，经过查看@HystrixCommand注解的源代码,

咱们能够配置

• commandProperties: 指令属性
• threadPoolProperties：线程池的属性

等等，例如：

@RestController
@RequestMapping("/hystrix")
public class HystrixController {

    @Autowired
    HelloApi helloApi;

    @RequestMapping("/sayHello")
    @HystrixCommand(
            commandProperties = {
                    @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "500"),
                     @HystrixProperty(name = "execution.timeout.enabled", value = "false")
            },
            threadPoolProperties = {
                    @HystrixProperty(name = "coreSize", value = "30"),
                    @HystrixProperty(name = "maxQueueSize", value = "101"),
                    @HystrixProperty(name = "keepAliveTimeMinutes", value = "2"),
                    @HystrixProperty(name = "queueSizeRejectionThreshold", value = "15"),
                    @HystrixProperty(name = "metrics.rollingStats.timeInMilliseconds", value = "1440")
            },
            fallbackMethod = "sayError")
    public String sayHello(String name) {
        return helloApi.sayHello(name);
    }
    public String sayError(String name) {
        return "sayError!";
    }
}

• execution.isolation.thread.timeoutInMilliseconds ：设置thread和semaphore两种策略的超时时间，默认是1000毫秒，这也是咱们写程序常常忽略的一点，命名接口没错，可是调用就是失败，这里咱们能够设置超时时长。

• execution.timeout.enabled：是否开启超时，默认是true

• execution.isolation.thread.interruptOnTimeout:发生超时时，是否中断线程，默认true

• circuitBreaker.sleepWindowInMilliseconds：熔断后多久开始尝试恢复

• circuitBreaker.errorThresholdPercentage：出错百分比阈值，默认是50%

 固然咱们也能够配置在yml配置文件中：经过hystrix.command.[commandKey],commandKey默认是default，对于Zull而言就是 service ID：

hystrix:
  command:
    default:
      execution:
        timeout:
          enabled : false

 关于更多的配置能够参考：https://github.com/Netflix/Hystrix/wiki/Configuration

4、总结

 咱们了解了Hystrix利用线程池实现了对服务的隔离，熔断器是位于线程池以前的组件,Hystrix的功能对于微服务是一个不可缺乏的组件，同时提供了二次的开发能力，下一章咱们将继续了解如何使用Hystrix实现监控功能。

以就是本期的分享，你还能够关注公众号:** 程序员笑笑生**，关注更多精彩内容！

SpringCloud基础教程(一)-微服务与SpringCloud

SpringCloud基础教程(二)-服务发现 Eureka

SpringCloud基础教程(三)-Eureka进阶

SpringCloud 基础教程(四)-配置中心入门

SpringCloud基础教程(五)-配置中心热生效和高可用

SpringCloud 基础教程(六)-负载均衡Ribbon

SpringCloud 基础教程(七)-Feign声明式服务调用

更多精彩内容，请期待...

本文由博客一文多发平台 OpenWrite 发布！

个人博客地址兰陵笑笑生,欢迎浏览！