Spring搭配Ehcache实例解析

package com.test.ehcache;

import java.io.Serializable;

import net.sf.ehcache.Cache;
import net.sf.ehcache.Element;

import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.util.Assert;

public class CacheMethodInterceptor implements MethodInterceptor,
 InitializingBean {

 private Cache cache;

 public void setCache(Cache cache) {
 this.cache = cache;
 }

 public CacheMethodInterceptor() {
 super();
 }

 /**
 * 拦截ServiceManager的方法，并查找该结果是否存在，如果存在就返回cache中的值，
 * 否则，返回数据库查询结果，并将查询结果放入cache
 */
 public Object invoke(MethodInvocation invocation) throws Throwable {
 //获取要拦截的类
 String targetName = invocation.getThis().getClass().getName();
 //获取要拦截的类的方法
 String methodName = invocation.getMethod().getName();
 //获得要拦截的类的方法的参数
 Object[] arguments = invocation.getArguments();
 Object result;

 //创建一个字符串，用来做cache中的key
 String cacheKey = getCacheKey(targetName, methodName, arguments);
 //从cache中获取数据
 Element element = cache.get(cacheKey);

 if (element == null) {
 //如果cache中没有数据，则查找非缓存，例如数据库，并将查找到的放入cache

  result = invocation.proceed();
  //生成将存入cache的key和value
  element = new Element(cacheKey, (Serializable) result);
  System.out.println("-----进入非缓存中查找，例如直接查找数据库，查找后放入缓存");
  //将key和value存入cache
  cache.put(element);
 } else {
 //如果cache中有数据，则查找cache

  System.out.println("-----进入缓存中查找，不查找数据库，缓解了数据库的压力");
 }
 return element.getValue();
 }

 /**
 * 获得cache的key的方法，cache的key是Cache中一个Element的唯一标识，
 * 包括包名+类名+方法名，如：com.test.service.TestServiceImpl.getObject
 */
 private String getCacheKey(String targetName, String methodName,
  Object[] arguments) {
 StringBuffer sb = new StringBuffer();
 sb.append(targetName).append(".").append(methodName);
 if ((arguments != null) && (arguments.length != 0)) {
  for (int i = 0; i 

package com.test.ehcache;

import java.lang.reflect.Method;
import java.util.List;

import net.sf.ehcache.Cache;

import org.springframework.aop.AfterReturningAdvice;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.util.Assert;

public class CacheAfterReturningAdvice implements AfterReturningAdvice,
 InitializingBean {

 private Cache cache;

 public void setCache(Cache cache) {
 this.cache = cache;
 }

 public CacheAfterReturningAdvice() {
 super();
 }

 public void afterReturning(Object arg0, Method arg1, Object[] arg2,
  Object arg3) throws Throwable {
 String className = arg3.getClass().getName();
 List list = cache.getKeys();
 for (int i = 0; i 

package com.test.service;

import java.util.List;

public interface ServiceManager { 
 public List getObject(); 

 public void updateObject(Object Object); 
}

package com.test.service;

import java.util.ArrayList;
import java.util.List;

public class ServiceManagerImpl implements ServiceManager {

 @Override
 public List getObject() {
 System.out.println("-----ServiceManager：缓存Cache内不存在该element，查找数据库，并放入Cache！");

 return null;
 }

 @Override
 public void updateObject(Object Object) {
 System.out.println("-----ServiceManager：更新了对象，这个类产生的cache都将被remove！");
 }

}

package com.test.service;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestMain {

 public static void main(String[] args) {

 String cacheString = "/cache-bean.xml";
 ApplicationContext cOntext= new ClassPathXmlApplicationContext(
  cacheString);
 //获取代理工厂proxyFactory生成的bean，以便产生拦截效果
 ServiceManager testService = (ServiceManager) context.getBean("proxyFactory");

 // 第一次查找
 System.out.println("=====第一次查找");
 testService.getObject();

 // 第二次查找
 System.out.println("=====第二次查找");
 testService.getObject();

 // 执行update方法（应该清除缓存）
 System.out.println("=====第一次更新");
 testService.updateObject(null);

 // 第三次查找
 System.out.println("=====第三次查找");
 testService.getObject();
 } 
}

<&＃63;xml version="1.0" encoding="UTF-8"&＃63;> 
  
 
  
  
  
  ehcache.xml 
 
  

  
  
  
   
 
 
  
  com.tt 
  
  

  
  
  
   
  
 

  
  
  
   
  
 

 
  

 
  
 
  
   
  
  
   
     
  
  .*get.* 
   
  
  

 
  
  
   
  
  
  
   
  .*update.* 
   
  
 

 
 
 
  
   
  
 
  
   
  cachePointCut 
  cachePointCutAdvice 
   
  
  

<&＃63;xml version="1.0" encoding="UTF-8"&＃63;>