【熔断限流组件resilience4j和hystrix】

2024-01-01 11:44
文章标签 组件 限流 hystrix 熔断 resilience4j

本文主要是介绍【熔断限流组件resilience4j和hystrix】，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • 🔊博主介绍
  • 🥤本文内容
    • 起因
    • resilience4j落地实现
      • pom.xml依赖
      • application.yml配置
      • 接口使用
    • hystrix 落地实现
      • pom.xml依赖
      • 启动类上添加注解
      • 接口上使用
  • 📢文章总结
  • 📥博主目标

🔊博主介绍

🌟我是廖志伟，一名Java开发工程师、Java领域优质创作者、CSDN博客专家、51CTO专家博主、阿里云专家博主、清华大学出版社签约作者、产品软文专业写手、技术文章评审老师、问卷调查设计师、个人社区创始人、开源项目贡献者。🌎跑过十五公里、🚀徒步爬过衡山、🔥有过三个月减肥20斤的经历、是个喜欢躺平的狠人。

📕拥有多年一线研发和团队管理经验，研究过主流框架的底层源码(Spring、SpringBoot、Spring MVC、SpringCould、Mybatis、Dubbo、Zookeeper)，消息中间件底层架构原理(RabbitMQ、RockerMQ、Kafka)、Redis缓存、MySQL关系型数据库、 ElasticSearch全文搜索、MongoDB非关系型数据库、Apache ShardingSphere分库分表读写分离、设计模式、领域驱动DDD、Kubernetes容器编排等。

📙有过从0到1的项目高并发项目开发与管理经验，对JVM调优、MySQL调优、Redis调优 、ElasticSearch调优、消息中间件调优、系统架构调优都有着比较全面的实战经验。

📘有过云端搭建服务器环境，自动化部署CI/CD，弹性伸缩扩容服务器（最高200台），了解过秒级部署（阿里云的ACK和华为云的云容器引擎CCE）流程，能独立开发和部署整个后端服务，有过分库分表的实战经验。

🎥经过多年在CSDN创作上千篇文章的经验积累，我已经拥有了不错的写作技巧，与清华大学出版社签下了四本书籍的合约，并将陆续在明年出版。这些书籍包括了基础篇、进阶篇、架构篇的📌《Java项目实战—深入理解大型互联网企业通用技术》📌，以及📚《解密程序员的思维密码–沟通、演讲、思考的实践》📚。具体出版计划会根据实际情况进行调整，希望各位读者朋友能够多多支持！

文章目录

  • 🔊博主介绍
  • 🥤本文内容
    • 起因
    • resilience4j落地实现
      • pom.xml依赖
      • application.yml配置
      • 接口使用
    • hystrix 落地实现
      • pom.xml依赖
      • 启动类上添加注解
      • 接口上使用
  • 📢文章总结
  • 📥博主目标

🌾阅读前，快速浏览目录和章节概览可帮助了解文章结构、内容和作者的重点。了解自己希望从中获得什么样的知识或经验是非常重要的。建议在阅读时做笔记、思考问题、自我提问，以加深理解和吸收知识。

💡在这个美好的时刻，本人不再啰嗦废话，现在毫不拖延地进入文章所要讨论的主题。接下来，我将为大家呈现正文内容。

🥤本文内容

CSDN

起因

阿里Sentinel团队不稳定，超过了一半年的时间没有更新了，虽然认为一个成熟产品没必要老更新，在特定的阶段能完成他的历史使命就好，并且sentinel开源这块依旧还在维护开发中。但是它是为了kpi开放出来的，生怕哪天不维护了，总感觉阿里是在培养用户习惯之后，让你绑定阿里的生态，再到阿里云割韭菜，开源嘛，本来也是无偿用，人家没有义务像商业软件那样永久更新，之前开源社区好几个作者就是因为不更新或者更新慢被别人喷不搞了，所以个人觉得有必要多掌握几个限流熔断组件。

resilience4j落地实现

pom.xml依赖

如果你的springboot版本是2的使用以下依赖：

<!-- 熔断限流resilience4j-->
<dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot2</artifactId><version>2.2.0</version>
</dependency>

如果你的springboot版本是3的使用以下依赖：

<!-- 熔断限流resilience4j-->
<dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot3</artifactId><version>2.2.0</version>
</dependency>

