posts - 156,  comments - 601,  trackbacks - 0

    在上篇博客中,介绍了如何借助Spring Module项目,配置声明式缓存功能实现,文中只针对Ehcahce的实现进行了讲解,其实Spring Module项目把这块的功能做了一个很好的抽取,使其能更方便的对其它的缓存框架的支持和扩展。笔者正好利用该代码框架实现了与Memcached服务的集成,本文将得点通过源代码解讲一下抽取这层的实现,希望对大家有所帮助。注:本文只讲缓存部分的实现,刷新部分功能相同,请大家自己源读代码即可。

   先看一下Spring的配置内容
 1     <!-- 缓存拦截器 -->
 2     <bean id="cachingInterceptor"
 3         class="org.springmodules.cache.interceptor.caching.MethodMapCachingInterceptor">
 4         <property name="cacheProviderFacade" ref="cacheProviderFacade" />
 5         <property name="cachingModels"> <!-- 进行cache缓存 -->
 6             <props> <!-- 所有StudentService对象中,以get开头的方法都将进行缓存 -->
 7                 <prop key="StudentService.get*">cacheName=testCache</prop>
 8             </props>
 9         </property>
10     </bean>
11     
12     
13     <!-- 配置 基于BeanName规则的动态代理封装 -->
14     <bean class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
15         <property name="beanNames">
16             <list>
17                 <value>studentService</value>
18             </list>
19         </property>
20         <property name="interceptorNames">
21             <list>
22                 <value>cachingInterceptor</value>
23                 <value>flushingInterceptor</value>
24             </list>
25         </property>
26     </bean>
  通过Spring提供的BeanNameAutoProxyCreator类,提供对Bean对象的统一自动代理实现。从上面的配置中,实现缓存拦截的实现类就是org.springmodules.cache.interceptor.caching.MethodMapCachingInterceptor。实现了MethodInterceptor接口,对代理的对象的方法调用进行拦截,实现缓存功能。
下面是完整的类图:

  

从类图中,可以看到AbstractCachingInterceptor抽象实现了MethodInterceptor接口的invoke方法。这也是整个缓存处理的入口。
看代码之前,我先来补充一下框架是如果实现方法拦截后的匹配过程。
首先是构建匹配规则:
由 MethodMapCachingInterceptor类的onAfterPropertiesSet方法实现。
实现思路如下:
取得 cachingModels属性,遍历每一个 key
 例如上例中 StudentService.get* , 解析出 class 类名(StudentService),和方法的匹配字符串(get*)
 然后通过 Class.forName 方法,装载该类,取出该类的所有方法,一一与指定的方法匹配字符串进行 正则匹配TextMatcher.isMatch,匹配通过的则放入到一个Map中, key=Method对象, value=CacheModel对象当 拦截器 对调用的方法进行拦截时,通过 map.get返回值来确认是否对方法进行缓存处理

实现代码如下:已经添加注释
 1     public final Object invoke(MethodInvocation mi) throws Throwable {
 2         Method method = mi.getMethod();//取得拦截的方法
 3         if (!CachingUtils.isCacheable(method))
 4             return methodNotCacheable(mi, method); //如果是void返回值,则不需要缓存支持
 5 
 6         CachingModel model = model(mi); //根据method,则定是否要进行缓存
 7         if (model == nullreturn noModelFound(mi, method);
 8 
 9         Serializable key = keyGenerator.generateKey(mi);//根据方法对象,生成key
10         Object cached = cache.getFromCache(key, model);//如果有缓存
11 
12         if (null == cached) return cachedValueFromSource(mi, key, model); //如果没有缓存,把返回保存到缓存
13         return unmaskNull(cached);
14     }


到些基本的实现流程已经讲解完了,其它的大家可以通过阅读源代码进行理解。

最后补充一下如何根据这个框架集成其它的缓存服务,需要实现的接口和继承的抽象类如下:
AbstractCacheProviderFacade 缓存保存,取得,更新的实现
AbstractCacheModelValidator 检测缓存模型合法性
CachingModel 保存缓存的模型接口
AbstractFlushingModel 刷新缓存的模型抽象类


Good Luck!
Yours Matthew!

posted on 2010-05-13 19:53 x.matthew 阅读(4416) 评论(2)  编辑  收藏 所属分类: Spring|Hibernate|Other framework

只有注册用户登录后才能发表评论。


网站导航: