Spring Cloud Netflix微服务组件-Hystrix

news2024/11/26 18:45:08

目录

Hystrix的主要功能

传统容错手段

超时机制

应用容错三板斧

超时机制

舱壁隔离

熔断降级

侵入式Command用法

改进版一:ribbon与hystrix组合

改进版二:feign与hystrix组合

Hystrix三态转换图

源码分析

流程图

原理流程图

核心实现流程图

入口

HystrixCircuitBerakerConfiguration

如何做功能增强?

@HystrixCommand注解的切面逻辑

CommandExecutor#execute()

HystrixCommand#execute()

applyHystrixSemantics()(熔断器核心逻辑)

流程图

熔断器打开时

熔断器关闭时

线程隔离有两种隔离模式

信号量隔离逻辑

线程池隔离逻辑

线程池隔离原理

熔断器源码

流程图

熔断器初始化

熔断器判断机制

如何进入半开状态

滑动时间窗口

原理图

相关配置参数

监控数据收集


Hystrix的主要功能

  • 线程池隔离、
  • 熔断降级、
  • 超时降级、
  • 宕机降级 

传统容错手段

超时机制

是设置RestTemplate的连接超时和读取超时,这是我们在没有使用hytrix这些辅助的分布式工具时的做法

af9f3d20e9624a65a69a73bf57990fba.png

全局异常处理器

6268a3a00e164877b6971f89825f5a0a.png控制器中,捕获超时异常,封装成统一的自定义异常并再次抛出,让全局异常处理器来进行处理

ead32e620ec441af8160f4c075aa91e6.png

上面这种,就是传统的容错的处理套路

应用容错三板斧

超时机制

以前没有hytrix的时候,就是直接给RestTemplate设置一个超时时间,RestTemplate调用超时时会抛出TimeoutException,然后我们直接catch到此异常,就直接把同步阻塞的调用线程掐死

d07b46c11d16419185f97469cd5a5caf.png

舱壁隔离

说白了就是资源隔离,比如线程池隔离

1d008450df664fd38b8ecc24c3c2e3cc.png

熔断降级

b747210f7ebe40e288f40787051edfdb.png

当一段时间内失败次数达到一定阈值,那么熔断器就会打开,此时主业务线程就不会再去调用真正的远程的业务方法,而是直接调用本地早已写好的“降级方法”,返回一个可预知的结果。也就是说:熔断是结果,降级是处理的手段

侵入式Command用法

我们只会下单、支付、调库存等核心高频接口,才需要进行降级,才需要自己在本地写降级方法

d0f200c4915b4cd7b35fa3629f093035.png

这样当前端看到返回的订单的订单号为-1时,就可以给客户展示一个友好的页面,比如当前系统开了小差之类的

1c3650ee063c441e8df6c0cb11911d44.png

原始的hytrix API处理熔断降级时,就需要这样的强侵入式写法

改进版一:ribbon与hystrix组合

a1e2ddbc9f0042a8815baf91f95edba0.png

c553f1776c4248d2a1152aa5da4b383b.png

这里可以配置线程池

改进版二:feign与hystrix组合

feign调用时,通过hystrix进行降级

8b1d6400aae7438e8b4021fa00188559.png

a28c1c082bc448b2a7b44348416796df.png85b1a561201347998fa2ff648db99e46.png

Hystrix的默认配置跳闸阈值

60511a68b2974cd8a97c7fbecdf23b72.png

上面就是可能会发生降级的三种情况,分别是:宕机降级、超时降级、异常降级

aff49a154fb946e6a1ddfd02ff2a0a82.png

生产上上面的配置一般不动,使用默认的配置值

Hystrix三态转换图

ba72e4fc930b4ce481d7a20086a8d48d.png