application.yml配置

resilience4j:retry: # 重试策略机制配置instances: # 定义多个重试策略实例retryApi: # 第一个重试策略重试名称max-attempts: 3 # 操作失败最大重试次数为3wait-duration: 1s # 每次重试等待时间1秒circuitbreaker:instances: # 定义多个断路器实例circuitBreakerApi: # 第一个断路器实例名称registerHealthIndicator: true # 配置健康指示器slidingWindowSize: 10 # 滑动窗口大小minimumNumberOfCalls: 5 # 最小调用次数permittedNumberOfCallsInHalfOpenState: 3 # 半开状态下允许的调用次数slidingWindowType: TIME_BASED # 滑动窗口类型automaticTransitionFromOpenToHalfOpenEnabled: true # 是否自动从开启状态转换为半开状态waitDurationInOpenState: 1s # 开启状态下等待时间failureRateThreshold: 20 # 失败率阈值，失败率20%时，断路器打开eventConsumerBufferSize: 10 # 事件消费者缓冲区大小ignoreExceptions: # 忽略的异常列表- java.io.IOExceptionratelimiter:instances: # 定义多个限流策略实例rateLimiterApi: # 第一个限流策略实例名称limitForPeriod: 10000 # 限制周期内的请求数量10000limitRefreshPeriod: 10s # 限制刷新周期，10秒一个周期timeoutDuration: 500ms # 超时时间为0.5秒，请求超过限制客户端立即收到超时响应，不等待subscribeForEvents: AFTER_SUCCESS # 订阅事件类型eventConsumerBufferSize: 10 # 事件消费者缓冲区大小

接口使用

@Retry(name = "retryApi",fallbackMethod = "fallbackRedPackage")
@CircuitBreaker(name = "circuitBreakerApi",fallbackMethod = "fallbackRedPackage")
@RateLimiter(name = "rateLimiterApi",fallbackMethod = "fallbackRedPackage")
@PostMapping(value = "/redPackage")
public Result redPackage(@RequestBody RedPackegeRainVo redPackage) {//红包唯一标识\红包的keyString redPackageKey = redPackage.getRedPackageKey();//用户id\用户tokenString userId = redPackage.getUserId();//使用StringBuilder拼接字符串，作为红包的键（key）String redAppend = StringUtil.StringAppend(RedPackageRainConstant.RED_PACKAGE_KEY, redPackageKey);//从redis缓存中获取红包池中的红包String partRedPackage = redisUtil.leftPop(redAppend);//判断是否为空，不为空进入后续流程；为空直接返回if (StringUtils.isNotEmpty(partRedPackage)) {//将红包的key和用户的id作为存储redis缓存已抢红包池的键（key）String redConsumeAppend = StringUtil.StringAppend(RedPackageRainConstant.RED_PACKAGE_CONSUME_KEY, redPackageKey,":", RedPackageRainConstant.RED_PACKAGE_USER_ID, userId);//存入redis缓存并且设置过期时间（使用了redis事务，保证原子性，因为操作简单、依赖关系简单，使用使用redis事务比使用 Lua 脚本更适合当前场景）redisUtil.multiStr(redConsumeAppend,partRedPackage,1,TimeUnit.DAYS);//自适应（根据当前机器的线程数适配核心线程数和最大线程数）全局线程池ThreadPoolExecutor.getThreadPoolExecutor().execute(new Runnable() {@Overridepublic void run() {ConcurrentHashMap concurrentHashMap =  pool.acquire(); // 从对象池中获取一个ConcurrentHashMap实例concurrentHashMap.put(RedPackageRainConstant.RED_PACKAGE_KEY,redPackageKey);concurrentHashMap.put(RedPackageRainConstant.RED_PACKAGE_USER_ID,userId);concurrentHashMap.put(RedPackageRainConstant.RED_PACKAGE_VALUE,partRedPackage);//将ConcurrentHashMap对象转换成字符串。String convertToString = StringUtil.convertToString(concurrentHashMap);//释放对象pool.release(concurrentHashMap);//发送MQ消息 发送字符串比发送对象的网络传输更小。这是因为字符串可以被序列化为字节数组，而对象需要被序列化为字节数组，并包含对象的类信息和其他序列化数据。因此，发送字符串可以节省网络传输的带宽。messageProducer.sendMessage(RedPackageRainConstant.TOPIC,convertToString);}});return Result.build(ResultCodeEnum.SUCCESS.getCode(), ResultCodeEnum.SUCCESS);}return Result.error(ResultCodeEnum.RED_PACKAGE_FINISHED.getCode(),ResultCodeEnum.RED_PACKAGE_FINISHED.getMessage());
}public Result fallbackRedPackage(Throwable throwable) {log.error("fallback RedPackage info:",throwable.getMessage());return Result.error(ResultCodeEnum.RED_PACKAGE_ERROR.getCode(),ResultCodeEnum.RED_PACKAGE_ERROR.getMessage());
}

