Spring Cloud :Hystrix实现优雅的服务容错

news2024/11/15 11:00:13

目录

  • Hystrix概述:
  • 第一个Hystrix程序
    • 步骤1:创建父工程hystrix-1
    • 步骤2:改造服务提供者
    • 步骤3:改造服务消费者为Hystrix客户端
      • (1)添加Hystrix依赖
      • (2)添加@EnableHystrix注解
      • (3)创建Config配置类
      • (4)新建service包
      • (5)新建controller包
    • 步骤4:项目测试
  • 在Feign中使用Hystrix
    • 步骤1:开启Hystrix熔断
    • 步骤2:开启Feign Client功能
    • 步骤4:项目测试
    • 问题
      • 1.Hystrix 是怎么实现服务容错的?
      • 2.什么是Hystrix ?
  • 总结

Hystrix概述:

在这里插入图片描述

作为Spring Cloud体系内实现熔断机制的关键组件,Hystrix承担着服务容错保护的重要职责。

它由Netflix开源,旨在为分布式系统提供延迟处理和容错解决方案。

其核心作用在于引入延迟容忍与容错逻辑,精细管理分布式服务间的交互,确保系统的高可用性和鲁棒性。

在复杂分布式系统环境中,往往涉及数十个应用,这些应用依赖于多个项目。

不可避免地,每个依赖项目都有可能在某个时刻遭遇失败并触发故障。

若未对这些故障实施有效隔离措施,整个分布式系统可能面临崩溃风险。


在分布式系统中,当某个环节出现延迟时,可能会阻塞整个用户请求。

特别是在高流量情况下,后端依赖的延迟可能迅速导致全部服务资源在短短几秒内耗尽,从而无法处理后续请求,使应用发生故障。

更严重的是,这些问题还可能引发服务间延迟累积,占用备份队列、线程等关键资源,触发连锁反应般的级联故障。

为应对这些挑战,Hystrix应运而生。

它通过封装每一个依赖项,实现它们之间的相互隔离。

一旦延迟发生,问题被限制在局部资源中,并包含回退逻辑,该逻辑决定在依赖失败时应采取何种措施,确保系统的稳定性。


第一个Hystrix程序

步骤1:创建父工程hystrix-1

将搭建的Eureka基本应用中的3个子项目都复制到hystrix-1父工程中,并依次添加为Maven项目。
在这里插入图片描述

步骤2:改造服务提供者

在服务提供者eureka-provider中创建controller包,并在该包下创建HystrixController类,该类定义了一个demo ()方法,用于处理路径为/demo的请求。

HystrixController类的内容如下:
在这里插入图片描述

步骤3:改造服务消费者为Hystrix客户端

流程:

(1)添加Hystrix依赖

(2)添加@EnableHystrix注解

(3)创建Config配置类

(4)创建Service层类

(5)创建Controller层类


(1)添加Hystrix依赖

在项目eureka-consumer的pom文件中添加Hystrix的依赖如下:

在这里插入图片描述

  <dependency>

      <groupId>org.springframework.cloud</groupId>

      <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>

  </dependency>

添加后重新加载pom文件。

(2)添加@EnableHystrix注解

在启动类EurekaConsumerApplication中添加@EnableHystrix注解启动熔断功能。
在这里插入图片描述

(3)创建Config配置类

在eureka-consumer中创建config包,并在该包下创建类HystrixConfig。在HystrixConfig类中注入restTemplate的Bean对象。
在这里插入图片描述

(4)新建service包

在service包下新建LocalItemService类
在这里插入图片描述

被@HystrixCommand注解修饰的demo()方法就启动了Hystrix熔断器的功能fallbackMethod属性定义的是处理回退(fallback)逻辑的方法。如果必须在fallback逻辑方法中远程调度其他服务,最好在远程调度其他服务时,也加上熔断器。

注:@Autowired注解不能运行时可换成@Resource注解,按Bean的名称装配。

(5)新建controller包

在controller包下新建LocalItemController类
在这里插入图片描述

步骤4:项目测试

启动服务并进行测试。依次启动eureka-server,eureka-provider,eureka-consumer,在浏览器输入http://localhost:7006/demo?name=布说,观察浏览器显示的效果。
在这里插入图片描述
在这里插入图片描述