默认失败比例超过50%,则会打开熔断器

  • 熔断时间窗口结束后,熔断器状态就从打开转换到半开状态,此时会放过一条请求去请求真正的远程业务方法,如果此次调用成功,则熔断器状态就转成关闭状态,如果此次调用任失败,那么熔断器就又会回到打开状态
  • 什么叫调用失败?客户端去调用服务端接口API,服务端抛了异常并且没有catch直接抛了出来、服务器宕机、服务端接口业务执行耗时太多导致客户端等待接口返回超时
  • 半开状态存在的意义就是为了,让熔断器有机会回到关闭状态(也就是回到能正常去远程调用的状态)

94ee31ab676d4bb09cf6cdcdf72c7132.png这个就是工作中需要配置的ribbon的超时时间,配置了ribbon的超时时间,那么restTemplate也自动跟随ribbon的超时时间了 

3205ac1ae96c4db28441a4752a390430.png

这些参数的设置,就供学习,平时生产大多使用默认参数

如何关闭hystrix对feign的支持

e5046c45db234927a16c0ea4dec95085.png

5a7a49d96ceb45f89157caf024977855.png

这里需要hystrix的超时时间需要设置为6000

生产上需要:

hystrix的超时时间  >  (本次调用次数 1 + 出现异常时对当前实例的重试次数 1 + 切换实例后的重试次数 1) * ribbon的超时时间 = 3 * ribbon的超时时间

因为hystrix要保证所有的ribbon调用重试都结束后,hystrix再去插断主线程的调用并给主线程返回降级结果

a81263e29709429b94c0fe57c8a5841e.png

第89行,把总体的熔断机制的打开

第92行,可以开始选择某一个方法关闭熔断机制(剩下的,就是局部开启的)

注意上面参数赋值用等号=

源码分析

流程图

原理流程图

25a08fd56ba94003854bb627590de25f.png

核心实现流程图

727cdd94a9974a69b472e737179a5120.png

入口

a1e2ddbc9f0042a8815baf91f95edba0.png

通过框架的启动注解开始,实际上这个注解内部就是通过@Import注解,去加载spring.factories中以EnableCircuitBreaker为key的“普通配置类

这个ImportSelector的作用,就是去找Netflix-core.jar下的spring.factories中以EnableCircuitBreaker为key的键值对,将该key对应的值为一个普通配置类HystrixCircuitBerakerConfiguration,将它注入到ioc容器中来

5579727128fc44cfb255e01905fd97fb.png

  • 因为Springboot默认的自动配置类读取功能,仅仅只是读取所有jar包下spring.factories中以EnableAutoConfigurationr为key的“自动配置类
  • 各个第三方组件自定义的一些key下所属的“普通配置类”,Springboot是不负责读取的,需要各个第三方组件自己开发针对该key的加载功能
  • 普通配置类以XxxxxConfiguration命名,自动配置类以XxxxxAutoConfiguration命名

aa36fba3588b4251a4107eed4f168bbc.png

业务系统首先引入这个starter-netflix-hystrix,这个starter相当于一个聚合器,内部聚合了很多别的功能jar包

这些带有spring-cloud-开头的,就是spring cloud官方为了整合Netflix hystrix组件而开发的自动装配包 

a6be69e2eca344fcaa6ca4cfe0db0436.png

优先看与核心功能相关的配置类,比如这里就优先看HystrixCircuitBreakerConfiguration类,像这种HystrixSecurityAutoConfiguration一看就是与安全有关的,非主功能,我们就先不看,这些都是看源码的技巧

a17a3d923a8748d08caf48fe30714d87.png

HystrixCircuitBerakerConfiguration

dc842cda3f6b4bd282315c899228074d.png

如何做功能增强?

  • 无非就是用代理AOP,横切拦截
  • 或者加待增强对象所拥有的拦截器链中加一个拦截器/过滤器

@HystrixCommand注解的切面逻辑

这一段切面逻辑,也就是每一个被@HystrixCommand注解修饰的方法,在被调起之前,都会先走一遍这个切面增强逻辑。而这一段切面增强逻辑,实际上也就是Hystrix熔断器起作用的逻辑

注意,这都是在客户端执行的代码,也就是请求发起方,此时还没有到接口提供方(服务端)

