如何利用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包：

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

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






调用：



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




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



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