动态设置缓存expireAfterWrite属性- Caffeine和Spring WebFlux

动态设置缓存`expireAfterWrite`属性 - Caffeine和Spring WebFlux

基础概念

Caffeine 是一个高性能的Java缓存库，提供了多种缓存策略，包括基于时间的过期策略（如expireAfterWrite）。expireAfterWrite属性指定了缓存项在写入后经过指定时间将被视为过期。

Spring WebFlux 是Spring框架的一部分，用于构建响应式Web应用程序。它支持非阻塞I/O操作，适用于高并发场景。

类型与应用场景

固定时间过期：适用于数据变化不频繁且对实时性要求不高的场景。
动态时间过期：根据业务逻辑动态调整过期时间，适用于数据变化频繁或对实时性有一定要求的场景。

示例代码

以下是一个使用Caffeine和Spring WebFlux动态设置expireAfterWrite属性的示例：

import com.github.benmanes.caffeine.cache.Caffeine;
import org.springframework.cache.CacheManager;
import org.springframework.cache.caffeine.CaffeineCacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.ServerResponse;

import java.util.concurrent.TimeUnit;

@Configuration
public class CacheConfig {

    @Bean
    public CacheManager cacheManager() {
        CaffeineCacheManager cacheManager = new CaffeineCacheManager("items");
        cacheManager.setCaffeine(caffeineCacheBuilder());
        return cacheManager;
    }

    Caffeine<Object, Object> caffeineCacheBuilder() {
        return Caffeine.newBuilder()
                .expireAfterWrite(10, TimeUnit.MINUTES); // 默认过期时间
    }

    @Bean
    public RouterFunction<ServerResponse> routes() {
        return RouterFunctions.route(RequestPredicates.GET("/item/{id}"), request -> {
            String id = request.pathVariable("id");
            // 动态设置过期时间
            long dynamicExpireTime = getDynamicExpireTime(id);
            caffeineCacheBuilder().expireAfterWrite(dynamicExpireTime, TimeUnit.MINUTES);
            // 从缓存或数据库获取数据
            Item item = getItemFromCacheOrDb(id);
            return ServerResponse.ok().bodyValue(item);
        });
    }

    private long getDynamicExpireTime(String id) {
        // 根据业务逻辑动态计算过期时间
        // 例如：根据item的类型或其他属性来决定
        return 5; // 示例：5分钟
    }

    private Item getItemFromCacheOrDb(String id) {
        // 实现从缓存或数据库获取数据的逻辑
        return new Item(); // 示例返回
    }
}

遇到的问题及解决方法

问题：动态设置expireAfterWrite属性时，缓存策略没有按预期生效。

原因：

缓存构建器未重新应用：在运行时修改缓存构建器的属性不会影响已经创建的缓存实例。
缓存管理器未刷新：缓存管理器可能没有正确地重新加载缓存配置。

解决方法：

重新创建缓存实例：在每次请求时重新创建缓存实例，并应用新的过期时间。
使用缓存注解：结合Spring的缓存注解（如@Cacheable），在方法级别动态设置过期时间。

import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

@Service
public class ItemService {

    @Cacheable(value = "items", key = "#id", unless = "#result == null")
    public Item getItem(String id) {
        long dynamicExpireTime = getDynamicExpireTime(id);
        // 动态设置过期时间
        caffeineCacheBuilder().expireAfterWrite(dynamicExpireTime, TimeUnit.MINUTES);
        // 从数据库获取数据
        return getItemFromDb(id);
    }

    private long getDynamicExpireTime(String id) {
        // 根据业务逻辑动态计算过期时间
        return 5; // 示例：5分钟
    }

    private Item getItemFromDb(String id) {
        // 实现从数据库获取数据的逻辑
        return new Item(); // 示例返回
    }
}

通过上述方法，可以确保动态设置的expireAfterWrite属性在缓存中正确生效。