第90行,同时会拦截@HystrixCommand,还有合并请求的@HystrixCollapser

a501741b16ee4475ab7ed415ca235e1b.png

第96行,会创建一个HystrixInvokable,如下是第96行的create()逻辑:

GenericCommand命令模式对象中有两个核心方法,一个就是run()也就是正常的业务逻辑方法,另一个就是getFallback()也就是降级方法,getFallback()内部会通过反射调用@HystrixCommand中配置的fallBackMethod方法

从这里也知道,返回的HystrixInvokable,实际上就是一个GenericCommand

截止以上的流程图

CommandExecutor#execute()

ed746f165f754663abde6a574e3ba8e7.png

HystrixCommand#execute()

44dd515ea8834875b42e7a8d6b889eca.png

queue()返回一个Future凭证,从这里开始就是一堆的响应式变成了,各种定义监听与事件响应执行来串起整个执行流程

e5b66dce859b49cbb95e1ac1d1441e84.png

上述流程对应的流程图

23e414e6eb5e4371a1599d1a28727d53.png

响应式编程的定义语法(rxJava响应式编程框架,手机上用的比较多)响应式编程说白了就是一堆的观察者模式,zookeeper里面的节点内容变化也会触发监听器执行,这都是观察者模式

1ad7482a56a2483eb75394e422c21921.png

总体原理就是:Observable是被观察者,Observer是观察者,当被观察者发生变化时就会回调观察者

231bae12dbaf48d28b4e33c140165e7f.png

这里就把34行就当做定义了一个观察者,45行就定义了一个被观察者

e255c77d8950426886a7cfb81592e41c.png

这里把观察者,注册绑定到被观察者上,以后被观察者发生不同事件,就会回调不同的观察者的call()方法

这里就是被@HystrixCommand注解修饰的方法,在发起一次调用时,如果调用的方法正常返回

90b6f66a318a40c599acedbe835ec41d.png

这里就出现了一个核心观察者applyHystrixSemantics()

applyHystrixSemantics()(熔断器核心逻辑)

流程图

59fe487e352c42cf84e096c55fbf1c19.png

熔断器打开时

当发现当前熔断器是打开状态,则调用FallBack方法,也就是调用GenericCommand的getFallBack()方法,getFallBack()方法会去找到@HystrixCommand中配置的fallBackMethod方法,并执行这个fallBackMethod方法方法(最终,就是通过方法名,通过反射来调用到fallBackMethod方法的)

第523行,判断当前熔断器状态,是否为打开状态

第523行,判断当前熔断器状态是关闭状态,则走524行开始的逻辑,如果判断熔断器当前是打开状态,则走557行的FallBack逻辑,也就是调用降级逻辑

判断当前熔断器状态,是否为打开状态

熔断器可以强制配置为关闭,但是这里代码写的有点难理解,与正常思维判断逻辑是个反的

熔断器关闭时

线程隔离有两种隔离模式
  • 一种是信号量的隔离模式,信号量计数器满了以后也会走降级逻辑
  • 一种是线程池的隔离模式,线程池满了以后也会走降级逻辑

信号量隔离逻辑

20ce1659ed3740fa984cef7fd0707ff4.png

信号量的隔离模式下,如果542行获取信号量失败,则执行554行的信号量拒绝FallBack,但是现实中基本都用线程池隔离模式

线程池隔离逻辑

这是在没有配置信号量策略时

如果没有配置信号量,那么下面的第542行会一直返回true,从而进入真正的线程池隔离的逻辑

executeCommandAndObserve()

8c423d78cbad4f4db36b5b16ec32801f.png

a95e8cb47c144c2dbe5b961e9bc86f00.png 51898b7ff86240e7bd055ee2390f5510.pnggetUserExecutionObservable()方法中就有监听回调方法,回调方法内部,就会通过线程池线程调用GenericCommand的run()

9a2f55bdaeb5400b8b06cba1f4abe077.png

