Spring Cloud:熔断器Hystrix
一.雪崩效应
在微服务架构中通常会有多个服务层调用,基础服务的故障可能会导致级联故障,进而造成整个系统不可用的情况,这种现象被称为服务雪崩效应。服务雪崩效应是一种因“服务提供者”的不可用导致“服务消费者”的不可用,并将不可用逐渐放大的过程。
如果下图所示:A作为服务提供者,B为A的服务消费者,C和D是B的服务消费者。A不可用引起了B的不可用,并将不可用像滚雪球一样放大到C和D时,雪崩效应就形成了。
二.熔断器(CircuitBreaker)
熔断器的原理很简单,如同电力过载保护器。它可以实现快速失败,如果它在一段时间内侦测到许多类似的错误,会强迫其以后的多个调用快速失败,不再访问远程服务器,从而防止应用程序不断地尝试执行可能会失败的操作,使得应用程序继续执行而不用等待修正错误,或者浪费CPU时间去等到长时间的超时产生。熔断器也可以使应用程序能够诊断错误是否已经修正,如果已经修正,应用程序会再次尝试调用操作。
熔断器模式就像是那些容易导致错误的操作的一种代理。这种代理能够记录最近调用发生错误的次数,然后决定使用允许操作继续,或者立即返回错误。 熔断器开关相互转换的逻辑如下图:
熔断器就是保护服务高可用的最后一道防线。
三.Hystrix特性
1.断路器机制
断路器很好理解,当 Hystrix Command 请求后端服务失败数量超过一定比例(默认50%),断路器会切换到开路状态(Open)。这时所有请求会直接失败而不会发送到后端服务。断路器保持在开路状态一段时间后(默认5秒),自动切换到半开路状态(HALF-OPEN)。这时会判断下一次请求的返回情况,如果请求成功,断路器切回闭路状态(CLOSED),否则重新切换到开路状态(OPEN)。Hystrix 的断路器就像我们家庭电路中的保险丝,一旦后端服务不可用,断路器会直接切断请求链,避免发送大量无效请求影响系统吞吐量,并且断路器有自我检测并恢复的能力。
2.Fallback
Fallback 相当于是降级操作。对于查询操作,我们可以实现一个 fallback 方法,当请求后端服务出现异常的时候,可以使用 fallback 方法返回的值。fallback 方法的返回值一般是设置的默认值或者来自缓存。
3.资源隔离
在 Hystrix 中,主要通过线程池来实现资源隔离。通常在使用的时候我们会根据调用的远程服务划分出多个线程池。例如:调用产品服务的Command 放入A线程池,调用账户服务的 Command 放入B线程池。这样做的主要优点是运行环境被隔离开了。这样就算调用服务的代码存在 bug 或者由于其他原因导致自己所在线程池被耗尽时,不会对系统的其他服务造成影响。但是带来的代价就是维护多个线程池会对系统带来额外的性能开销。如果是对性能有严格要求而且确信自己调用服务的客户端代码不会出问题的话,可以使用 Hystrix 的信号模式(Semaphores)来隔离资源。
四.Feign Hystrix
因为熔断只是作用在服务调用这一端,因此我们根据上一篇的示例代码只需要改动 spring-cloud-consumer 项目相关代码就可以。因为,Feign 中已经依赖了 Hystrix,所以在 maven 配置上不用做任何改动。
1.配置文件
application.properties 添加这一条:
feign.hystrix.enabled=true
2.创建回调类
创建 HelloRemoteHystrix 类继承与 HelloRemote 实现回调的方法:
@Componentpublic class HelloRemoteHystrix implements HelloRemote{@Overridepublic String hello(@RequestParam(value = "name") String name) {return "hello" +name+", this messge send failed ";}}
3.添加 fallback 属性
在 HelloRemote 类添加指定 fallback 类,在服务熔断的时候返回 fallback 类中的内容。
@FeignClient(name= "spring-cloud-producer",fallback = HelloRemoteHystrix.class)public interface HelloRemote {@RequestMapping(value = "/hello")public String hello(@RequestParam(value = "name") String name);}
4.测试
那我们就来测试一下看看效果吧。
依次启动 spring-cloud-eureka、spring-cloud-producer、spring-cloud-consumer 三个项目。
浏览器中输入:http://localhost:9001/hello/neo,返回:hello neo,this is first messge,说明加入熔断相关信息后,不影响正常的访问。
接下来我们手动停止 spring-cloud-producer 项目再次测试:
浏览器中输入:http://localhost:9001/hello/neo,返回:hello neo, this messge send failed,根据返回结果说明熔断成功。
参考文章:http://www.ityouknow.com/springcloud/2017/05/16/springcloud-hystrix.html
Spring Cloud:熔断器Hystrix相关推荐
- Spring Cloud中Hystrix、Ribbon及Feign的熔断关系是什么?
导读 今天和大家聊一聊在Spring Cloud微服务框架实践中,比较核心但是又很容易把人搞得稀里糊涂的一个问题,那就是在Spring Cloud中Hystrix.Ribbon以及Feign它们三者之 ...
- Spring Cloud之Hystrix服务容错
Spring Cloud之Hystrix服务容错 Hystrix的概述 Hystrix的使用 相关依赖 Eureka注册中心 服务提供者 服务消费者 执行测试 @HystrixCommand详解 服务 ...
- Spring Cloud Netfix Hystrix(断路器)
一.灾难性雪崩 造成灾难性雪崩效应的原因,可以简单归结为下述三种: 服务提供者(Application Service)不可用.如:硬件故障.程序BUG.缓存击穿.并发请求量过大等. 重试加大流量.如 ...
- Spring Cloud 之 Hystrix
Spring Cloud 之 Hystrix 1. Feign+Hystrix实现RPC调用保护 2. Spring Cloud Hystrix失败回退 3. Spring Cloud Hystrix ...
- Spring Cloud中Hystrix仪表盘与Turbine集群监控
Hystrix仪表盘,就像汽车的仪表盘实时显示汽车的各项数据一样,Hystrix仪表盘主要用来监控Hystrix的实时运行状态,通过它我们可以看到Hystrix的各项指标信息,从而快速发现系统中存在的 ...
- Spring Cloud中Hystrix 线程隔离导致ThreadLocal数据丢失(续)
前言 上篇文章<Spring Cloud中Hystrix 线程隔离导致ThreadLocal数据丢失>我们对ThreadLocal数据丢失进行了详细的分析,并通过代码的方式复现了这个问题. ...
- Spring Cloud中Hystrix的请求合并
在微服务架构中,我们将一个项目拆分成很多个独立的模块,这些独立的模块通过远程调用来互相配合工作,但是,在高并发情况下,通信次数的增加会导致总的通信时间增加,同时,线程池的资源也是有限的,高并发环境会导 ...
- Spring Cloud中Hystrix仪表盘与Turbine集群监控 1
Hystrix仪表盘,就像汽车的仪表盘实时显示汽车的各项数据一样,Hystrix仪表盘主要用来监控Hystrix的实时运行状态,通过它我们可以看到Hystrix的各项指标信息,从而快速发现系统中存在的 ...
- Spring Cloud 集成 Hystrix 熔断器
文章目录 Hystrix 熔断器 Hystrix 概述 Hystrix 降级 服务提供方 步骤 pom.xml(依赖) GoodsController.java(包含降级方法) 启动类(@Enable ...
- spring cloud使用hystrix实现断路保护机制
断路保护机制:即容错性,在微服务架构中,系统之间都是相互依赖的,如果一个系统出现了异常,就会出现如下情况: 断路保护机制就是为了解决这种情况. hystrix的大致原理如下: spring cloud ...
最新文章
- 技术总监,被判刑12年!因公司未兑现股权,愤怒植入代码,牟利333万
- python学习笔记---字符串
- 【控制】滑动模式观测器 sliding mode observer
- 【Efficient-Net】基于Efficient-Net效率网的目标识别算法的MATLAB仿真——详细版
- 错误fatal error: zlib.h: 没有那个文件或目录的解决办法
- spring 通过EsClientFactory注入elasticsearch
- MCU提高ADC采样精度的几种方案
- 学习手记(2018/7/14~2018/7/18)——快乐纪中
- c++中list容器
- 让我们发展纯粹的金钱关系吧,那多美好(转)
- oracle单纯的sql能写循环吗,循环执行sql语句
- 商贸宝显示连接不到服务器,登录T1商贸宝就提示 服务器链接失败 请重新登录 这个怎么解决?...
- DCOS快速部署手册
- 第十二周项目四----利用遍历思想求解图问题之7最远顶点
- 315成央视盛宴是中国媒体的悲哀
- 论文导读:Deep Attentive Learning for Stock Movement Prediction From Social Media Text and Company Correl
- QGIS 1. qgis的下载和安装(Windows和macOS)
- 【StyleGAN代码学习】StyleGAN模型架构
- Nginx系列教程(六)| 手把手教你搭建 LNMP 架构并部署天空网络电影系统
- JS(ES5) 实现数组方法(迭代类型:evey、some、map、filter)的重构
热门文章
- 省级交通运输行政执法综合管理信息系统工程方案
- CMD实用指令汇总收集(持续更新中)
- 1560_AURIX_TC275_NMI Trap以及PMC
- java服务器端集成友盟,Android友盟推送集成
- 转;三宫九观二十四坊——摘自苏州热线
- CDH 6.2.0启用kerberos认证
- 纯干货!15000 字语法手册分享给你,看完搞懂,再也不担心SQL写不好了
- C语言——报数问题:有n个人围成一圈,顺序排号。从第一个人开始报数(从1到3报数),凡报到3的人退出圈子,问最后留下的是原来第几号的那位。
- 售前售前售前售前售前
- 一个连接态DRX下的paging接收专利