AutoLoadCache

<dependency>
 <groupId>com.github.qiujiayu</groupId>
 <artifactId>autoload-cache</artifactId>
 <version>2.8</version>
</dependency>

<!-- Jedis 连接池配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
 <property name="maxTotal" value="2000" />
 <property name="maxIdle" value="100" />
 <property name="minIdle" value="50" />
 <property name="maxWaitMillis" value="2000" />
 <property name="testOnBorrow" value="false" />
 <property name="testOnReturn" value="false" />
 <property name="testWhileIdle" value="false" />
</bean>
<bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool">
 <constructor-arg ref="jedisPoolConfig" />
 <constructor-arg>
 <list>
 <bean class="redis.clients.jedis.JedisShardInfo">
 <constructor-arg value="${redis1.host}" />
 <constructor-arg type="int" value="${redis1.port}" />
 <constructor-arg value="instance:01" />
 </bean>
 <bean class="redis.clients.jedis.JedisShardInfo">
 <constructor-arg value="${redis2.host}" />
 <constructor-arg type="int" value="${redis2.port}" />
 <constructor-arg value="instance:02" />
 </bean>
 <bean class="redis.clients.jedis.JedisShardInfo">
 <constructor-arg value="${redis3.host}" />
 <constructor-arg type="int" value="${redis3.port}" />
 <constructor-arg value="instance:03" />
 </bean>
 </list>
 </constructor-arg>
</bean>
<bean id="autoLoadConfig" class="com.jarvis.cache.to.AutoLoadConfig">
 <property name="threadCnt" value="10" />
 <property name="maxElement" value="20000" />
 <property name="printSlowLog" value="true" />
 <property name="slowLoadTime" value="500" />
 <property name="sortType" value="1" />
 <property name="checkFromCacheBeforeLoad" value="true" />
</bean>
<!-- 可以通过implements com.jarvis.cache.serializer.ISerializer<Object> 实现 Kryo 和 FST Serializer 工具,框架的核对不在这里,所以不提供过多的实现 -->
<bean id="hessianSerializer" class="com.jarvis.cache.serializer.HessianSerializer" />
<bean id="cachePointCut" class="com.jarvis.cache.redis.ShardedCachePointCut" destroy-method="destroy">
 <constructor-arg ref="autoLoadConfig" />
 <property name="serializer" ref="hessianSerializer" />
 <property name="shardedJedisPool" ref="shardedJedisPool" />
 <property name="namespace" value="test_hessian" />
</bean>

<bean id="memcachedClient" class="net.spy.memcached.spring.MemcachedClientFactoryBean">
 <property name="servers" value="192.138.11.165:11211,192.138.11.166:11211" />
 <property name="protocol" value="BINARY" />
 <property name="transcoder">
 <bean class="net.spy.memcached.transcoders.SerializingTranscoder">
 <property name="compressionThreshold" value="1024" />
 </bean>
 </property>
 <property name="opTimeout" value="2000" />
 <property name="timeoutExceptionThreshold" value="1998" />
 <property name="hashAlg">
 <value type="net.spy.memcached.DefaultHashAlgorithm">KETAMA_HASH</value>
 </property>
 <property name="locatorType" value="CONSISTENT" />
 <property name="failureMode" value="Redistribute" />
 <property name="useNagleAlgorithm" value="false" />
</bean>
<bean id="hessianSerializer" class="com.jarvis.cache.serializer.HessianSerializer" />
<bean id="cachePointCut" class="com.jarvis.cache.memcache.CachePointCut" destroy-method="destroy">
 <constructor-arg ref="autoLoadConfig" />
 <property name="serializer" ref="hessianSerializer" />
 <property name="memcachedClient", ref="memcachedClient" />
 <property name="namespace" value="test" />
</bean>

<aop:config>
 <aop:aspect ref="cachePointCut">
 <aop:pointcut id="daoCachePointcut" expression="execution(public !void com.jarvis.cache_example.common.dao..*.*(..)) &amp;&amp; @annotation(cache)" />
 <aop:around pointcut-ref="daoCachePointcut" method="proceed" />
 </aop:aspect>
 <aop:aspect ref="cachePointCut" order="1000"><!-- order 参数控制 aop通知的优先级,值越小,优先级越高 ,在事务提交后删除缓存 -->
 <aop:pointcut id="deleteCachePointcut" expression="execution(* com.jarvis.cache_example.common.dao..*.*(..)) &amp;&amp; @annotation(cacheDelete)" />
 <aop:after-returning pointcut-ref="deleteCachePointcut" method="deleteCache" returning="retVal"/>
 </aop:aspect>
</aop:config>

package com.jarvis.example.dao;
import ... ...
public class UserDAO {
 /**
 * 添加用户的同时,把数据放到缓存中
 * @param userName
 * @return
 */
 @Cache(expire=600, key="'user'+#retVal.id", opType=CacheOpType.WRITE)
 public UserTO addUser(String userName) {
 UserTO user=new UserTO();
 user.setName(userName);
 Random rand=new Random();
 // 数据库返回ID
 Integer id=rand.nextInt(100000);
 user.setId(id);
 System.out.println("add User:" + id);
 return user;
 }
 
 /**
 * 
 * @param id
 * @return
 */
 @Cache(expire=600, autoload=true, key="'user'+#args[0]", condition="#args[0]>0")
 public UserTO getUserById(Integer id) {
 UserTO user=new UserTO();
 user.setId(id);
 user.setName("name" + id);
 System.out.println("getUserById from dao");
 return user;
 }
 
 /**
 * 
 * @param user
 */
 @CacheDelete({@CacheDeleteKey(value="'user'+#args[0].id", keyType=CacheKeyType.DEFINED)})
 public void updateUserName(UserTO user) {
 System.out.println("update user name:" + user.getName());
 // save to db
 }
 // 注意:因为没有用 SpEL表达式,所以不需要用单引号
 @CacheDelete({@CacheDeleteKey(value="user*", keyType=CacheKeyType.DEFINED)})
 public void clearUserCache() {
 System.out.println("clearUserCache");
 }
 // ------------------------以下是使用默认生成Key的方法--------------------
 @Cache(expire=600, autoload=true, condition="#args[0]>0")
 public UserTO getUserById2(Integer id) {
 UserTO user=new UserTO();
 user.setId(id);
 user.setName("name" + id);
 System.out.println("getUserById from dao");
 return user;
 }
 @CacheDelete({@CacheDeleteKey(cls=UserDAO.class, method="getUserById2", argsEl={"#args[0].id"}, keyType=CacheKeyType.DEFAULT)})
 public void updateUserName2(UserTO user) {
 System.out.println("update user name:" + user.getName());
 // save to db
 }
 @CacheDelete({@CacheDeleteKey(deleteByPrefixKey=true, cls=UserDAO.class, method="getUserById2", keyType=CacheKeyType.DEFAULT)})
 public void clearUserCache2() {
 System.out.println("clearUserCache");
 // save to db
 }
}

当@Cache中不设置key值时,使用默认方式生成缓存Key。

package com.jarvis.example.dao;
import ... ...
public class GoodsCommentDAO{
 @Cache(expire=600, subKeySpEL="#args[0]", autoload=true, requestTimeout=18000)
 public List<CommentTO> getCommentListByGoodsId(Long goodsId, int pageNo, int pageSize) {
 ... ...
 }
}

package com.jarvis.example.dao;
import ... ...
public class GoodsCommentDAO{
 
 @Cache(expire=600, subKeySpEL="#args[0]", autoload=true, requestTimeout=18000)
 public List<CommentTO> getCommentListByGoodsId(Long goodsId, int pageNo, int pageSize) {
 ... ...
 }
 @CacheDelete({@CacheDeleteKey(cls=GoodsCommentDAO.class, method="getCommentListByGoodsId", deleteByPrefixKey=true, subKeySpEL=subKeySpEL="#args[0].goodsId" , keyType=CacheKeyType.DEFAULT)})
 public void addComment(Comment comment) {
 ... ...// 省略添加评论代码
 }
 }
}

package com.jarvis.example.dao;
import ... ...
public class GoodsCommentDAO{
 @Cache(expire=600, key="'goods_comment_'+#args[0]+'.list__'+#args[1]+'_'+#args[2]", autoload=true, requestTimeout=18000)
 public List<CommentTO> getCommentListByGoodsId(Long goodsId, int pageNo, int pageSize) {
 ... ...
 }
 @CacheDelete({@CacheDeleteKey(value="'goods_comment_'+#args[0].goodsId+'*'", keyType=CacheKeyType.DEFINED)}) // 删除当前所属商品的所有评论,不删除其它商品评论
 public void addComment(Comment comment) {
 ... ...// 省略添加评论代码
 }
}