281d0e8871044e6190b85915dd8f7f7f.png

线程池隔离原理

783298f47a0e4bd885138e8787a1093d.png

a17a3d923a8748d08caf48fe30714d87.png

大体流程:用户在调用findById()方法时,hystrix写的AOP切面类会拦截这个注解,拦截这个注解后会初始化一个GenericCommand命令,在初始化这个GenericCommand命令内部,就会通过这些线程池的配置,来初始化该命令特有的执行线程池

562dfa7125f646ff9a28cbf4cb4daae5.png

上上图@HystrixCommand注解中的所有信息,默认就会被保存在这个元信息MetaHolder中去,Spring的代码都是很统一的,这种注解的元数据一般都是用MetaXxxxx来保存的 

这里就通过注解的元信息来构造了一个GenericCommand命令。GenericCommand是AbstractCommand的子类

AbstractCommand

bd4b1e58197a4554ae38dfdf061fbbe6.png

1b3dce52d5f4438ab58389b6242ead16.png

@HystrixCommand注解中的所有信息,默认就会被保存在这个元信息MetaHolder中,从这些元信息中,就能获得到threadPoolProperties信息

这里就会用到threadPoolKey,

所以,这里就实现了有多少key就会初始化出来多少个线程池,也就实现了通过key的不同来实现不同粒度的隔离 

如果有多个业务方法配置了相同的key,那么也就实现了多个hystrix方法公用了同一个线程池

线程池缓存的技术

以后线程池隔离执行时,就是把当前的GenericCommand#run()方法,丢进这个threadPool中去执行的

7cab0163d1eb48208bae5ad7e08b5369.png

a17a3d923a8748d08caf48fe30714d87.png

利用线程池缓存的技术,实现多个用户方法公用同一个线程池的目的,只需要多个方法,配置相同的commandKey和threadPoolKey

e2b53d88285d425783f08eceae9343c7.png

熔断器源码

hytrix的熔断器是可以直接关掉不启用的

流程图

1045ba63705243618b16100246307868.png

熔断器初始化

每个命令对象,都有自己专属的熔断器,也有自己专属的线程池

如果没有设置启用熔断器,则直接返回NoOpCircuitBreaker

从这里也能看到,

每一个CommandKey方法,都有对应自己唯一的熔断器,互相之间不影响,不会出现一个方法的熔断器打开了,影响到了别的方法的调用执行

熔断器判断机制

每一次请求调用,都会走这个onNext()方法

第179行,判断时间窗口内的所有请求,是否小于滑动窗口能触发熔断的最小请求数,如果小于则代码直接跳过不做任何操作(也就是不做打开熔断器的逻辑)

第185行,说明样本数达标了20个,

  • 第186行,如果错误率小于配置的错误率值,比如小于50%,直接跳过不做任何操作
  • 第192行,如果错误率大于配置的错误率值,比如小于50%,打开熔断器,并给熔断器记录下当前打开时的时间戳circuitOpened(因为熔断器打开后,有个默认5s的持续,超过5s后进入半开状态,放一个请求过去) 

如何进入半开状态

判断当前时间,是否超过熔断器睡觉的5s

如果熔断器睡觉超过5s,则把熔断器置为半开状态

滑动时间窗口

这个滑动时间窗口,也可以用来实现限流策略

原理图

7624b9ac37844b40aedc4670e14da1d0.png

0125ddc9307044f0b3c12912c00e2a3d.png

相关配置参数

numbuckets就是为了调整时间的统计粒度,统计粒度越细则熔断器对于网络堵塞等异常状态的感应就更加灵敏

滑动窗口触发熔断的最小请求数,这个是整个时间窗口内的,这是一种兜底策略

监控数据收集

a430ba81d2e248dfb0cd27fb4e3544e5.png

e6d503accd26406e89da63e9dda2cc77.png

上图画反了,下图是对的

8153d225447a40bb8b2078b6dee113b1.png

对应源码如下:

每次请求,都会走上面的判断逻辑

