springcloud五大神兽之Hystrix介绍

2023-11-08 12:30
文章标签 java 介绍 五大 spring springcloud hystrix 神兽

本文主要是介绍springcloud五大神兽之Hystrix介绍，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

① Hystrix是什么？
Hystrix，英文意思是豪猪，全身是刺，刺是一种保护机制。Hystrix也是Netflix公司的一款组件。
② Hystrix可以做什么？
实现服务熔断降级处理，保护微服务，防止雪崩效应发生。
③ 雪崩效应
当单个服务出现问题，调用这个服务的请求就出现线程阻塞，此时若有大量的请求涌入，容器的线程资源就会被消耗完毕导致服务瘫痪。
1.微服务中，一个请求可能需要多个微服务接口才能实现，会形成复杂的调用链路。
2.如果某服务出现异常，请求阻塞，用户得不到响应，容器中线程不会释放，于是越来越多用户请求堆积，越来越多线程阻塞。
3.单服务器支持线程和并发数有限，请求如果一直阻塞，会导致服务器资源耗尽，从而导致所有其他服务都不可用，从而形成雪崩效应；
比如下图场景：
在这里插入图片描述
对于同步调用，当库存服务不可用时，商品服务请求线程被阻塞，当有大批量请求调用库存服务时，最终可能导致整个商品服务资源耗尽，无法继续对外提供服务。服务与服务之间的依赖性，故障会传播，会对整个微服务系统造成不可估量的严重后果，这就是常说的服务故障的“雪崩效应”。

如果一个应用不能对来自依赖的故障进行隔离，那该应用本身就处在被拖垮的风险中。 因此，为了构建稳定、可靠的分布式系统，我们的服务应当具有自我保护能力，当依赖服务不可用时，当前服务启动自我保护功能，从而避免发生雪崩效应。
④ 熔断器状态
（1）全开状态Open 所有请求都会被降级
（2）半开状态HalfOpen
（3）关闭状态Closed（默认熔断器关闭），所有请求正常访问
⑤ 关系转换
（1）默认情况下，服务均正常运行，熔断器处于关闭状态；
（2）当某个服务出现故障时，其它服务发请求访问当前服务（已故障）失败，Hystrix框架会对请求情况进行计数操作，在一定的时间内，失败的请求百分比达到阈值（极限值）时（默认失败比例的阈值是50%，请求次数最低不少于20次），则自动触发熔断机制，熔断器状态转为全开状态；

（3）熔断器全开5s后，会进入半开状态（熔断器判断下次请求的返回状况，若成功，熔断器切回关闭状态，若失败，熔断器切回全开状态）；
2.6 Hystrix案例演示
0 局部熔断
目标：服务提供者的服务出现了故障，服务消费者快速失败给用户友好提示，体验服务降级。
① 导入坐标依赖

<!--熔断器-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

② 开启熔断注解
在服务消费者的启动类上加上开启熔断注解

@SpringBootApplication
@EnableDiscoveryClient
@EnableCircuitBreaker   //开启熔断
//@EnableFeignClients(basePackages = {"com.swk.feign"})
public class UserConsumerSpringBootApplication {
public static void main(String[] args) {    SpringApplication.run(UserConsumerSpringBootApplication.class,args);}@Bean@LoadBalanced   //开启ribbon负载均衡，默认是轮询public RestTemplate restTemplate(){return new RestTemplate();}
}

③ 服务降级处理
被调用服务中的方法发生故障时，则返回默认的数据给用户，此操作叫服务降级。其他方法可用，该方法不可用 ，只是降低权限。
在对应的服务消费者一方添加一个降级处理方法，直接让该方法处理用户的请求。