关闭服务提供者eureka-provider,制造服务不可用的情形。再次请求 以上地址,观察浏览器显示的效果。
在这里插入图片描述


在Feign中使用Hystrix

创建父工程hystrix-2,将上述中的3个子项目都复制到hystrix-2父工程中,并依次添加为Maven项目。

步骤1:开启Hystrix熔断

Feign自带熔断功能,默认情况下,熔断功能是关闭的。如果要开启熔断,只需在配置文件中将hystrix.enabled设置为true即可。

开启Hystrix熔断功能。在eureka-consumer项目的配置文件application.yml中添加开启熔断的配置:
在这里插入图片描述

注:因为在Feign的起步依赖中引入了Hystrix依赖,所以在Feign中使用Hystrix不需要引入任何的依赖,只需要在配置文件中开启即可。

步骤2:开启Feign Client功能

因为使用Feign组件调用,需要在eureka-consumer项目的pom文件中加入feign依赖。

在项目eureka-consumer的pom文件中添加Feign的依赖如下:

<dependency>

      <groupId>org.springframework.cloud</groupId>

      <artifactId>spring-cloud-starter-openfeign</artifactId>

  </dependency>

添加后重新加载pom文件。

在eureka-consumer的启动类中添加@EnableFeignClients开启Feign Client功能。
![在这里插入图片描述](https://i-blog.csdnimg.cn/在这里插入图片描述

注:使用fallback属性指定的用于处理回退逻辑的类,必须实现@FeignClient注解修饰的接口。

步骤3:修改项目中接口

在service包中新建失败逻辑处理类LocalbushuoServiceImpl,并实现被@FeignClient修饰的LocalItemService接口。
在这里插入图片描述

进入项目eureka-consumer,删除掉之前的LocalItemService类。创建LocalItemService接口,并在上方的@FeignClient注解中,增加fallback属性配置,指定LocalItemServiceImpl类为失败逻辑处理类。

注:使用fallback属性指定的用于处理回退逻辑的类,必须实现@FeignClient注解修饰的接口。
在这里插入图片描述

步骤4:项目测试

启动服务并进行测试。依次启动eureka-server,eureka-provider,eureka-consumer,在浏览器输入http://localhost:7006/demo?name=www,观察浏览器显示的效果。
在这里插入图片描述

关闭服务提供者eureka-provider,制造服务不可用的情形。再次请求 以上地址,观察浏览器显示的效果。
在这里插入图片描述
在这里插入图片描述

问题

1.Hystrix 是怎么实现服务容错的?

Hystrix 主要通过以下几点实现服务容错:

断路器模式:当依赖服务频繁失败时,断路器会打开,直接拒绝请求,防止系统因等待响应而耗尽资源。当服务恢复后,断路器会进入半开状态,逐步恢复请求。(上述程序就是)

资源隔离:使用线程池或信号量隔离来限制依赖服务的请求,防止一个服务的问题影响到整个系统。
Fallback 机制:当依赖服务不可用时,提供一个备用响应(Fallback),确保请求不会完全失败,而是返回一个默认值或备用结果。

超时与重试:设置请求超时时间,超出时间直接返回错误;对于临时故障,可以配置重试机制。

2.什么是Hystrix ?

Hystrix 是一个由 Netflix 开发的开源库,用于提高分布式系统的服务弹性和可靠性。它通过增加延迟容忍和容错逻辑来防止级联故障。

主要功能包括:

  1. 断路器:监测依赖服务的故障,当检测到故障时,阻止请求发送到有问题的服务上,避免级联故障。

  2. 资源隔离:使用线程池隔离或信号量隔离来限制服务调用的资源消耗,防止系统不稳定。

  3. Fallback 回退机制:配置备用响应(Fallback),当依赖服务故障时返回备用结果,确保请求不会完全失败。

  4. 监控与仪表盘:提供实时监控数据,如延迟和错误率,并通过 Hystrix Dashboard 展示,帮助监控系统状态。

Hystrix 常与 Spring Cloud 集成,用于构建高可用和高弹性的微服务架构。尽管 Netflix 已停止维护 Hystrix,但它在许多现有项目中仍然广泛使用。

总结

在这里插入图片描述

每个微服务都需要独立部署,管理多个环境和配置,这无疑增加了部署的复杂性。

由于系统由众多微服务构成,一旦发生故障,定位问题的时间会相应增加,监控和故障排查的难度也随之增大。

此外,不同微服务对资源的需求各不相同,需要合理分配以避免资源浪费或不足。

激励自己:天行健,君子以自强不息。

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

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

相关文章

共享单车轨迹数据分析:以厦门市共享单车数据为例(六)

副标题&#xff1a;.基于POI数据的站点功能混合度探究——以厦门市为例 为了保证数据时间尺度上的一致性&#xff0c;我们从互联网上下载了2020年的POI数据&#xff0c;POI数据来源于高德地图 API平台,包括名称、大小类、地理坐标等。并将高德地图 POI数据的火星坐标 系 GCJ-0…

轻松搭建企业报修平台,零代码解决方案

在当今竞争激烈的商业环境中&#xff0c;企业的高效运营离不开稳定的设备和设施。而当设备出现故障时&#xff0c;一个高效的维修报修平台就显得至关重要。那么&#xff0c;如何零代码搭建企业内部维修报修平台呢&#xff1f; 一、明确需求与目标 在搭建维修报修平台之前&…

Apache APISIX学习(2):安装Grafana、prometheus

一、Grafana安装 1、介绍 Grafana 是一个监控仪表系统&#xff0c;它是由 Grafana Labs 公司开源的的一个系统监测 (System Monitoring) 工具。它可以大大帮助你简化监控的复杂度&#xff0c;你只需要提供你需要监控的数据&#xff0c;它就可以帮你生成各种可视化仪表。同时它…

day01——通过git进行管理项目

新建仓库 IDEA新建本地仓库&#xff0c;并上传本地代码将代码上传到远程仓库 不同版本的idea&#xff0c;方式不同&#xff0c;自行摸索

鸿蒙界面开发——组件(10):单选框Radio复选框checkbox 下拉框select 多条件筛选Filter

单选框Radio 单选框一直会有这个圆圈&#xff0c;在选中和未选中之间切换状态。 Radio通过调用接口来创建&#xff0c;接口调用形式如下&#xff1a; Radio(options: RadioOptions) Radio(options: {value: string, group: string ,indicatorType:RadioIndicatorType,(新增) …

基于SSM的家政服务网站【附源码】

基于SSM的家政服务网站&#xff08;源码L文说明文档&#xff09; 目录 4 系统设计 4.1 系统概述 4.2 系统结构 4.3. 数据库设计 4.3.1 数据库实体 4.3.2 数据库设计表 4.4 数据表 第5章 系统详细设计 5.1管理员功能模块 5.2用户功能模块 5.3前…

STM32F407单片机编程入门(二十四) USB口介绍及CDC类虚拟串口通讯详解及源码

文章目录 一.概要二.USB2.0基本介绍及虚拟串口介绍三.STM32F407VET6单片机USB模块框图四.STM32单片机USB从机模式五.STM32F407VET6 USB设备CDC类六.CubeMX配置一个USB虚拟串口收发例程七.CubeMX工程源代码下载八.小结 一.概要 STM32F407VET6 USB虚拟串口是一种采用STM32F407VE…

【测试】什么是需求?

测试的概念&#xff1a;验证软件的特性是否满足用户的需求。软件测试领域&#xff1a;软件测试工程师、软件测试开发工程师 需求的概念 在企业中&#xff0c;经常会听到俩个词&#xff1a;用户需求和软件需求。 例如&#xff1a;开发人员与产品人员出现冲突... 产品同学要求开…

ROG NUC:重塑未来,从“芯”开始

ROG NUC以令人惊叹的紧凑身形、强大配置&#xff0c;从“芯”出发&#xff0c;重塑我们对科技生活的想象&#xff0c;让玩家感受由微缩主机带来的性能风暴。 至强“芯”脏&#xff0c;性能巅峰 ROG NUC至高搭载英特尔酷睿Ultra9处理器&#xff0c;采用先进的制程工艺&#xff…

【C++】STL详解之string类

目录 什么是STL STL的版本 STL的六大组件 STL的缺陷 一.string的定义方式 二. string的插入 1.使用push_back进行尾插 2.使用insert插入 三.string的拼接 四.string的删除 1.使用pop_back进行尾删 2.使用erase进行删除 五.string的查找 1.使用find正向搜索第一个…

设计模式 策略模式(Strategy Pattern)

策略模式简绍 策略模式&#xff08;Strategy Pattern&#xff09;是一种行为设计模式&#xff0c;它使你能在运行时改变对象的行为。该模式定义了一系列的算法&#xff0c;并将每一个算法封装起来&#xff0c;使它们可以相互替换。策略模式让算法独立于使用它的客户而变化。 …

【计网】从零开始掌握序列化 --- 实现网络计算器项目

​​​请各位保持头脑清醒&#xff0c; ​​​读些好书&#xff0c;做点有用的事&#xff0c; ​​​快快乐乐地生活。 ​​​ --- 斯蒂芬金 《肖申克的救赎》--- 从零开始掌握序列化 1 知识回顾2 服务器框架3 客户端框架4 运行测试 1 知识回顾 前面两篇文章学习中基础知识…

CSS 实现文本溢出省略号显示,含单行与多行文本溢出

&#x1f680; 个人简介&#xff1a;某大型国企资深软件研发工程师&#xff0c;信息系统项目管理师、CSDN优质创作者、阿里云专家博主&#xff0c;华为云云享专家&#xff0c;分享前端后端相关技术与工作常见问题~ &#x1f49f; 作 者&#xff1a;码喽的自我修养&#x1f9…

[翟旭发射器]python-推导式-列表list表达式练习

# 简单的列表生成 numbers00[x for x in range(1,11)] print(numbers00) # 带条件的列表生成 numbers01[x for x in range(1,11) if x%20] print(numbers01) # 带表达式的列表生成 numbers10[x**2 for x in range(1,11)] print(numbers10) # 嵌套循环的列表生成 coordinates[(x…

UE4_Niagara基础实例—使用自定义参数

实现的功能&#xff1a;使用自定义的参数来调整粒子远离发射器后粒子大小的变化 效果图&#xff1a; 操作步骤&#xff1a; 1、创建Niagara系统&#xff0c;使用Simple Sprite Burst模板作为新系统的发射器&#xff0c;更名为NS_Custompara。 2、双击打开Niagara系统编辑界面…

Shopee 大促想爆单如何准备?EasyBoss ERP为你准备了一份攻略!

Shopee下半年第二个大促节点——10.10品牌大促即将来到&#xff0c;根据Shopee的官方的数据&#xff0c;9.9大促当天&#xff0c;Shopee Mall单量增至平日4倍。 老板们&#xff0c;准备好自己的热卖爆款冲击10.10大促了吗&#xff1f; 图源&#xff1a;Shopee 为助力大家迎战大…

NetApp EF 系列全闪存阵列 EF600 和 EF300

功能强大且经济实惠的性能 NetApp EF600 全闪存阵列专为需要最高性能的工作负载而设计。NetApp EF300阵列专为大数据分析和数据库等混合工作负载环境而设计。这些NVMe全闪存阵列的性能是以前SAS全闪存阵列的两倍。您可以使用专为高性能工作负载打造的端到端 NVMe 存储平台来加速…

node-rtsp-stream、jsmpeg.min.js实现rtsp视频在web端播放

1. 服务地址&#xff08;私有&#xff09;&#xff1a;https://gitee.com/nnlss/video-node-server 2.node-rtsp-stream 需要安装FFMPEG&#xff1b; 3.给推拉流做了开关&#xff0c;可借助http请求&#xff0c;有更好方式可联系&#xff1b; 4.存在问题&#xff1a; 1&…

Vue中集中常见的布局方式

布局叠加 完整代码最外层的Container设置为relative&#xff0c;内部的几个box设置为absolute <template><div class"container"><div class"box box1">Box 1</div><div class"box box2">Box 2</div><d…

导出Power bi中的Measure

工作中做交接文档时&#xff0c;有时需要导出Power BI中所有度量值&#xff0c;这时可以下载两个工具。 一 &#xff0c; 下载工具&#xff1a; 1 &#xff0c; DaxStudio&#xff1a; http://daxstudio.org/ 2&#xff0c; Vertipaq Analyzer&#xff1a; https://www.sqlbi.c…