hystrix 落地实现

pom.xml依赖

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

启动类上添加注解

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;@SpringBootApplication
@EnableDiscoveryClient
// 开启断路器，开启Hystrix容错能力
@EnableCircuitBreaker
public class SpringCloudHystrixDemoApplication {public static void main(String[] args) {SpringApplication.run(SpringCloudHystrixDemoApplication.class, args);}@Bean@LoadBalancedpublic RestTemplate restTemplate() {return new RestTemplate();}
}

接口上使用

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import com.netflix.hystrix.contrib.javanica.conf.HystrixPropertiesManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;@RestController
@RequestMapping("/hystrix")
public class HystrixController {@Autowiredprivate RestTemplate restTemplate;/*** HystrixCommand 开启Hystrix命令 当方法执行失败时，使用Hystrix逻辑处理* fallbackMethod 当方法执行失败时,调用此方法。*/@GetMapping("/getNacosConfigure")@HystrixCommand(fallbackMethod = "defaultFallbackMethod")public String getNacosConfigure() {return restTemplate.getForObject("http://nacos-config/getNacosConfigure", String.class);}private String defaultFallbackMethod() {return "方法执行失败啦，Hystrix起作用了";}// 信号量隔离@HystrixCommand(commandProperties = {// 超时时间，默认1000ms@HystrixProperty(name = HystrixPropertiesManager.EXECUTION_ISOLATION_THREAD_TIMEOUT_IN_MILLISECONDS, value = "5000"),// 信号量隔离@HystrixProperty(name = HystrixPropertiesManager.EXECUTION_ISOLATION_STRATEGY, value = "SEMAPHORE"),// 信号量最大并发@HystrixProperty(name = HystrixPropertiesManager.EXECUTION_ISOLATION_SEMAPHORE_MAX_CONCURRENT_REQUESTS, value = "5")},//回退方法fallbackMethod = "defaultFallbackMethod")@GetMapping("/semaphoreIsolation")public String semaphoreIsolation() {return "信号量隔离" + Thread.currentThread().getName();}// 线程池隔离@HystrixCommand(groupKey = "productService", // 服务名称，相同名称使用同一个线程池commandKey = "selectById",              // 接口名称，默认为方法名threadPoolKey = "productServiceListPool",    // 线程池名称，相同名称使用同一个线程池commandProperties = {// 超时时间，默认1000ms@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "5000")},threadPoolProperties = {// 线程池大小@HystrixProperty(name = "coreSize", value = "5"),// 等待队列长度（最大队列长度，默认值-1）@HystrixProperty(name = "maxQueueSize", value = "100"),// 线程存活时间，默认1min@HystrixProperty(name = "keepAliveTimeMinutes", value = "2"),// 超出等待队列阈值执行拒绝策略@HystrixProperty(name = "queueSizeRejectionThreshold", value = "100")},//回退方法fallbackMethod = "defaultFallbackMethod")@GetMapping("/threadPoolIsolation")public String threadPoolIsolation() {return "线程池隔离" + Thread.currentThread().getName();}// 服务熔断@HystrixCommand(commandProperties = {// 请求数阈值：在快照时间窗口内，必须满足请求阈值数才有资格熔断。打开断路器的最少请求数，默认20个请求。//意味着在时间窗口内，如果调用次数少于20次，即使所有的请求都超时或者失败，断路器都不会打开@HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_REQUEST_VOLUME_THRESHOLD, value = "10"),// 错误百分比阈值：当请求总数在快照内超过了阈值，且有一半的请求失败，这时断路器将会打开。默认50%@HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_ERROR_THRESHOLD_PERCENTAGE, value = "50"),// 快照时间窗口：断路器开启时需要统计一些请求和错误数据，统计的时间范围就是快照时间窗口，默认5秒@HystrixProperty(name = HystrixPropertiesManager.CIRCUIT_BREAKER_SLEEP_WINDOW_IN_MILLISECONDS, value = "5000")},fallbackMethod = "defaultFallbackMethod")@GetMapping("/serviceFuse")public String serviceFuse() {return "服务熔断" + Thread.currentThread().getName() + LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_TIME);}// 服务降级@HystrixCommand(fallbackMethod = "defaultFallbackMethod")@GetMapping("/serviceDegradation ")public String serviceDegradation() {return "服务降级" + Thread.currentThread().getName() + LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_TIME);}
}