@RequestMapping("/consumer")
@RestController
public class UserController {@AutowiredRestTemplate restTemplate;@AutowiredDiscoveryClient discoveryClient;/*** 服务降级处理方法* 当某个方法发生异常或者执行超时的时候，则直接让该方法处理用户的请求* @param id* @return*/public User failBack(Integer id){User user = new User();user.setName("服务降级~~默认处理");return user;}@GetMapping(value = "/{id}")//@HystrixCommand(fallbackMethod = "failBack")    //局部服务降级public User queryById(@PathVariable("id") Integer id){/* String url = "http://localhost:8081/user/find/" + id ;return restTemplate.getForObject(url,User.class);*///基于DiscoveryClient对象来访问/*List<ServiceInstance> userProducer = discoveryClient.getInstances("user-producer");ServiceInstance serviceInstance = userProducer.get(0);String url = "http://" + serviceInstance.getHost()+":"+serviceInstance.getPort() + "/user/find/" + id;return restTemplate.getForObject(url,User.class);*///基于服务名称来访问String url = "http://user-producer/user/find/"+id;return restTemplate.getForObject(url,User.class);}
}

④ 指定服务降级调用
在有可能发生问题的方法上添加降级处理调用，添加@HystrixCommand注解并指定降级处理方法。

@RequestMapping("/consumer")
@RestController
public class UserController {@AutowiredRestTemplate restTemplate;@AutowiredDiscoveryClient discoveryClient;/*** 服务降级处理方法* 当某个方法发生异常或者执行超时的时候，则直接让该方法处理用户的请求* @param id* @return*/public User failBack(Integer id){User user = new User();user.setName("服务降级~~默认处理");return user;}@GetMapping(value = "/{id}")@HystrixCommand(fallbackMethod = "failBack")    //局部服务降级public User queryById(@PathVariable("id") Integer id){/* String url = "http://localhost:8081/user/find/" + id ;return restTemplate.getForObject(url,User.class);*///基于DiscoveryClient对象来访问/*List<ServiceInstance> userProducer = discoveryClient.getInstances("user-producer");ServiceInstance serviceInstance = userProducer.get(0);String url = "http://" + serviceInstance.getHost()+":"+serviceInstance.getPort() + "/user/find/" + id;return restTemplate.getForObject(url,User.class);*///基于服务名称来访问String url = "http://user-producer/user/find/"+id;return restTemplate.getForObject(url,User.class);}
}

⑤ 制造异常
服务提供者中被调用方法添加异常，用于演示调用服务降级方法，给出默认的返回值.

