如何利用Guava实现方法调用超时自动中断

2024-05-15 03:32

本文主要是介绍如何利用Guava实现方法调用超时自动中断,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在实际的开发中,我们会经常遇见一些这样的情景, 
(1)对于突发高并发下环境下,服务器压力很大的情况下,调用某些方法超过100ms不响应,应自动拒绝服务,而不是一直阻塞下去,直至服务器崩溃,算是一种变相的服务降级 
(2)对于不可预知可能出现死锁的代码,加上时间阈值限制,避免无限制资源竞争 
(3)对于不可预知可能出现死循环的代码,加上时间阈值监控,避免死循环恶化 

对于一些成熟的开源框架一般都会带有超时响应这种功能,比如 
搜索框架:Lucene,Solr,ElasticSearch, 
RPC框架:Dubbo,Thrift, 
服务协调框架:Zookeeper 等 


如果是我们自己开发的服务,想要加入这种功能,应该怎么做呢? 其实也不难,在方法的调用前后加入加入计时功能,如果超过阈值,应主动终止线程,抛出异常代码,当然,为了不影响主服务运行,这段代码,应该独立运行在一个子线程中,而不是耦合在主线程中。思路大致如此,当然为了不重复造轮子,建议使用Google开源的Guava工具包,里面提供了许多有用的功能,包括这次介绍的超时方法自动终止功能,还有一些限制网络流量,或者限制在规定时间内的访问次数的功能,这里就不一一说明了,感兴趣的朋友,可以自行看Guava的文档。 


TimeLimiter 是个接口,下面有两个子类, 
FakeTimeLimiter,  常用于debug时,限制时间超时调试 
SimpleTimeLimiter   常用于正式方法中,调用方法超时,即抛出异常 

重点介绍下SimpleTimeLimiter的使用,这个类里面主要有2个方法: 

(1)newProxy  通过JDK动态代理配合callWithTimeout实现超时拦截 
(2)callWithTimeout  通过Callable回调,实现超时拦截 

两者的不同之初在于,通过代理方式实现的策略,可以对这个类里面每一个被调用的方法,实行超时拦截 
而通过回调实现的策略,适用于仅仅对某一个代码块或者方法,实行超时拦截。 

通过maven引入最新的guava包: 

Java代码   收藏代码
  1. <dependency>  
  2.            <groupId>com.google.guava</groupId>  
  3.            <artifactId>guava</artifactId>  
  4.            <version>19.0</version>  
  5.        </dependency>  


A:基于代理模式实现的拦截: 
由于Guava采用的是JDK动态代理的方式实行AOP拦截,所以要求代理类必须有一个接口实现,所以用起来稍显麻烦, 
我们先需要定义一个接口,然后定义实现类,重写需要调用的方法: 






调用:  



B:基于回调的用法,比较简单,因为不需要使用代理模式 




总结: 两种方式都能实现方法调用超时中断,代理方式适合用于类级别的方法超时中断,而基于回调的方式 
则比较适合任意的单个方法使用。 



有什么问题可以扫码关注微信公众号:我是攻城师(woshigcs),在后台留言咨询。 
技术债不能欠,健康债更不能欠, 求道之路,与君同行。 

 

这篇关于如何利用Guava实现方法调用超时自动中断的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/990684

相关文章

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

第10章 中断和动态时钟显示

第10章 中断和动态时钟显示 从本章开始,按照书籍的划分,第10章开始就进入保护模式(Protected Mode)部分了,感觉从这里开始难度突然就增加了。 书中介绍了为什么有中断(Interrupt)的设计,中断的几种方式:外部硬件中断、内部中断和软中断。通过中断做了一个会走的时钟和屏幕上输入字符的程序。 我自己理解中断的一些作用: 为了更好的利用处理器的性能。协同快速和慢速设备一起工作

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯,先赞后看哦~🎈🎈 🏆 作者简介:景天科技苑 🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,CSDN全栈领域优质创作者,掘金优秀博主,51CTO博客专家等。 🏆《博客》:Python全栈,前后端开发,小程序开发,人工智能,js逆向,App逆向,网络系统安全,数据分析,Django,fastapi

如何在页面调用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

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现,因为rasa本身是带有remindschedule模块的。不过经过一番折腾后,忽然发现,chatbot上实现的定时,语音助手不一定会有响应。因为,我目前语音助手的代码设置了长时间无应答会结束对话,这样一来,chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢? 我最后选择的方法是用threading.Time

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

浅谈主机加固,六种有效的主机加固方法

在数字化时代,数据的价值不言而喻,但随之而来的安全威胁也日益严峻。从勒索病毒到内部泄露,企业的数据安全面临着前所未有的挑战。为了应对这些挑战,一种全新的主机加固解决方案应运而生。 MCK主机加固解决方案,采用先进的安全容器中间件技术,构建起一套内核级的纵深立体防护体系。这一体系突破了传统安全防护的局限,即使在管理员权限被恶意利用的情况下,也能确保服务器的安全稳定运行。 普适主机加固措施:

webm怎么转换成mp4?这几种方法超多人在用!

webm怎么转换成mp4?WebM作为一种新兴的视频编码格式,近年来逐渐进入大众视野,其背后承载着诸多优势,但同时也伴随着不容忽视的局限性,首要挑战在于其兼容性边界,尽管WebM已广泛适应于众多网站与软件平台,但在特定应用环境或老旧设备上,其兼容难题依旧凸显,为用户体验带来不便,再者,WebM格式的非普适性也体现在编辑流程上,由于它并非行业内的通用标准,编辑过程中可能会遭遇格式不兼容的障碍,导致操