<aop:aspect ref="cachePointCut" order="1000">
 <aop:pointcut id="deleteCachePointcut"
 expression="execution(* com.jarvis.cache_example.common.dao..*.*(..)) &amp;&amp; @annotation(cacheDelete)" />
 <aop:after-returning pointcut-ref="deleteCachePointcut" method="deleteCache" returning="retVal"/>
</aop:aspect>

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface Cache {
 /**
 * 缓存的过期时间,单位:秒
 */
 int expire();
 /**
 * 自定义缓存Key,如果不设置使用系统默认生成缓存Key的方法
 * @return
 */
 String key() default "";
 
 /**
 * 是否启用自动加载缓存
 * @return
 */
 boolean autoload() default false;
 /**
 * 自动缓存的条件,可以为空,使用 SpEL 编写,返回 true 或者 false,优化级高级autoload,例如:null != #args[0].keyword,当第一个参数的keyword属性为null时设置为自动加载。
 * @return
 */
 String autoloadCondition() default "";
 /**
 * 当autoload为true时,缓存数据在 requestTimeout 秒之内没有使用了,就不进行自动加载数据,如果requestTimeout为0时,会一直自动加载
 * @return
 */
 long requestTimeout() default 36000L;
 
 /**
 * 使用SpEL,将缓存key,根据业务需要进行二次分组
 * @return
 */
 String subKeySpEL() default "";
 /**
 * 缓存的条件,可以为空,使用 SpEL 编写,返回 true 或者 false,只有为 true 才进行缓存,例如:"#args[0]==1",当第一个参数值为1时,才进缓存。
 * @return
 */
 String condition() default "";
 /**
 * 缓存的操作类型:默认是READ_WRITE,先缓存取数据,如果没有数据则从DAO中获取并写入缓存;如果是WRITE则从DAO取完数据后,写入缓存
 * @return CacheOpType
 */
 CacheOpType opType() default CacheOpType.READ_WRITE;
}

 public CollectionTO<AccountTO> getAccountByCriteria(AccountCriteriaTO criteria) {
 List<AccountTO> list=null;
 PaginationTO paging=criteria.getPaging();
 if(null != paging && paging.getPageNo() > 0 && paging.getPageSize() > 0) {// 如果需要分页查询,先查询总数
 criteria.setPaging(null);// 减少缓存KEY的变化,在查询记录总数据时,不用设置分页相关的属性值
 Integer recordCnt=accountDAO.getAccountCntByCriteria(criteria);
 if(recordCnt > 0) {
 criteria.setPaging(paging);
 paging.setRecordCnt(recordCnt);
 list=accountDAO.getAccountByCriteria(criteria);
 }
 return new CollectionTO<AccountTO>(list, recordCnt, criteria.getPaging().getPageSize());
 } else {
 list=accountDAO.getAccountByCriteria(criteria);
 return new CollectionTO<AccountTO>(list, null != list ? list.size() : 0, 0);
 }
 }

 TempDAO {
 public Object a() {
 return b().get(0);
 }
 @Cache(expire=600)
 public List<Object> b(){
 return ... ...;
 }
 }

 @Cache(expire=600, autoload=true)
 public List<AccountTO> getDistinctAccountByPlayerGet(AccountCriteriaTO criteria) {
 List<AccountTO> list;
 int count=criteria.getPaging().getThreshold() ;
 // 查预设查询数量的10倍
 criteria.getPaging().setThreshold(count * 10);
 ... ...
 }

<servlet>
 <servlet-name>cacheadmin</servlet-name>
 <servlet-class>com.jarvis.cache.admin.servlet.AdminServlet</servlet-class>
 <init-param>
 <param-name>cacheManagerNames</param-name>
 <param-value>cachePointCut</param-value>
 </init-param>
 <load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
 <servlet-name>cacheadmin</servlet-name>
 <url-pattern>/cacheadmin</url-pattern>
</servlet-mapping>

更新日志