如何使用Spring Cache實現多級緩存

作者：迷路的架構師 2023-05-05 18:38:33

Spring Cache可以通過配置多級緩存來達到一級緩存查詢Caffeine，Caffeine查詢不到查詢Redis緩存，Redis查詢不到查詢數據庫的效果。需要在Spring配置文件中配置多個CacheManager，并將其分別配置為不同的緩存源，例如Caffeine和Redis，然后使用組合模式將它們結合起來。

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結合起來

@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); // 關閉緩存未命中時自動創建的空緩存
        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文件中配置緩存參數

cache.caffeine.maximumSize=1000
cache.caffeine.expireAfterWriteSeconds=300
cache.redis.time-to-live-seconds=600

通過如上5個步驟即可實現多級緩存。

在Redis單獨作為緩存性能都無法滿足時，可以使用多級緩存。

責任編輯：華軒來源：今日頭條