Spring Boot+Guava Cache+@EnableCaching

Spring Boot集成Guava Cache并配合@EnableCaching注解管理本地缓存

依赖

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>23.6-jre</version>
</dependency>

Guava缓存集成

GuavaCacheConfig：

@EnableConfigurationProperties(GuavaProperties.class)
@EnableCaching
@Configuration
public class GuavaCacheConfig {

@Autowired
private GuavaProperties guavaProperties;

@Bean
public CacheBuilder<Object, Object> cacheBuilder() {
long maximumSize = guavaProperties.getMaximumSize();
long duration = guavaProperties.getExpireAfterAccessDuration();
if (maximumSize <= 0) {
maximumSize = 1024;
}
if (duration <= 0) {
duration = 1800;
}
return CacheBuilder.newBuilder()
.maximumSize(maximumSize)
.expireAfterAccess(duration, TimeUnit.SECONDS);
}

/**
* expireAfterAccess: 当缓存项在指定的时间段内没有被读或写就会被回收。
* expireAfterWrite：当缓存项在指定的时间段内没有更新就会被回收,如果我们认为缓存数据在一段时间后数据不再可用，那么可以使用该种策略。
* refreshAfterWrite：当缓存项上一次更新操作之后的多久会被刷新。
* @return
*/
@DependsOn({"cacheBuilder"})
@Bean
public CacheManager cacheManager(CacheBuilder<Object, Object> cacheBuilder) {
GuavaCacheManager cacheManager = new GuavaCacheManager();
cacheManager.setCacheBuilder(cacheBuilder);
return cacheManager;
}

}

GuavaProperties：

@ConfigurationProperties(prefix = "guava.cache.config")
public class GuavaProperties {

private long maximumSize;

private long maximumWeight;

private long expireAfterWriteDuration;

private long expireAfterAccessDuration;

private long refreshDuration;

private int initialCapacity;

private int concurrencyLevel;

// get/set忽略
}

为了方便测试设置缓存过期时间为10秒

application.properties:

server.port=8081
guava.cache.config.expire-after-access-duration=10

缓存测试

CacheService：

@Service
public class CacheService {
@CachePut(value = "guavacache")
public long save() {
long timestamp = new Timestamp(System.currentTimeMillis()).getTime();
System.out.println("进行缓存：" + timestamp);
return timestamp;
}

@CacheEvict(value = "guavacache")
public void delete() {
System.out.println("删除缓存");
}

@Cacheable(value = "guavacache")
public long getByCache() {
try {
Thread.sleep(3 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return new Timestamp(System.currentTimeMillis()).getTime();
}
}

CacheController：

@RestController
@RequestMapping("/cache")
public class CacheController {
@Autowired
private CacheService cacheService;

/**
* 查询方法
*/
@RequestMapping(value = "", method = RequestMethod.GET)
public String getByCache() {
Long startTime = System.currentTimeMillis();
long timestamp = this.cacheService.getByCache();
Long endTime = System.currentTimeMillis();
System.out.println("耗时: " + (endTime - startTime));
return timestamp+"ms";
}

/**
* 保存方法
*/
@RequestMapping(value = "", method = RequestMethod.POST)
public void save() {
this.cacheService.save();
}

/**
* 删除方法
*/
@RequestMapping(value = "", method = RequestMethod.DELETE)
public void delete() {
this.cacheService.delete();
}
}

get方法访问localhost:8081/cache/，控制台输出：

耗时: 3007ms

在10s内访问，输出：

耗时: 1ms

说明，getByCache方法直接从缓存获取结果，线程没有执行到sleep方法，缓存成功。

其它方法可自行测试。

源码地址：

https://gitee.com/yidasanqian/spring-boot-guava-cache-demo.git