快捷導(dǎo)航

Spring @Cacheable自定義緩存過期時(shí)間的實(shí)現(xiàn)示例

更新時(shí)間：2024年05月27日 11:56:27 作者：路漫修遠(yuǎn) 上下求索

本文主要介紹了Spring @Cacheable自定義緩存過期時(shí)間的實(shí)現(xiàn)示例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

實(shí)現(xiàn)效果

原來的@Cacheable使用方式：

@Cacheable(value = "userinfo", key = "#dto.userId")

實(shí)現(xiàn)后的使用方式：

@Cacheable(value = "userinfo#30#m", key = "#dto.userId")

實(shí)現(xiàn)代碼

創(chuàng)建一個(gè)自定義的緩存管理器，繼承自RedisCacheManager

public class CustomRedisCacheManager extends RedisCacheManager {
    
    public CustomRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration) {
        super(cacheWriter, defaultCacheConfiguration);
    }

    /**
     * 重寫createRedisCache方法
     * @param name 原來的name只是作為redis存儲(chǔ)鍵名
     *             重寫的name可通過"#"拼接過期時(shí)間：
     *             1. 如果沒有"#"則默認(rèn)不設(shè)置過期時(shí)間
     *             2. 拼接的第一個(gè)"#"后面為過期時(shí)間，第二個(gè)"#"后面為時(shí)間單位
     *             3. 時(shí)間單位的表示使用: d(天)、h(小時(shí))、m(分鐘)、s(秒), 默認(rèn)為h(小時(shí))
     * @param cacheConfig
     * @return
     */
    @Override
    protected RedisCache createRedisCache(String name, RedisCacheConfiguration cacheConfig) {
        // 解析name,設(shè)置過期時(shí)間
        if (StringUtils.isNotEmpty(name) && name.contains("#")) {
            String[] split = name.split("#");

            // 緩存鍵名
            String cacheName = split[0];
            // "#"后第一位是時(shí)間
            int expire = Integer.parseInt(split[1]);
            // 過期時(shí)間，默認(rèn)為h(小時(shí))
            Duration duration = Duration.ofHours(expire);
            // 根據(jù)"#"后第二位字符判斷過期時(shí)間的單位，設(shè)置相應(yīng)的過期時(shí)間，默認(rèn)時(shí)間單位是h(小時(shí))
            if (split.length == 3) {
                switch (split[2]){
                    case "d":
                        duration = Duration.ofDays(expire);
                        break;
                    case "m":
                        duration = Duration.ofMinutes(expire);
                        break;
                    case "s":
                        duration = Duration.ofSeconds(expire);
                        break;
                    default:
                        duration = Duration.ofHours(expire);
                }
            }
            return super.createRedisCache(cacheName, cacheConfig.entryTtl(duration));
        }
        return super.createRedisCache(name, cacheConfig);
    }
}

在redis配置類中，將上面自定義的緩存管理器注冊(cè)為Bean

@Configuration
@EnableCaching
public class RedisConfig {
    
    /**
     * 自定義RedisTemplate
     * 設(shè)置Redis序列化方式，默認(rèn)使用的是JDKSerializer的序列化方式，效率低，所以這里設(shè)置使用FastJsonRedisSerializer
     * @param connectionFactory
     * @return
     */
    @Bean
    @SuppressWarnings(value = {"unchecked", "rawtypes"})
    public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory connectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();

        // 設(shè)置redis連接（LettuceConnectionFactory實(shí)現(xiàn)了RedisConnectionFactory）
        redisTemplate.setConnectionFactory(connectionFactory);

        FastJsonRedisSerializer serializer = new FastJsonRedisSerializer(Object.class);

        // key設(shè)置StringRedisSerializer序列化
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        // value設(shè)置FastJsonRedisSerializer序列化
        redisTemplate.setValueSerializer(serializer);

        // Hash key設(shè)置序列化
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        // Hash value設(shè)置序列化
        redisTemplate.setHashValueSerializer(serializer);

        return redisTemplate;
    }


    /**
     * 實(shí)例化自定義的緩存管理器
     * @param redisTemplate
     * @return
     */
    @Bean
    @SuppressWarnings(value = {"unchecked", "rawtypes"})
    public RedisCacheManager redisCacheManager(RedisTemplate redisTemplate) {
        RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(Objects.requireNonNull(redisTemplate.getConnectionFactory()));
        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisTemplate.getValueSerializer()));
        return new CustomRedisCacheManager(redisCacheWriter, redisCacheConfiguration);
    }
}

到此這篇關(guān)于Spring @Cacheable自定義緩存過期時(shí)間的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)Spring @Cacheable緩存過期時(shí)間內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: