`
qindongliang1922
  • 浏览: 2184317 次
  • 性别: Icon_minigender_1
  • 来自: 北京
博客专栏
7265517b-f87e-3137-b62c-5c6e30e26109
证道Lucene4
浏览量:117541
097be4a0-491e-39c0-89ff-3456fadf8262
证道Hadoop
浏览量:125928
41c37529-f6d8-32e4-8563-3b42b2712a50
证道shell编程
浏览量:59923
43832365-bc15-3f5d-b3cd-c9161722a70c
ELK修真
浏览量:71301
社区版块
存档分类
最新评论

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

    博客分类:
  • JAVA
阅读更多

在实际的开发中,我们会经常遇见一些这样的情景,
(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包:

 <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>19.0</version>
        </dependency>


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






调用:



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




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



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





  • 大小: 12.9 KB
  • 大小: 16.8 KB
  • 大小: 52.9 KB
  • 大小: 43.3 KB
1
1
分享到:
评论

相关推荐

    使用google guava 实现定时缓存功能

    本篇文章将详细探讨如何利用Guava库实现定时缓存功能,以提高应用的性能和效率。 首先,Guava的Cache组件是其核心特性之一,它提供了一种高效、自动化的缓存机制。定时缓存功能允许我们存储计算结果或从远程服务...

    guava使用方法教程

    guava 使用方法 教程

    guava-jdk5

    6. **预检查(Preconditions)**:Guava的Preconditions类提供了多种断言方法,用于在程序执行前检查条件是否满足,有助于发现潜在的错误,提高代码质量。 7. **流(Stream)操作**:虽然Java 5本身不支持Stream API...

    guava-18.0(guava-18.0.jar和guava-18.0-sources.jar)

    7. **流处理**:Guava的FluentIterable和Iterables提供了一种更流畅的迭代器操作方式,便于链式调用。 8. **事件监听**:Guava的EventBus可以方便地实现发布/订阅模式,简化事件驱动的编程。 9. **枚举集与常量**:...

    eclipse-guava-插件

    通过Eclipse Guava插件,你可以轻松地自动生成基于类字段的`toString()`实现,这样可以减少错误并保持代码整洁。 `hashCode()`和`equals()`方法是Java中的关键组件,它们用于对象比较和哈希表操作。`hashCode()`...

    guava-18.0资料

    2. **缓存机制**:Guava提供了强大的本地缓存实现,允许开发者创建自定义的缓存策略,如基于引用或时间的自动过期。 3. **函数式编程**:Guava引入了Function、Predicate等接口,支持函数式编程风格,便于编写无副...

    SpringBoot使用Guava实现日志脱敏

    在Guava中,脱敏通常涉及对字符串的操作,例如使用`Strings.redact()`方法将敏感数据替换为特定的占位符,如"&lt;REDACTED&gt;"。此外,还可以使用`CharMatcher`类来自定义脱敏规则,只对特定类型的字符进行脱敏。 使用...

    guava-cache.rar

    Guava Cache支持惰性加载,即当尝试获取一个不存在的键对应的值时,会自动调用预设的`CacheLoader`来计算并存储该值。上述代码中的`createExpensiveGraph`方法就是一个典型的计算逻辑。 3. **缓存统计** Guava ...

    Guava 工程项目包 有实例

    - **缓存**:Guava 提供了一种高效、可配置的缓存实现,使得缓存数据变得简单,支持自动过期和大小限制。 - **函数式编程**:Guava 引入了 Function 和 Predicate 等接口,促进了函数式编程风格在 Java 中的应用。...

    guava 常用API说明

    Guava的EnumSet是针对枚举类型的高效集合实现,比使用标准的Set实现有更好的性能。 通过以上对Guava常用API的介绍,我们可以看出Guava库的强大之处在于它为Java开发提供了许多实用工具和优化,帮助我们编写出更...

    guava-23.0.zip guava.jar guava

    2. **缓存机制**:Guava提供了LruCache(最近最少使用)缓存实现,可以方便地在应用程序中构建高效的缓存系统。 3. **函数式编程**:Guava支持函数式编程,包括Function、Predicate、Transformer等接口,便于编写...

    Guava-Cache本地缓存案例代码

    Guava Cache是Google Guava库中的一个强大特性,它提供了高效的本地缓存解决方案,用于存储经常访问的数据,以减少对远程服务或计算的调用,从而提高应用性能。本案例代码将详细介绍Guava Cache的使用,包括缓存的...

    guava-21.0-rc2 、guava-21.0-rc2-javadoc 、guava-21.0-rc2-sources

    2. **guava-21.0-rc2-javadoc**: Javadoc是Java的文档生成工具,用于自动生成API文档。这个文件包含了Guava库中所有公共类和方法的详细说明,是开发者理解和使用Guava API的重要参考。通过阅读Javadoc,开发者可以...

    guava-26.0-jre.zip

    2. **缓存机制**:Guava提供了LruCache(最近最少使用)实现,帮助开发者轻松创建高效的数据缓存系统,自动管理缓存大小,并能根据访问模式进行优化。 3. **函数式编程**:Guava支持函数式编程风格,包括Function、...

    Guava常用类库 v33.0.0.zip

    6. **I/O工具**:Guava的Files、ByteStreams和CharStreams类提供了许多方便的静态方法,用于处理文件、字节流和字符流操作,简化了I/O操作。 7. **原生类型支持**:Guava提供了对基本类型(如int、char等)的泛型...

    Google Guava 官方教程

    通过 LoadingCache,你可以轻松实现自动加载或计算缺失的缓存项。 3. **并发编程支持** Guava 提供了并发工具,如 ListenableFuture 和 Futures,便于构建异步处理程序。它还包含一个强大的执行服务 ...

    不加密Google Guava视频教程.txt

    ├─Google Guava 第21讲-实战:手动实现一个EventBus-02快速实现程序功能.wmv ├─Google Guava 第22讲-实战:手动实现一个EventBus-03总结与查缺补漏.wmv ├─Google Guava 第23讲-Guava EventBus源码剖析以及优...

    google-guava.jar

    Guava的Cache模块提供了一种高效的本地缓存实现,可以自动管理缓存项的过期和容量限制。开发者可以通过简单的方法调用实现缓存的创建、加载和淘汰策略,大大提高了应用的性能。 三、并发编程支持 Guava提供了许多...

    Go-Localcaching-GuavaCache在Go中的部分的实现

    但是,Guava Cache包含了一些高级特性,如自动过期、大小限制、缓存加载和监听器等,这些需要通过自定义代码或者第三方库来实现。 1. **自动过期**:Guava Cache允许设置缓存项的过期时间,超过这个时间后,缓存项...

    Guava-CacheDemo.rar

    1. **LoadingCache**: Guava Cache的核心接口,它是一个自动加载的缓存,当试图获取一个不存在的键对应的值时,会自动调用预先定义的`CacheLoader`来加载数据。 2. **LoadingCache.put()**: 向缓存中添加或更新条目...

Global site tag (gtag.js) - Google Analytics