【springboot整合】Springboot和RedisCache

news2024/10/7 16:22:01

前面介绍了CacheAutoConfiguration默认生效的是SimpleCacheConfiguration配置类,实际中我们更多的是利用redis作为缓存,现在我们继续看看RedisCacheConfiguration有什么不同

原理分析

  1. 在引入redis相关依赖之后,对应的RedisCacheConfiguration配置类就生效了。因为RedisCacheConfiguration的加载顺序在SimpleCacheConfiguration前面,所以RedisCacheConfiguration配置会先生效
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(RedisConnectionFactory.class)
@AutoConfigureAfter(RedisAutoConfiguration.class)
@ConditionalOnBean(RedisConnectionFactory.class)
@ConditionalOnMissingBean(CacheManager.class)
@Conditional(CacheCondition.class)
class RedisCacheConfiguration {
}
  1. 在RedisCacheConfiguration配置类中,帮我们向容器注入了一个RedisCacheManager的redis类型的缓存管理器
class RedisCacheConfiguration {
    // 向容器注入RedisCacheManager缓存管理器,通过缓存管理器管理RedisCache缓存组件
    @Bean
    RedisCacheManager cacheManager(CacheProperties cacheProperties, CacheManagerCustomizers cacheManagerCustomizers,
                                   ObjectProvider<org.springframework.data.redis.cache.RedisCacheConfiguration> redisCacheConfiguration,
                                   ObjectProvider<RedisCacheManagerBuilderCustomizer> redisCacheManagerBuilderCustomizers,
                                   RedisConnectionFactory redisConnectionFactory, ResourceLoader resourceLoader) {
        RedisCacheManagerBuilder builder = RedisCacheManager.builder(redisConnectionFactory).cacheDefaults(
                determineConfiguration(cacheProperties, redisCacheConfiguration, resourceLoader.getClassLoader()));
        List<String> cacheNames = cacheProperties.getCacheNames();
        if (!cacheNames.isEmpty()) {
            builder.initialCacheNames(new LinkedHashSet<>(cacheNames));
        }
        redisCacheManagerBuilderCustomizers.orderedStream().forEach((customizer) -> customizer.customize(builder));
        return cacheManagerCustomizers.customize(builder.build());
    }
}
  1. 在RedisCacheManager中会加载初始化缓存组件,如果存在会循环创建RedisCache组件
public class RedisCacheManager extends AbstractTransactionSupportingCacheManager {
    /**
     * 加载缓存组件
     */
    @Override
    protected Collection<RedisCache> loadCaches() {

        List<RedisCache> caches = new LinkedList<>();

        for (Map.Entry<String, RedisCacheConfiguration> entry : initialCacheConfiguration.entrySet()) {
            caches.add(createRedisCache(entry.getKey(), entry.getValue()));
        }

        return caches;
    }

    /**
     * 创建RedisCache缓存组件
     */
    protected RedisCache createRedisCache(String name, @Nullable RedisCacheConfiguration cacheConfig) {
        return new RedisCache(name, cacheWriter, cacheConfig != null ? cacheConfig : defaultCacheConfig);
    }
}
  1. 在RedisCacheManager缓存管理器中来对redis缓存组件(RedisCache)进行操作
public class RedisCache extends AbstractValueAdaptingCache {
    /**
     * 查找缓存
     * @param key
     * @return
     */
    @Override
    protected Object lookup(Object key) {
        // createAndConvertCacheKey会进行序列化key,如果有使用前缀,也是在这里面拼接的 cacheConfig.getKeyPrefixFor(name) + key;
        byte[] value = cacheWriter.get(name, createAndConvertCacheKey(key));

        if (value == null) {
            return null;
        }
        // 序列化value
        return deserializeCacheValue(value);
    }

    /**
     * 更新缓存
     * @param key
     * @param value
     */
    @Override
    public void put(Object key, @Nullable Object value) {

        Object cacheValue = preProcessCacheValue(value);

        if (!isAllowNullValues() && cacheValue == null) {

            throw new IllegalArgumentException(String.format(
                    "Cache '%s' does not allow 'null' values. Avoid storing null via '@Cacheable(unless=\"#result == null\")' or configure RedisCache to allow 'null' via RedisCacheConfiguration.",
                    name));
        }

        cacheWriter.put(name, createAndConvertCacheKey(key), serializeCacheValue(cacheValue), cacheConfig.getTtl());
    }

