spring cloud学习之六: Hystrix(熔断器)

2024-01-11 04:32

本文主要是介绍spring cloud学习之六: Hystrix(熔断器),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在微服务架构中,我们通常会将一个大系统拆分成多个小服务,各个服务之间通过服务注册与订阅的方式进行依赖,依赖通过远程调用(RPC)的方式执行。通过这种方式,可能就会因为网络或者服务本身的问题而导致调用延迟或故障,就会造成调用者的服务延迟,当持续中断、无法提供服务,就会造成整个系统的崩溃,因此引出Hystrix–服务容错保护机制。
Spring Cloud Hystrix 实现了断路器、线程隔离等一系列服务保护功能,是基于Netflix Hystrix实现的。 Hystrix具备服务降级服务熔断线程和信号隔离、请求缓存、请求合并以及服务监控等功能。
在该篇文章中只介绍springcloud 如何集成Hystrix及使用方法,实现服务降级。之后在不断的学习中进行补充。
创建两个spring boot 基础工程,集成Eureka-client、config-client、ribbon等依赖,如有不懂,请看之前的文章、或者留言。
添加Hystrix依赖
pom.xml

<!--熔断器--><!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-hystrix --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-hystrix</artifactId><version>1.3.5.RELEASE</version></dependency>

启动类添加注解,开启Hystrix功能支持

@EnableHystrix //包含了 @EnableCircuitBreaker 注解
或
@EnableCircuitBreaker

bootstrap.properties 配置

#服务端口号
server.port=8181
#服务访问路径
server.context-path=/clientone
#应用名称,用于服务注册及访问
spring.application.name=clientone#配置注册eureka地址
eureka.client.service-url.defaultZone=http://192.168.2.83:7081/eureka/
#配置-配置文件
开启通过服务访问config
spring.cloud.config.discovery.enabled=true
#config服务名
spring.cloud.config.discovery.service-id=config-server
#仓库中通过profile定位配置文件
spring.cloud.config.profile=dev
#配置仓库文件分支
spring.cloud.config.label=dev##开启配置文件的快速失败与重试
spring.cloud.config.fail-fast=true
##配置重试参数,一下配置的是默认值
#最大重试次数
spring.cloud.config.retry.max-attempts=6
#重试间隔,毫秒
spring.cloud.config.retry.initial-interval=1000
#重试乘数,下次重试的间隔 1.1*当前重试时间
spring.cloud.config.retry.multiplier=1.1
#最大重试时间,毫秒
spring.cloud.config.retry.max-interval=2000##ribbon重试
#开启服务重试机制
spring.cloud.loadbalancer.retry.enabled=true
#请求连接超时时间,默认250
ribbon.ConnectTimeout=2000
#请求处理的超时时间,默认1000
ribbon.ReadTimeout=6000
#对虽有请求都进行重试,默认 true
ribbon.OkToRetryOnAllOperations=true
#切换实例的重试次数,默认 2
ribbon.MaxAutoRetriesNextServer=2
#对当前实例的重试次数,默认 1
ribbon.MaxAutoRetries=1#断路器超时时间,默认为2000,该时间要大于ribbon的时间,否则会触发重试机制
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=6000#开启热启动
spring.devtools.restart.enabled=true

第一个服务创建一个访问接口

@RestController
@RequestMapping("/ribbon")
public class TestRibbon {@Autowiredprivate DiscoveryClient discoveryClient;/*** @author:XingWL* @description:测试接口* @date: 2019/2/22 10:29*/@ResponseBody@RequestMapping(value = "/testRibbonProducer",method = RequestMethod.GET)public String testRibbon(){ServiceInstance instance=discoveryClient.getLocalServiceInstance();String hostMsg="";try {long time= new Random().nextInt(3000);System.out.println("=====休眠时长:"+time+"=====");Thread.sleep(time);hostMsg= "Producer: host-"+instance.getHost()+",service_id-"+instance.getServiceId()+",Url-"+instance.getUri();} catch (Exception e) {e.printStackTrace();hostMsg="异常";}return hostMsg;}
}

第二个服务创建一个接口

@RestController
@RequestMapping("/ribbon")
public class TestRibbon {@Autowiredprivate DiscoveryClient discoveryClient;@Autowiredprivate ServiceHystrix serviceHystrix;/*** @author:XingWL* @description:测试接口* @date: 2019/2/22 10:29*/@ResponseBody@RequestMapping(value = "/testRibbonProducer",method = RequestMethod.GET)public String testRibbon(){ServiceInstance instance=discoveryClient.getLocalServiceInstance();String hostMsg="";try {hostMsg= "Producer: host-"+instance.getHost()+",service_id-"+instance.getServiceId()+",Url-"+instance.getUri();} catch (Exception e) {e.printStackTrace();hostMsg="异常";}return hostMsg;}/*** @author:XingWL* @description:测试接口* @date: 2019/2/22 10:29*/@ResponseBody@RequestMapping(value = "/testHystrix",method = RequestMethod.GET)public String testHystrix(){return serviceHystrix.testHystrix();}}

第二个服务添加一个服务类