第643行,给execution注册了一个doOnCompleted事件,这个事件就会在当前请求顺利执行成功后,就会回调这个事件对应的回调方法,也就是下面这段逻辑:

15861c844e9f404e8e5a2063844c707d.png

每次请求调用成功没有抛异常,就会调用这个回调方法,这个回调方法内部就会调用断路器HystrixCircuitBreakerImpl的markSuccess()方法,进行调用数据上报数据统计中心

0b6c20fbd56e4c16b97a48de7e80bd4c.png

第207行是上报本次调用数据,比如本次调用是调用成功、熔断器拒绝、线程池拒绝等等不同请求,都需要上报Metrics

如果当前是半开状态,则关闭熔断器

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1219221.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【开源】基于Vue.js的社区买菜系统的设计和实现

项目编号: S 011 ,文末获取源码。 \color{red}{项目编号:S011,文末获取源码。} 项目编号:S011,文末获取源码。 目录 一、摘要1.1 项目介绍1.2 项目录屏 二、系统设计2.1 功能模块设计2.1.1 数据中心模块2.1…

11.13ASM图,FSM的一些verliog实现,串并转换

ASM图 除法器 FSM的verilog实现 状态机的状态就不用编码,而是用参数的定义进行转换 1. 在次态确定当中,只要w和y发生变化,就进行操作 在次态当中,只要时钟上升沿来临或者复位信号,就进行操作 2 Mealy型状态机 串…

CNN(卷积神经网络)、RNN(循环神经网络)、DNN(深度神经网络)的内部网络结构有什么区别?

【导师不教?我来教!】同济计算机博士半小时就教会了我五大深度神经网络,CNN/RNN/GAN/transformer/LSTM一次学会,简直不要太强!_哔哩哔哩_bilibili了解的五大神经网络,整理笔记如下: 视频是唐宇…

瑞萨RZ/G2L平台 初起动(SD卡启动)