@RequestMapping("/user")
@RestController
public class UserController {@AutowiredUserService userService;@RequestMapping("/find/{id}")public User findByUserId(@PathVariable("id") Integer id){
//制造异常if (id==3){throw new RuntimeException("aaa");}//演示熔断超时，服务降级/*try {System.out.println("正在睡觉");Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}*/User user = userService.findByUserId(id);user.setName(user.getUsername()+"user_producer");return user;}
}

⑥ 测试
启动EurekaServer注册中心、服务提供者，服务消费者，请求http://localhost:18082/consumer/3，查看效果
在这里插入图片描述
⑦ 其它熔断策略配置解析

# 配置熔断策略：
hystrix:command:default:circuitBreaker:# 强制打开熔断器 默认false关闭的。测试配置是否生效#forceOpen: false# 触发熔断错误比例阈值，默认值50% 10个请求有5个被拒绝访问，则开启熔断#errorThresholdPercentage: 50# 熔断后休眠时长，默认值5秒 熔断器开启5s后，在关闭#sleepWindowInMilliseconds: 10000# 熔断触发最小请求次数，默认值是20 累计请求20次无响应，开启熔断#requestVolumeThreshold: 10execution:isolation:thread:# 熔断超时设置，默认为1秒 过了超时时间后，做服务降级，给用户的请求返回设置的默认值timeoutInMilliseconds: 2000

⑧ 超时时间设置
设置超时时间之后，在该时间段内，调用服务提供者的问题方法，不会触发熔断，过了这个时间（比如5s后），则开启熔断。
（1）修改服务提供者方法，休眠3秒钟

@RequestMapping("/user")
@RestController
public class UserController {@AutowiredUserService userService;@RequestMapping("/find/{id}")public User findByUserId(@PathVariable("id") Integer id){if (id==3){throw new RuntimeException("aaa");}//演示熔断超时，服务降级try {System.out.println("正在睡觉");Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}User user = userService.findByUserId(id);user.setName(user.getUsername()+"user_producer");return user;}
}

（2）修改服务消费者的application.yml文件，设置超时时间为5s，不会熔断

# 配置熔断策略：
hystrix:command:default:circuitBreaker:# 强制打开熔断器 默认false关闭的。测试配置是否生效#forceOpen: false# 触发熔断错误比例阈值，默认值50% 10个请求有5个被拒绝访问，则开启熔断#errorThresholdPercentage: 50# 熔断后休眠时长，默认值5秒 熔断器开启5s后，在关闭#sleepWindowInMilliseconds: 10000# 熔断触发最小请求次数，默认值是20 累计请求20次无响应，开启熔断#requestVolumeThreshold: 10execution:isolation:thread:# 熔断超时设置，默认为1秒 过了超时时间后，做服务降级，给用户的请求返回设置的默认值timeoutInMilliseconds: 5000

（3）发生请求访问
在这里插入图片描述
（4）修改服务提供者方法，休眠6秒钟，这时超时时间是5s，过了超时时间仍调用不到服务，此时触发熔断，服务降级
在这里插入图片描述
⑨ 熔断触发最小请求次数测试
设置最小请求次数为2，第一次正常发请求访问，获取不到数据，自动发送第二次请求，若仍获取不到数据，则触发熔断，服务降级。
在这里插入图片描述
在这里插入图片描述
1 全局熔断
两种编写方式：编写在类上，编写在方法上。在类的上边对类的所有方法都生效。在方法上，仅对当前方法有效。
① 方法上服务降级
@HystrixCommand(fallbackMethod=“failBack”)用来声明一个降级逻辑的fallback兜底方法
② 类上默认服务降级
（1）在服务消费者一方UserController中，添加一个全局熔断方法

/***** 全局的服务降级处理方法* @return*/
public User defaultFailBack(){User user = new User();user.setUsername("Default-服务降级,默认处理！");return  user;
}

（2）服务消费者一方，调用服务的问题方法上，去除@HystrixCommand注解，改为@HystrixCommand

@GetMapping(value = "/{id}")
//@HystrixCommand(fallbackMethod = "failBack")    //局部服务降级
@HystrixCommand                                 //全局服务降级
public User queryById(@PathVariable("id") Integer id){//基于服务名称来访问String url = "http://user-producer/user/find/"+id;return restTemplate.getForObject(url,User.class);
}

（3）在服务消费方的UserController类上添加
@DefaultProperties(defaultFallback = “defaultFailBack”)，然后启动访问
在这里插入图片描述
2 要知
① 什么是线程隔离？
是指Hystrix为每个依赖服务调用一个小的线程池，如果线程池用尽，调用立即被拒绝，默认不采用排队。
② 什么是服务降级？
（兜底方法）优先保证核心服务，而非核心服务不可用或弱可用。触发Hystrix服务降级的情况：线程池已满、请求超时。
在这里插入图片描述

这篇关于springcloud五大神兽之Hystrix介绍的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/369874。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
性能测试介绍

性能测试介绍

性能测试是一种测试方法，旨在评估系统、应用程序或组件在现实场景中的性能表现和可靠性。它通常用于衡量系统在不同负载条件下的响应时间、吞吐量、资源利用率、稳定性和可扩展性等关键指标。 为什么要进行性能测试 通过性能测试，可以确定系统是否能够满足预期的性能要求，找出性能瓶颈和潜在的问题，并进行优化和调整。 发现性能瓶颈：性能测试可以帮助发现系统的性能瓶颈，即系统在高负载或高并发情况下可能出现的问题
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...
Hadoop数据压缩使用介绍

Hadoop数据压缩使用介绍

一、压缩原则 （1）运算密集型的Job，少用压缩 （2）IO密集型的Job，多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1）为了支持多种压缩/解压缩算法，Hadoop引入了编码/解码器 2）要在Hadoop中启用压缩，可以配置如下参数
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2