    /**
     * 按key清除某个缓存
     * @param key
     */
    @Override
    public void evict(Object key) {
        cacheWriter.remove(name, createAndConvertCacheKey(key));
    }
} 

需要注意的点

  1. 存储对象需要序列化
    在这里插入图片描述

  2. 默认使用jdk的序列化规则,如需使用json需自定义配置类
    [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-314zgIG6-1687588519651)(src/main/resources/image/jdk序列化.png)]

@Configuration
public class MyRedisConfig {

    @Bean
    RedisCacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
        Jackson2JsonRedisSerializer<Student> serializer = new Jackson2JsonRedisSerializer<>(Student.class);
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        serializer.setObjectMapper(objectMapper);
        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(Duration.ofDays(1))
                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(stringRedisSerializer))
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(serializer))
                .disableCachingNullValues();

        return RedisCacheManager.builder(redisConnectionFactory).cacheDefaults(config).build();
    }
}

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-KWU3UC2x-1687588519651)(src/main/resources/image/json序列化.png)]
gitee代码示例

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/694596.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

基于BS架构的汽车销售管理系统(源码+文档+报告+安装环境)

如今&#xff0c;越来越多的人愿意选择一种适合自己的管理方案&#xff0c;随着线上管理系统的快速兴起&#xff0c;大量的车辆信息被人们所熟知&#xff0c;而4S店车辆管理系统无疑是对4S店车辆进行管理的最好的系统。4S店车辆系统&#xff0c;为用户提供了一种可以让他们更好…

(16)燃油流量和液位传感器

文章目录 前言 16.1 燃油流量传感器 16.1.1 连接到自动驾驶仪 16.2 燃油液位传感器 16.2.1 PWM油位传感器 16.2.2 模拟油位传感器 前言 在 4.0 及以后的固件版本中&#xff0c;ArduPilot 提供了使用燃油流量和液位传感器的能力&#xff0c;此外还有电池监控器。支持脉冲输…

MongoDB复制集原理

复制集简介 Mongodb复制集由一组Mongod实例&#xff08;进程&#xff09;组成&#xff0c;包含一个Primary节点和多个Secondary节点&#xff0c;Mongodb Driver&#xff08;客户端&#xff09;的所有数据都写入Primary&#xff0c;Secondary从Primary同步写入的数据&#xff0…

Flink-窗口源码

滚动窗口底层只有一个窗口&#xff0c;每次用for循环&#xff0c;把前面过期的数据移除&#xff0c;留下的数据再进行计算 滑动窗口的时间窗口&#xff0c;是有多个window的&#xff0c;因为有重叠的数据 计数窗口、计数滑动窗口&#xff0c;底层只有一个窗口 会话窗口只有一…

视频融合平台EasyCVR电子地图增加鼠标悬停展示经纬度

EasyCVR可拓展性强、视频能力灵活、部署轻快&#xff0c;可支持的主流标准协议有GB28181、RTSP/Onvif、RTMP等&#xff0c;以及厂家私有协议与SDK接入&#xff0c;包括海康Ehome、海大宇等设备的SDK等&#xff0c;能对外分发RTSP、RTMP、FLV、HLS、WebRTC等格式的视频流。平台可…

结合底层源码介绍ConcurrentHashMap如何保证线程安全,佬会爱上这篇文章嘛

前言&#xff1a; 本篇文章主要讲解结合底层源码介绍ConcurrentHashMap如何保证线程安全的知识。该专栏比较适合刚入坑Java的小白以及准备秋招的大佬阅读。 如果文章有什么需要改进的地方欢迎大佬提出&#xff0c;对大佬有帮助希望可以支持下哦~ 小威在此先感谢各位小伙伴儿了…

周鸿祎晒出清华大学研究生录取通知书:终于考上了

周鸿祎晒出清华大学研究生录取通知书 IT之家获悉&#xff0c;近日&#xff0c;360公司创始人、董事长周鸿祎在微博上晒出了自己的清华大学研究生录取通知书&#xff0c;并称&#xff1a;“终于考上了&#xff0c;感谢360智脑的老师们&#xff0c;希望360智脑能帮助我顺利毕业&a…

【Python笔记】之-bash: python: command not found