CSDN

📢文章总结

对本篇文章进行总结： 本篇文章主要讲解了熔断限流组件resilience4j和hystrix，对sentinel感兴趣的同学可以看看这二篇文章：

  • 【java_wxid项目】【第十六章】【Spring Cloud Alibaba Sentinel集成】
  • sentinel-dashboard-1.8.0.jar开机自启动脚本

🔔以上就是今天要讲的内容，阅读结束后，反思和总结所学内容，并尝试应用到现实中，有助于深化理解和应用知识。与朋友或同事分享所读内容，讨论细节并获得反馈，也有助于加深对知识的理解和吸收。

以梦为马，不负韶华

🔔如果您需要转载或者搬运这篇文章的话，非常欢迎您私信我哦~

🚀🎉希望各位读者大大多多支持用心写文章的博主，现在时代变了，🚀🎉 信息爆炸，酒香也怕巷子深🔥，博主真的需要大家的帮助才能在这片海洋中继续发光发热🎨，所以，🏃💨赶紧动动你的小手，点波关注❤️，点波赞👍，点波收藏⭐，甚至点波评论✍️，都是对博主最好的支持和鼓励！

  • 💂 博客主页： 我是廖志伟
  • 👉开源项目：java_wxid
  • 🌥 哔哩哔哩：我是廖志伟
  • 🎏个人社区：幕后大佬
  • 🔖个人微信号： SeniorRD
  • 🎉微信号二维码：SeniorRD

📥博主目标

探寻内心世界，博主分享人生感悟与未来目标

  • 🍋程序开发这条路不能停，停下来容易被淘汰掉，吃不了自律的苦，就要受平庸的罪，持续的能力才能带来持续的自信。我本是一个很普通的程序员，放在人堆里，除了与生俱来的盛世美颜，就剩180的大高个了，就是我这样的一个人，默默写博文也有好多年了。
  • 📺有句老话说的好，牛逼之前都是傻逼式的坚持，希望自己可以通过大量的作品、时间的积累、个人魅力、运气、时机，可以打造属于自己的技术影响力。
  • 💥内心起伏不定，我时而激动，时而沉思。我希望自己能成为一个综合性人才，具备技术、业务和管理方面的精湛技能。我想成为产品架构路线的总设计师，团队的指挥者，技术团队的中流砥柱，企业战略和资本规划的实战专家。
  • 🎉这个目标的实现需要不懈的努力和持续的成长，但我必须努力追求。因为我知道，只有成为这样的人才，我才能在职业生涯中不断前进并为企业的发展带来真正的价值。在这个不断变化的时代，我们必须随时准备好迎接挑战，不断学习和探索新的领域，才能不断地向前推进。我坚信，只要我不断努力，我一定会达到自己的目标。

🔔有需要对自己进行综合性评估，进行职业方向规划，我可以让技术大牛帮你模拟面试、针对性的指导、传授面试技巧、简历优化、进行技术问题答疑等服务。

可访问：https://java_wxid.gitee.io/tojson/

开发人员简历优化、面试突击指导、技术问题解答

这篇关于【熔断限流组件resilience4j和hystrix】的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


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

相关文章

JS常用组件收集

JS常用组件收集

收集了一些平时遇到的前端比较优秀的组件，方便以后开发的时候查找！！！ 函数工具： Lodash 页面固定： stickUp、jQuery.Pin 轮播： unslider、swiper 开关: switch 复选框： icheck 气泡： grumble 隐藏元素： Headroom
阅读更多...
如何在页面调用utility bar并传递参数至lwc组件

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件： 2.调用utility bar api的方式有两种： 方法一，通过lwc调用： import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca
阅读更多...
vue2 组件通信

vue2 组件通信

props + emits props:用于接收父组件传递给子组件的数据。可以定义期望从父组件接收的数据结构和类型。‘子组件不可更改该数据’emits:用于定义组件可以向父组件发出的事件。这允许父组件监听子组件的事件并作出响应。(比如数据更新) props检查属性 属性名类型描述默认值typeFunction指定 prop 应该是什么类型，如 String, Number, Boolean,
阅读更多...
kubelet组件的启动流程源码分析

kubelet组件的启动流程源码分析

概述 摘要: 本文将总结kubelet的作用以及原理，在有一定基础认识的前提下，通过阅读kubelet源码，对kubelet组件的启动流程进行分析。 正文 kubelet的作用 这里对kubelet的作用做一个简单总结。 节点管理 节点的注册 节点状态更新 容器管理(pod生命周期管理) 监听apiserver的容器事件 容器的创建、删除(CRI) 容器的网络的创建与删除
阅读更多...
火语言RPA流程组件介绍--浏览网页

火语言RPA流程组件介绍--浏览网页

🚩【组件功能】：浏览器打开指定网址或本地html文件 配置预览 配置说明 网址URL 支持T或# 默认FLOW输入项 输入需要打开的网址URL 超时时间 支持T或# 打开网页超时时间 执行后后等待时间(ms) 支持T或# 当前组件执行完成后继续等待的时间 UserAgent 支持T或# User Agent中文名为用户代理，简称 UA，它是一个特殊字符串头，使得服务器
阅读更多...
vue 父组件调用子组件的方法报错，“TypeError: Cannot read property ‘subDialogRef‘ of undefined“

vue 父组件调用子组件的方法报错，“TypeError: Cannot read property ‘subDialogRef‘ of undefined“

vue 父组件调用子组件的方法报错，“TypeError: Cannot read property ‘subDialogRef’ of undefined” 最近用vue做的一个界面，引入了一个子组件，在父组件中调用子组件的方法时，报错提示： [Vue warn]: Error in v-on handler: “TypeError: Cannot read property ‘methods
阅读更多...
JavaEE应用的组件

JavaEE应用的组件

1、表现层组件：主要负责收集用户输入数据，或者向客户显示系统状态。最常用的表现层技术是JSP，但JSP并不是唯一的表现层技术。 2、控制器组件：对于JavaEE的MVC框架而言，框架提供一个前端核心控制器，而核心控制器负责拦截用户请求，并将用户请求转发给用户实现的控制器组件。而这些用户实现的控制器则负责处理调用业务逻辑方法，处理用户请求。 3、业务逻辑组件：是系统的核心组件，实现系统的业务逻辑
阅读更多...
Java后端微服务架构下的API限流策略：Guava RateLimiter

Java后端微服务架构下的API限流策略：Guava RateLimiter

Java后端微服务架构下的API限流策略：Guava RateLimiter 大家好，我是微赚淘客返利系统3.0的小编，是个冬天不穿秋裤，天冷也要风度的程序猿！ 在微服务架构中，API限流是保护服务不受过度使用和拒绝服务攻击的重要手段。Guava RateLimiter是Google开源的Java库中的一个组件，提供了简单易用的限流功能。 API限流概述 API限流通过控制请求的速率来防止
阅读更多...
17 通过ref代替DOM用来获取元素和组件的引用

17 通过ref代替DOM用来获取元素和组件的引用

重点 ref :官网给出的解释是： ref: 用于注册对元素或子组件的引用。引用将在父组件的$refs 对象下注册。如果在普通DOM元素上使用，则引用将是该元素；如果在子组件上使用，则引用将是组件实例： <!-- vm.$refs.p will be the DOM node --><p ref="p">hello</p><!-- vm.$refs.child will be the c
阅读更多...
16 子组件和父组件之间传值

16 子组件和父组件之间传值

划重点 子组件 / 父组件 定义组件中：props 的使用组件中：data 的使用(有 return 返回值) ； 区别：Vue中的data （没有返回值）;组件方法中 emit 的使用：emit:英文原意是：触发、发射 的意思components :直接在Vue的方法中声明和绑定要使用的组件 小炒肉：温馨可口 <!DOCTYPE html><html lang="en"><head><
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2