Spring Boot+Guava Cache+@EnableCaching

本文主要是介绍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 {@Autowiredprivate GuavaProperties guavaProperties;@Beanpublic 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"})@Beanpublic 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 {@Autowiredprivate 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();}
}