文章目录 一 准备条件1 工具2 硬件3 镜像 二 烧录SD卡启动盘三 写Bootloader1 烧录文件2 启动烧录3 烧录 四 启动设置 一 准备条件 1 工具 ** BalenaEtcher(俗称“ Etcher”),是一款快速将系统镜像文件( .iso 或 .img 或 .zip或…

数据库实验报告(六)

实验报告(六) 1、实验目的 (1) 掌握关联查询的用法 (2) 掌握集合查询的区别和用法 (3) 掌握EXISTS的用法 2、实验预习与准备 (1) 了解ANY&…

精彩回顾|从架构到实践,AntDB融合型数据库揭秘

当今社会中的信息除了“多”,人们对于“效率”和“速度”的要求也越来越高。譬如,对于很多企业决策者来说,在当前的经济形势下需要尽一切可能降本增效。过去每周看看经营报表的习惯,现在慢慢转变为实时可视化分析企业当前的经营状…

「Verilog学习笔记」实现3-8译码器①

专栏前言 本专栏的内容主要是记录本人学习Verilog过程中的一些知识点,刷题网站用的是牛客网 分析 ① 本题要求根据38译码器的功能表实现该电路,同时要求采用基础逻辑门实现,那么就需要将功能表转换为逻辑表达式。 timescale 1ns/1nsmodule d…

ROS 学习应用篇(七)ROS中的坐标变换管理之tf广播与监听的编程实现

偶吼吼胜利在望,冲冲冲 老规矩新建功能包 工作空间目录下/src下开启终端输入 catkin_create_pkg learning_tf roscpp rospy tf turtlesim 如何实现tf广播 引入库 c python …

网络原理-IP/数据链路层协议

一. IP IP协议有两个版本,IPv4和IPv6.我们通常所用的IP协议,若没有特殊说明,默认都是IPv4. IPv4数量2^32,大约43亿左右,而TCP/IP协议规定,每个主机都需要有一个IP地址.对于全世界的计算机来说,这个数量是不够的,所以后来推出了IPv6(长度128位,是IPv4的4倍).但因为目前IPv4还广…

java集合,栈

只有栈是类 列表是个接口 栈是个类 队列 接口有双链表,优先队列(堆) add会报错 offer是一个满了不会报错 set集合 有两个类实现了这个接口

基于IDEA 进行Maven依赖管理

1. 依赖管理概念 Maven 依赖管理是 Maven 软件中最重要的功能之一。Maven 的依赖管理能够帮助开发人员自动解决软件包依赖问题,使得开发人员能够轻松地将其他开发人员开发的模块或第三方框架集成到自己的应用程序或模块中,避免出现版本冲突和依赖缺失等…

基于Java+Vue+uniapp微信小程序居住证申报系统设计和实现

博主介绍:✌全网粉丝30W,csdn特邀作者、博客专家、CSDN新星计划导师、Java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取源码联系🍅 👇🏻 精彩专…

分享一个自用的Win11护眼主题(无需下载)

先放上几张效果图 设置方法 首先,把主题设置为高对比度主题——沙漠。 然后点击编辑,依次设置为以下值 背景:#1C5E75文本:#FFF5E3超链接:#6EFFA4非活动文本:#FFF5E3选定文本:#903909、#8EE3F0…

Wordpress多语言插件:WPML插件使用教程,最佳的多语言建站方案

今天小编讲的是另外一款多语言插件WPML。相比Gtranslate采用的是机器翻译,难免存在翻译不准确,词不达意的情况,WPML可以支持人工翻译内容添加。 事先说明一点:用插件实现多语言较为方便,但此方法做出的多语言网站SEO性能一般,只建议展示站使用,如果想要SEO营销型多语言网…

【智能家居】5、主流程设计以及外设框架编写

一、主流程设计 #include <stdio.h>int main(){//指令工厂初始化//控制外设工厂初始化//线程池return 0; } 1、工厂模式结构体定义 &#xff08;1&#xff09;指令工厂 inputCmd.h struct InputCmd{char cmdName[128];//指令名称char cmd[32];//指令int (*Init)(char …

[Linux]NFS文件共享服务

一、NFS 1.1 NFS的简介 NFS&#xff08;Network File System 网络文件服务&#xff09;&#xff0c;是一种基于 TCP/IP 传输的网络文件系统协议&#xff0c;最初由 Sun 公司开发。 NFS 服务的实现依赖于 RPC&#xff08;Remote Process Call&#xff0c;远端过程调用&#x…

计算机网络八股文

计算机网络八股文 第一章 计算机网络基础 1.1 OSI 七层参考模型及各自功能 七层参考模式是一个抽象的模型体&#xff0c;不仅包括一系列抽象的术语或概念&#xff0c;也包括具体的协议。 &#xff08;物、数、网、传、会、表、应&#xff09; 物理层&#xff1a;主要定义物…

数字化转型具体包含哪些内容?

数字化转型是一个广泛且多方面的过程&#xff0c;涉及将数字技术集成到组织或企业的各个方面&#xff0c;从根本上改变其运营和交付价值的方式。它包含广泛的活动、战略和举措&#xff0c;这些活动、战略和举措可能会根据组织的具体目标和需求而有所不同。以下是数字化转型的一…

012.tr

1、用tr进行转换 tr是Unix命令行专家工具箱中的一件万能工具。它可用于编写优雅的单行命令。tr可以对来自标准输入的内容进行字符替换、字符删除以及重复字符压缩。tr是translate&#xff08;转换&#xff09;的简写&#xff0c;因为它可以将一组字符转换成另一组字符。 tr只…

IgH Master环境搭建

目标&#xff1a;实时linux内核中运行IgH主站&#xff0c;ethercat的用户态工具能看到主站信息。 一、需要的软件 1&#xff0c;vbox虚拟机 https://www.virtualbox.org/&#xff0c;下载VirtualBox 7.0, 备注&#xff1a;windows中不要用wsl开发&#xff0c;wsl运行unbuntu…