问题&#xff1a; 在服务器环境&#xff0c;使用python命令时提示&#xff1a;-bash: python: command not found 查看服务器python版本&#xff0c;一般是在/usr/bin目录下&#xff0c;在终端输入命令如下&#xff1a; find /usr/bin -iname python*得到输出&#xff1a; …

C# OpenCvSharp 图像校正

效果 Demo下载 代码 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using OpenCvSharp; using OpenCvSharp.Extensions;nam…

解决在IDEA中Ctrl+Y快捷键失效问题

之前我们一般使用CtrlY的方式删除当前行&#xff0c;但是有的时候这个快捷键就会被其他软件占用&#xff0c;就需要我们重新配置一下&#xff1a; 1、点击IDEA中的设置 2、点击Keymap—>Editor Actions 3、往下翻&#xff0c;双击Delete Line&#xff0c;再点击Add Keyboar…

【Opencv】PIL Opencv 向图片写入文字并旋转文字,Opencv图片旋转不截断,Opencv图片旋转不裁剪

文章目录 失真Pillow的实现Opencv的实现不裁剪的旋转图像旋转文字并贴图 失真 刚性变换&#xff1a; 只有物体的位置(平移变换)和朝向(旋转变换)发生改变&#xff0c;而形状不变&#xff0c;得到的变换称为刚性变换。刚性变换是最一般的变换。 使用透视变换&#xff0c;文字会…

Multi-Query Attention 阅读笔记

《Fast Transformer Decoding: One Write-Head is All You Need》 核心贡献&#xff1a;优化 multi-head attention 为文中命名的 multi-query attention&#xff0c;减少多head相关运算&#xff0c;不降低精度 且 大幅提升解码速度。 具体对比如下&#xff1a; multi-head a…

win下编译ycm报错 “could not find any instance of Visual Studio” 解决办法

ycm-core/YouCompleteMe: A code-completion engine for Vim 是一款vim插件&#xff0c;可为不同的代码类型提供语义级别的补全能力。 问题描述 通过vim-plug插件管理器安装ycm后&#xff0c;还需对进入其插件目录~\vimfiles\plugged\YouCompleteMe 进行编译python .\install…

分类预测 | MATLAB实现GA-LSTM遗传算法优化长短期记忆网络的数据多输入分类预测

分类预测 | MATLAB实现GA-LSTM遗传算法优化长短期记忆网络的数据多输入分类预测 目录 分类预测 | MATLAB实现GA-LSTM遗传算法优化长短期记忆网络的数据多输入分类预测效果一览基本介绍程序设计参考资料 效果一览 基本介绍 MATLAB实现GA-LSTM遗传算法优化长短期记忆网络的数据多…

DS18B20-STM32温度读取

command data 高地位组合即为温度数据 1. 初始化时钟 void Init_DS18B20(void) {char CY 1;while (CY){DQ_OUT();DQ_SET_H(); delay_us(20); DQ_SET_L(); //送出低电平复位信号delay_us(360); //延时至少480usdelay_us(240);DQ_SET_H(); …

忆联携手中国移动,企业级NVME SSD评测及生态推进计划发布仪式圆满成功

6月27日&#xff0c;中国信通院、中国移动和中国电信在ODCC 2023夏季全会上发布了“企业级NVME SSD评测及生态推进计划”&#xff08;以下简称“推进计划”&#xff09;&#xff0c;忆联作为中国移动重要的合作伙伴受邀出席该“推进计划”成立仪式环节&#xff0c;与中国信通院…

vue watch监听不生效,解决办法

1、在data里定义监听的属性&#xff0c;解决问题 2、使用深度监听

(0day通用)中庆纳博某系统敏感信息泄露+未授权修改密码

申明&#xff1a;本次测试只作为学习用处&#xff0c;请勿未授权进行渗透测试&#xff0c;切勿用于其它用途&#xff01; 1.漏洞背景 北京中庆纳博信息技术有限公司&#xff0c;简称中庆纳博&#xff0c;是有20年历史的中庆集团旗下核心企业&#xff0c;专注于教育信息化的深度…

UDP SocketAPI

1、TCP与UDP区别 TCP&#xff1a;有连接&#xff0c;可靠传输&#xff0c;面向字节流&#xff0c;全双工 UDP&#xff1a;无连接&#xff0c;不可靠传输&#xff0c;面向数据报&#xff0c;全双工 2、UDP sockeAPI的核心类 DatagramSocket&#xff1a;相当于对socket文件进…