如何使用Spring Cache實現(xiàn)多級緩存
Spring Cache可以通過配置多級緩存來達(dá)到一級緩存查詢Caffeine,Caffeine查詢不到查詢Redis緩存,Redis查詢不到查詢數(shù)據(jù)庫的效果。需要在Spring配置文件中配置多個CacheManager,并將其分別配置為不同的緩存源,例如Caffeine和Redis,然后使用組合模式將它們結(jié)合起來。
1.首先,需要在pom.xml文件中添加以下依賴:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<dependency>
<groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2.Caffeine和Redis的CacheManager
@Configuration
@EnableCaching
public class CacheConfig {
@Value("${cache.caffeine.maximumSize}")
private int maximumSize;
@Value("${cache.caffeine.expireAfterWriteSeconds}")
private int expireAfterWriteSeconds;
@Value("${cache.redis.time-to-live-seconds}")
private long redisTimeToLiveSeconds;
@Bean
public CaffeineCacheManager caffeineCacheManager() {
CaffeineCacheManager cacheManager = new CaffeineCacheManager();
cacheManager.setCaffeine(caffeineCacheBuilder());
return cacheManager;
}
@Bean
public RedisCacheManager redisCacheManager(RedisConnectionFactory redisConnectionFactory) {
RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
.entryTtl(Duration.ofSeconds(redisTimeToLiveSeconds));
return RedisCacheManager.builder(redisConnectionFactory)
.cacheDefaults(redisCacheConfiguration)
.build();
}
private Caffeine<Object, Object> caffeineCacheBuilder() {
return Caffeine.newBuilder()
.expireAfterWrite(expireAfterWriteSeconds, TimeUnit.SECONDS)
.maximumSize(maximumSize);
}
}
3.將Caffeine和Redis的CacheManager結(jié)合起來
@Configuration
public class CacheConfig {
...
@Bean
public CompositeCacheManager compositeCacheManager(CaffeineCacheManager caffeineCacheManager,
RedisCacheManager redisCacheManager) {
CompositeCacheManager compositeCacheManager = new CompositeCacheManager();
compositeCacheManager.setCacheManagers(Arrays.asList(caffeineCacheManager, redisCacheManager));
compositeCacheManager.setFallbackToNoOpCache(false); // 關(guān)閉緩存未命中時自動創(chuàng)建的空緩存
return compositeCacheManager;
}
...
}
如上 Arrays.asList(caffeineCacheManager, redisCacheManager) 中caffeineCacheManager放在前面,即先查詢caffeineCacheManager緩存,未命中則查詢redisCacheManager。順序很重要,別搞錯!
4.使用多級緩存
在需要緩存的方法上添加@Cacheable注解,并指定緩存名稱
@Service
public class UserServiceImpl implements UserService {
@Autowired
private UserRepository userRepository;
@Override
@Cacheable(value = {"userCache"})
public User getUserById(Long id) {
return userRepository.findById(id).orElse(null);
}
...
}
5.在application.properties文件中配置緩存參數(shù)
cache.caffeine.maximumSize=1000
cache.caffeine.expireAfterWriteSeconds=300
cache.redis.time-to-live-seconds=600
通過如上5個步驟即可實現(xiàn)多級緩存。
在Redis單獨作為緩存性能都無法滿足時,可以使用多級緩存。