我的博客：兰陵笑笑生,欢迎浏览博客！

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

一、前言

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

二、Hystrix简介

2.1 服务雪崩

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

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

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

通过客户端执行网络访问时，这些问题会更加的严重，第三方依赖就相当于一个"黑夹子"，封装操作的细节，而且还可以随时的修改，每个客户端的网络和资源配置都不同，通常也难以监控可修改。所有的问题都代表了需要对故障和延迟做隔离，单个依赖的故障不能关闭整个系统：

2.2 Hypstrix 设计原则：

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

2.3 Hystrix 设计原理

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

三、快速开始

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 {@AutowiredHelloApi 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 {@AutowiredHelloApi 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

四、总结

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

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

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

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

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

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

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

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

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

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

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

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

hystrix threadpool coresize_SpringCloud 基础教程(八)-Hystrix熔断器（上）
我的博客:兰陵笑笑生,欢迎浏览博客! 关注公众号:"程序员笑笑生", 回复 "Spring Cloud"."Spring Boot" 获取 ...
（转）jquery基础教程八 load方法及小技巧
首先我们看看手册上的描述 load(url, params, callback) 装入一个远程HTML内容到一个DOM结点. 注意:避免用装入的scripts脚本,装入脚本改用$.getScript. ...
（四）SpringCloud代码实战之hystrix熔断器
分布式微服务,在服务调用的时候可能回因为网络故障以及其他原因,造成服务无法调用.会导致该线程无法关闭,一直卡在这里,等到卡住的线程越来越多,服务器资源被耗尽,就会出现服务宕机,一连串相关的服务宕机(雪 ...
SpringCloud 入门教程(八)：断路器指标数据监控Hystrix Dashboard 和 Turbine
1. Hystrix Dashboard (断路器:hystrix 仪表盘) Hystrix一个很重要的功能是,可以通过HystrixCommand收集相关数据指标. Hystrix Dashboa ...
Spring Boot 2.x基础教程：实现文件上传
文件上传的功能实现是我们做Web应用时候最为常见的应用场景,比如:实现头像的上传,Excel文件数据的导入等功能,都需要我们先实现文件的上传,然后再做图片的裁剪,excel数据的解析入库等后续操作. ...
python基础教程--代码集合（上）
文章目录 1.转义字符与原字符 2.二进制与字符编码 3.二进制编码 4.变量定义 4.数据类型 5.浮点数类型 6.布尔类型 7.字符串类型 8.数据类型转换 9.注释功能 10.标识符和保留字 1 ...
【UV打印机】PrintExp打印软件教程(八)-厂家模式(上)
00. 目录文章目录 00. 目录 01. 概述 02. PrintExp厂家模式菜单栏 03. PrintExp厂家模式工具栏 04. PrintExp厂家模式开机初始化 05. PrintExp ...
Shell基础教程八: Shell数组：shell数组的定义、数组长度
Shell在编程方面比Windows批处理强大很多,无论是在循环.运算. bash支持一维数组(不支持多维数组),并且没有限定数组的大小.类似与C语言,数组元素的下标由0开始编号.获取数组中的元素要利 ...
Spring Boot 2.x基础教程：多文件的上传
昨天,我们介绍了如何在Spring Boot中实现文件的上传(博客地址:https://blog.didispace.com/spring-boot-learning-21-4-3/).有读者问:那么 ...

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