@Service
public class ServiceHystrix {@Autowiredprivate RestTemplate restTemplate;@HystrixCommand(fallbackMethod = "fallbackTest")public String testHystrix(){return restTemplate.getForEntity("http://CLIENTONE/clientone/ribbon/testRibbonProducer",String.class).getBody();}public String fallbackTest(){return "Hystrix -- fallback";}}

使用注解 @HystrixCommand(fallbackMethod = “fallbackTest”)
其中,fallbackMethod的值为同一个类下的方法,Hystrix默认超时时间为 2000ms
通过第二个服务去调用第一个服务的接口结果如图:
在这里插入图片描述
在这里插入图片描述
当被调用的服务发生故障或者延迟超时时,会通过 @HystrixCommand(fallbackMethod = “fallbackTest”)进行服务降级,返回处理结果。

断路器

isOpen()是用来判断断路器 关闭/打开的状态,
一个滚动时间窗内(10s),请求总数(QPS–默认-20)在请求数的范围内就为
fasle
,错误百分比的阀值默认为50%。
allowRequest()–判断请求是否被允许
当断路器处于打开状态时,会判断断开的时间戳+配置中的 circuitBreakerSleepWindowInMilliseconds时间是否小于当前时间(默认5s),是的话,就将当前时间更新到记录断路器打开的时间对象circuitOpenedOrLastTestedTime中,并且允许此次请求,在休眠时间到达之后,将再次允许请求尝试,此时断路器处于半开状态,若此时请求继续失败,断路器将再次打开。所以**allowRequest()isOpen()**配合实现断路器的打开、关闭状态的切换。
**依赖隔离’**之 舱壁模式
Hystrix使用该模式实现线程池隔离(为每个依赖服务提供一个独立的线程池,默认大小为10)。

持续更新中。。。。。

这篇关于spring cloud学习之六: Hystrix(熔断器)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


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

相关文章

Java如何用乘号来重复字符串的功能

《Java如何用乘号来重复字符串的功能》:本文主要介绍Java使用乘号来重复字符串的功能,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java乘号来重复字符串的功能1、利用循环2、使用StringBuilder3、采用 Java 11 引入的String.rep

SpringBoot中HTTP连接池的配置与优化

《SpringBoot中HTTP连接池的配置与优化》这篇文章主要为大家详细介绍了SpringBoot中HTTP连接池的配置与优化的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录一、HTTP连接池的核心价值二、Spring Boot集成方案方案1:Apache HttpCl

Spring Boot项目打包和运行的操作方法

《SpringBoot项目打包和运行的操作方法》SpringBoot应用内嵌了Web服务器,所以基于SpringBoot开发的web应用也可以独立运行,无须部署到其他Web服务器中,下面以打包dem... 目录一、打包为JAR包并运行1.打包为可执行的 JAR 包2.运行 JAR 包二、打包为WAR包并运行

Java进行日期解析与格式化的实现代码

《Java进行日期解析与格式化的实现代码》使用Java搭配ApacheCommonsLang3和Natty库,可以实现灵活高效的日期解析与格式化,本文将通过相关示例为大家讲讲具体的实践操作,需要的可以... 目录一、背景二、依赖介绍1. Apache Commons Lang32. Natty三、核心实现代

Spring Boot 常用注解整理(最全收藏版)

《SpringBoot常用注解整理(最全收藏版)》本文系统整理了常用的Spring/SpringBoot注解,按照功能分类进行介绍,每个注解都会涵盖其含义、提供来源、应用场景以及代码示例,帮助开发... 目录Spring & Spring Boot 常用注解整理一、Spring Boot 核心注解二、Spr

SpringBoot实现接口数据加解密的三种实战方案

《SpringBoot实现接口数据加解密的三种实战方案》在金融支付、用户隐私信息传输等场景中,接口数据若以明文传输,极易被中间人攻击窃取,SpringBoot提供了多种优雅的加解密实现方案,本文将从原... 目录一、为什么需要接口数据加解密?二、核心加解密算法选择1. 对称加密(AES)2. 非对称加密(R

详解如何在SpringBoot控制器中处理用户数据

《详解如何在SpringBoot控制器中处理用户数据》在SpringBoot应用开发中,控制器(Controller)扮演着至关重要的角色,它负责接收用户请求、处理数据并返回响应,本文将深入浅出地讲解... 目录一、获取请求参数1.1 获取查询参数1.2 获取路径参数二、处理表单提交2.1 处理表单数据三、

java变量内存中存储的使用方式

《java变量内存中存储的使用方式》:本文主要介绍java变量内存中存储的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、介绍2、变量的定义3、 变量的类型4、 变量的作用域5、 内存中的存储方式总结1、介绍在 Java 中,变量是用于存储程序中数据

如何合理管控Java语言的异常

《如何合理管控Java语言的异常》:本文主要介绍如何合理管控Java语言的异常问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、介绍2、Thorwable类3、Error4、Exception类4.1、检查异常4.2、运行时异常5、处理方式5.1. 捕获异常

Spring Boot集成SLF4j从基础到高级实践(最新推荐)

《SpringBoot集成SLF4j从基础到高级实践(最新推荐)》SLF4j(SimpleLoggingFacadeforJava)是一个日志门面(Facade),不是具体的日志实现,这篇文章主要介... 目录一、日志框架概述与SLF4j简介1.1 为什么需要日志框架1.2 主流日志框架对比1.3 SLF4