feign直接走熔断_SpringCloud微服务面试必问:Hystrix 服务降级、熔断
本文作者:JLSong
本文链接:https://www.cnblogs.com/songjilong/p/12770999.html
1、Hystrix是什么?
Hystrix 是一个用于处理分布式系统的延迟和容错的开源库,在分布式系统里,许多依赖不可避免的会调用失败,比如超时、异常等,Hystrix 能够保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联故障,以提高分布式系统的弹性。
「断路器」本身是一种开关装置,当某个服务单元发生故障之后,通过断路器的故障监控(类似熔断保险丝),向调用方返回一个符合预期的、可处理的备选响应(FallBack),而不是长时间的等待或者抛出调用方无法处理的异常,这样就保证了服务调用方的线程不会被长时间、不必要地占用,从而避免了故障在分布式系统中的蔓延,乃至雪崩。
2、Hystrix 的几个概念
2.1服务降级
不让客户端等待,并立即返回一个友好的提示(服务器忙,请稍后再试)
哪些情况会发生服务降级:
- 程序运行异常
- 超时
- 服务熔断引起服务降级
- 线程池/信号量打满也会导致服务降级
2.2服务熔断
类似保险丝,电流过大时,直接熔断断电。
熔断机制是应对雪崩效应的一种微服务链路保护机制,当扇出链路的某个微服务出错不可用或者响应时间太长时,会进行服务的降级,进而熔断该节点微服务的调用,快速返回错误的响应信息,当检测到该节点微服务调用响应正常后,恢复调用链路。
服务降级 → 服务熔断 → 恢复调用链路
2.3服务限流
对于高并发的操作,限制单次访问数量
3、服务降级的用法与分析
超时导致服务器变慢:超时不再等待; 出错(宕机或程序运行出错):要有备选方案
- 服务提供者超时了,调用者不能一直卡死等待,必须要服务降级
- 服务提供者宕机了,调用者不能一直卡死等待,必须要服务降级
- 服务提供者没问题,调用者自己出现故障或者有自我要求(自己的等待时间必须小于服务提供者)
3.1给服务提供方设置服务降级
1、在需要服务降级的方法上标注注解,fallbackMethod 代表回退方法,需要自己定义,@HystrixProperty 中设置的是该方法的超时时间,如果超过该事件则自动降级
当运行超时或服务内部出错都会调用回退方法
@HystrixCommand( fallbackMethod = "timeoutHandler", commandProperties = { @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")})public String timeout(Long id) { int time = 3000; try { TimeUnit.MILLISECONDS.sleep(time); } catch (InterruptedException e) { e.printStackTrace(); } //模拟异常 //int i = 10 / 0; return "线程:" + Thread.currentThread().getName();}
2、在启动类上添加注解,开启降级
@EnableCircuitBreaker
3.2给服务消费方设置服务降级
①.添加配置
# 在feign中开启hystrixfeign: hystrix: enabled: true
②.和服务提供方一样,照葫芦画瓢
@HystrixCommand( fallbackMethod = "timeoutHandler", commandProperties = { @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1500")})public String timeout(@PathVariable("id") Long id) { int i = 1/0; return hystrixService.timeout(id);}
③.在启动类上添加注解
@EnableHystrix
3.3问题
以上配置方式存在的问题:
- 每个业务方法对应一个回退方法,代码膨胀
- 每个业务方法上都配置相同的处理,代码冗余
解决方式1:在类上配置一个全局回退方法,相当于是一个通用处理,当此回退方法能满足你的需求,就无需在方法上指定其它回退方法,如果需要使用特定的处理方法可以再在业务方法上定义
@DefaultProperties(defaultFallback = "globalFallbackMethod")
解决方式2:但此时处理代码和依然和业务代码混合在一起,我们还可以使用另一种方式:编写一个类实现 Feign 的调用接口,并重写其方法作为回退方法,然后在 @FeignClient 注解上添加 fallback 属性,值为前面的类。
4、服务熔断的用法与分析
在SpringCloud中,熔断机制通过 Hystrix 实现。Hystrix 监控微服务间的调用状况,当失败的调用到一定阈值,默认 5 秒内 20 次调用失败就会启动熔断机制。熔断机制的注解是 @HystrixCommand
@HystrixCommand( fallbackMethod = "paymentCircuitBreakerFallback", commandProperties = { @HystrixProperty(name = "circuitBreaker.enabled", value = "true"), //是否开启断路器 @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"), //请求次数 @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"), //时间窗口期 @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60") //失败率达到多少后跳闸})public String circuitBreaker(Long id) { if (id < 0) { throw new RuntimeException("id 不能为负数"); } return Thread.currentThread().getName() + "" + "调用成功,流水号:" + IdUtil.simpleUUID();}public String circuitBreakerFallback(Long id) { return "id 不能为负数,你的id = " + id;}
@HystrixProperty 中的配置可以参考 com.netflix.hystrix.HystrixCommandProperties 类
详见官方文档:https://github.com/Netflix/Hystrix/wiki/Configuration
也有雷锋同志做了翻译:https://www.jianshu.com/p/39763a0bd9b8
熔断类型
- 熔断打开:请求不再调用当前服务,内部设置时钟一般为MTTR(平均故障处理时间),当打开时长达到所设时钟则进入半熔断状态。
- 熔断半开:部分请求根据规则调用服务,如果请求成功且符合规则,则关闭熔断。
- 熔断关闭:不会对服务进行熔断。
断路器什么时候起作用?
根据上面配置的参数,有三个重要的影响断路器的参数
- 快照时间窗:回路被打开、拒绝请求到再尝试请求并决定回路是否继续打开的时间范围,默认是 5 秒
- 请求总数阈值:在一个滚动窗口中,打开断路器需要的最少请求数,默认是 20 次(就算前 19 次都失败了,断路器也不会被打开)
- 错误百分比阈值:错误请求数在总请求数所占的比例,达到设定值才会触发,默认是 50%
断路器开启或关闭的条件
- 当请求达到一定阈值时(默认 20 次)
- 当错误率达到一定阈值时(默认 50%)
- 达到以上条件断路器开启
- 当开启的时候,所有请求都不会转发
- 当断路器开启一段时间后(默认 5 秒)进入半开状态,并让其中一个请求进行转发,如果成功断路器关闭,如果失败继续开启,重复第 4 和 5 步
断路器开启之后会发生什么?
- 再有请求调用时,不再调用主逻辑,而是调用降级 fallback。
- 断路器开启之后,Hytrix 会启动一个休眠时间窗,在此时间内,fallback 会临时称为主逻辑,当休眠期到了之后,断路器进入半开状态,释放一个请求到原来的主逻辑上,如果请求成功返回,则断路器关闭,如果请求失败,则继续进入打开状态,休眠时间窗重新计时。
5、Hystrix服务熔断的工作流程
详见官方文档:https://github.com/Netflix/Hystrix/wiki/How-it-Works
6、Hystrix DashBoard 上手
6.1搭建
①.新建一个项目,导入 maven 依赖
org.springframework.cloud spring-cloud-netflix-hystrix-dashboardorg.springframework.boot spring-boot-starter-actuator
②.添加配置
server: port: 9001
③.开启 Hystrix DashBoard
@SpringBootApplication@EnableHystrixDashboardpublic class ConsumerHystrixDashBoard9001 { public static void main(String[] args){ SpringApplication.run(ConsumerHystrixDashBoard9001.class, args); }}
④.浏览器输入 http://localhost:9001/hystrix,出现以下界面即启动成功
7、使用
注意:想要被 Hystrix DashBoard 监控的服务必须导入此依赖
org.springframework.boot spring-boot-starter-actuator
在被监控服务的主启动类里添加如下代码,否则某些旧版本可能报错 Unable to connect to Command Metric Stream.
/** * 此配置是为了服务监控而配置,与服务容错本身无关,SpringCloud升级后的坑 * ServletRegistrationBean因为springboot的默认路径不是"/hystrix.stream", * 只要在自己的项目里配置上下面的servlet就可以了 */@Beanpublic ServletRegistrationBean getServlet(){ HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet(); ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet); registrationBean.setLoadOnStartup(1); registrationBean.addUrlMappings("/hystrix.stream"); registrationBean.setName("HystrixMetricsStreamServlet"); return registrationBean;}
在 Hystrix DashBoard 页面输入基本信息,进入仪表盘界面
大致情况如下所示
操作界面分析:
代码地址:https://github.com/songjilong/springcloud-hoxton-learning
feign直接走熔断_SpringCloud微服务面试必问:Hystrix 服务降级、熔断相关推荐
- 微服务面试必问的Dubbo,这么详细还怕自己找不到工作?
Dubbo 起源于阿里巴巴,对于我们做电商开发的人来说,基本是首选的技术,那么为何一个区区 soa 服务治理框架,会受到这么多人的青睐呢? 今天就跟着小羽一起看看这个微服务框架之一的 Dubbo 的详 ...
- Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)【Dalston版】
前言 在微服务架构中,我们将系统拆分成了一个个的服务单元,各单元应用间通过服务注册与订阅的方式互相依赖.由于每个单元都在不同的进程中运行,依赖通过远程调用的方式执行,这样就有可能因为网络原因或是依赖服 ...
- Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)【Dalston版】 1
前言 在微服务架构中,我们将系统拆分成了一个个的服务单元,各单元应用间通过服务注册与订阅的方式互相依赖.由于每个单元都在不同的进程中运行,依赖通过远程调用的方式执行,这样就有可能因为网络原因或是依赖服 ...
- Java面试必问!javasocket服务端持久化
前言 最近刷到了一句耐人寻味的话,"解决雪崩问题的最好办法是不发生雪崩". 不论是在硅谷互联网公司里还是在国内的互联网平台上,曾多次遇到过海量规模的交易瞬间吞噬平台的悲惨故事. 核 ...
- 看完946页“JAVA高级架构面试必问”,金九银十社招全拿下
前言 我本科毕业后在老东家干了两年多,老东家算是一家"小公司"(毕竟这年头没有 BAT 或 TMD 的 title 都不好意思报出身),毕业这两年多我也没有在大厂待过,因此找坑的时 ...
- 互联网公司面试必问的mysql题目(下)
这是mysql系列的下篇,上篇文章地址我附在文末. 什么是数据库索引?索引有哪几种类型?什么是最左前缀原则?索引算法有哪些?有什么区别? 索引是对数据库表中一列或多列的值进行排序的一种结构.一个非常恰 ...
- linux驱动工程面试必问知识点
linux内核原理面试必问(由易到难) 简单型 1:linux中内核空间及用户空间的区别?用户空间与内核通信方式有哪些? 2:linux中内存划分及如何使用?虚拟地址及物理地址的概念及彼此之间的转化, ...
- 面试必问:JVM类加载机制详细解析
前言 在Java面试中,简历上有写JVM(Java虚拟机)相关的东西,JVM的类加载机制基本是面试必问的知识点. 类的加载和卸载 JVM是虚拟机的一种,它的指令集语言是字节码,字节码构成的文件是cla ...
- 互联网公司面试必问的Redis题目
https://juejin.im/post/5b99d4bce51d450e7a24b66e#heading-0 Redis是一个非常火的非关系型数据库,火到什么程度呢?只要是一个互联网公司都会使用 ...
最新文章
- oracle spatial(一)开端
- NTU 课程笔记:self-supervised learning
- js日期格式化精髓总结
- echarts中树图的label的点击_ECharts 堆积木(砖块)游戏
- c++循环执行一个函数_20川大计算机 | 时间复杂度,你避不开的一个考点
- 华科计算机课程设计,华中科大操作系统课程设计报告(附源码).doc
- thinking-in-java(10)内部类
- 生活窍门 这样用钱就会富足
- linux树莓派扩容,树莓派ubuntu 扩容
- Android ContentProvider的介绍(很详细)
- h5如何动态获取键盘高度_H5 键盘兼容性小结
- android:AIDL
- python判断字符串相等_“python”中怎么判断字符串相等?
- laravel 数据库操作之查询构造器
- C++ 编写一个解释器
- 微信支付(java版本)
- leetcode刷题目录总结
- 南卡和三星哪款蓝牙耳机音质好些?高颜值且音质好的蓝牙耳机测评
- 服务器硬盘故障问题有哪些
- MHT: Basic Methods for Data Association(二)Track Score Function
热门文章
- c 包含其他文件_C语言:全局变量在多个c文件中公用的方法!
- matlab 矩阵位移法编程 结构力学,matlab 矩阵位移法编程 结构力学
- php response响应,9. 响应 (Response)
- ❤️震惊!人生苦短,我用python来玩田忌赛马❤️
- centOS下lnamp安装
- python操作excel常用的方法
- Angular过滤器
- HTML5笔记1——HTML5的发展史及标签的改变
- 传感器系列之4.3流量传感器
- Swift - 发送消息(文本,图片,文件等)给微信好友或分享到朋友圈