1.pom文件中配置
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>4.2.4.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>4.2.4.RELEASE</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>19.0</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.16.20</version>
</dependency>
</dependencies>
2.GuavaCacheManagerConfig配置类
package com.zy; import com.google.common.cache.CacheBuilder;
import com.google.common.collect.Maps;
import org.springframework.cache.Cache;
import org.springframework.cache.guava.GuavaCache;
import org.springframework.cache.transaction.AbstractTransactionSupportingCacheManager; import java.util.Collection;
import java.util.Map;
import java.util.concurrent.ConcurrentMap; public class GuavaCacheManagerConfig extends AbstractTransactionSupportingCacheManager { private final ConcurrentMap<String, Cache> cacheMap = Maps.newConcurrentMap();
private Map<String, CacheBuilder> builderMap = Maps.newHashMap(); @Override
protected Collection<? extends Cache> loadCaches() {
return cacheMap.values();
} //获取缓存单例
@Override
public Cache getCache(String name) {
Cache cache = this.cacheMap.get(name);
if (null == cache) {
synchronized (this.cacheMap) {
cache = this.cacheMap.get(name);
if (null == cache && this.builderMap.containsKey(name)) {
CacheBuilder builder = this.builderMap.get(name);
cache = createGuavaCache(name, builder);
this.cacheMap.put(name, cache);
}
}
}
return cache;
} private Cache createGuavaCache(String name, CacheBuilder builder) {
com.google.common.cache.Cache<Object, Object> cache;
if(builder == null){
cache = CacheBuilder.newBuilder().build();
}else{
cache = builder.build();
}
return new GuavaCache(name, cache, isAllowNullValues());
} private boolean isAllowNullValues() {
return true;
} //配置中多组缓存池注入
public void setConfigMap(Map<String, CacheBuilder> configMap) {
this.builderMap = configMap;
}
}
3.applicationContext-cache-guava.xml配置文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:cache="http://www.springframework.org/schema/cache"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/cache
http://www.springframework.org/schema/cache/spring-cache.xsd"> <!-- 1.将需要加入缓存的类注册进来 -->
<bean id="guavaService" class="com.zy.GuavaServiceImpl"/> <!-- ==========================2.开启guava缓存开始==================== -->
<!-- 声明缓存注解的开启 -->
<cache:annotation-driven cache-manager="cacheManager" proxy-target-class="true"/>
<!-- 声明使用spring管理缓存组 -->
<bean id="cacheManager" class="org.springframework.cache.support.CompositeCacheManager">
<property name="cacheManagers">
<list>
<ref bean="guavaCacheManager"/>
</list>
</property>
<property name="fallbackToNoOpCache" value="true"/>
</bean>
<!-- 缓存的创建的具体实现类注入 class为自定义的类 -->
<bean id="guavaCacheManager" class="com.zy.GuavaCacheManagerConfig">
<!-- 此处可以配置一组缓存池对应不同的业务类型 这里实现了一个"guava"的默认缓存并构建 -->
<property name="configMap">
<map key-type="java.lang.String" value-type="com.google.common.cache.CacheBuilder">
<!-- 该缓存与service层实现类上注解上的value相等 -->
<entry key="guava" value-ref="defaultCacheBuilder"/>
</map>
</property>
</bean> <!-- 此处直接构建"guava"默认缓存 -->
<bean id="defaultCacheBuilder"
class="com.google.common.cache.CacheBuilder"
factory-method="from">
<!-- 缓存池大小 时间(定时回收 缓存项在给定时间内没有被'写'访问 回收 还有refreshAfterWrite expireAfterAccess可供使用) 当然还有一些其他可选组件(weakKeys,removalListener and so on!) -->
<constructor-arg value="maximumSize=10000, expireAfterAccess=5s"/>
</bean>
<!-- ==========================2.开启guava缓存结束==================== --> </beans>
4.GuavaDTO
package com.zy; import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor; @Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class GuavaDTO { private Integer id; private String name; }
5.GuavaServiceImpl的实现类
package com.zy; import org.springframework.cache.annotation.Cacheable;
public class GuavaServiceImpl {
// spring EL
// GuavaDTO 普通的DTO
// @Cacheable(value = "guava", key = "'testGuavaCache:' + #guavaDTO.id + #guavaDTO.name")
// value 为配置文件中的缓存池名称 key 为键名
@Cacheable(value = "guava", key = "'testGuavaCache:' + #guavaDTO.id + #guavaDTO.name")
public void testGuavaCache(GuavaDTO guavaDTO) {
System.out.println("=======缓存中没有,进入方法来查询了=========");
} }
如果service的实现类是删除方法,则在方法上,加上@CacheEvict注解
如果service的实现类是更新方法,则在方法上,加上@CachePut注解(每次执行,都会进入方法)
6.测试类GuavaTest
package com.zy; import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext; public class GuavaTest { @Test
public void fn() throws InterruptedException {
ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext-cache-guava.xml");
GuavaServiceImpl guavaService = (GuavaServiceImpl) applicationContext.getBean("guavaService");
System.out.println("第1次访问:1号tom==========================");
guavaService.testGuavaCache(new GuavaDTO(1, "tom"));
System.out.println("第2次访问:1号tom==========================");
guavaService.testGuavaCache(new GuavaDTO(1, "tom"));
guavaService.testGuavaCache(new GuavaDTO(1, "tom"));
System.out.println("第1次访问:2号jerry==========================");
guavaService.testGuavaCache(new GuavaDTO(2, "jerry"));
Thread.sleep(5000);
/**
* 此时配置文件中的失效时间是5000ms
* */
System.out.println("第3次访问:1号tom==========================");
guavaService.testGuavaCache(new GuavaDTO(1, "tom")); }
}
7.测试结果如下: