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

您所在的位置：程序员俱乐部 > 编程开发 > JAVA > 如何利用Guava实现方法调用超时自动中断

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

2016/6/15 5:35:10 qindongliang1922 程序员俱乐部我要评论(0)

摘要：在实际的开发中，我们会经常遇见一些这样的情景，（1）对于突发高并发下环境下，服务器压力很大的情况下，调用某些方法超过100ms不响应，应自动拒绝服务，而不是一直阻塞下去，直至服务器崩溃，算是一种变相的服务降级（2）对于不可预知可能出现死锁的代码，加上时间阈值限制，避免无限制资源竞争（3）对于不可预知可能出现死循环的代码，加上时间阈值监控，避免死循环恶化对于一些成熟的开源框架一般都会带有超时响应这种功能，比如搜索框架：Lucene，Solr，ElasticSearch，RPC框架：Dubbo
标签：方法实现利用超时

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

class="java" name="code">
 <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>19.0</version>
        </dependency>

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