Spring Cache 整合 Redis 做缓存使用~ 快速上手~

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 Tair(兼容Redis),内存型 2GB
简介: Spring Cache 整合 Redis 做缓存使用~ 快速上手~

前三篇文章说了那么那么多,但是我们在使用缓存的场景中,大都数还是会采用了类似 Spring Cache 的缓存管理器来做,说原因其实也没啥,因为项目中并不是所有的业务对数据有那么强的数据一致性。

前三篇:

聊一聊缓存和数据库不一致性问题的产生及主流解决方案以及扩展的思考

用万字长文来讲讲本地锁至分布式锁的演进和Redis实现,扩展:Redlock 红锁

周四埋下的坑,周五来恶补!! Redisson 加锁、锁自动续期、解锁源码分析

Spring Cache 正好可以帮我们减轻开发负担,一个注解就搞定,不用自己去编程式操作。

Spring Cache 介绍

看到Spring就知道这是Spring生态中的东西,其实缓存数据的技术并不少,Spring 官方此举是引入 Spring Cache 来帮我们管理缓存,使用注解,简化很多操作。

当然使用 Spring Cache 也有优缺点的.

优点

  • 使用注解,简化操作
  • 缓存管理器,方便多种实现切换缓存源,如Redis,Guava Cache等
  • 支持事务, 即事物回滚时,缓存同时自动回滚

缺点

  • 不支持TTL,不能为每个 key 设置单独过期时间 expires time
  • 针对多线程没有专门的处理,所以当多线程时,是会产生数据不一致性的。(同样,一般有高并发操作的缓存数据,都会特殊处理,而不太使用这种方式)

Spring Cache 快速上手

不想那么多,先快速上个手,再接着详细说一说。

SpringBoot 常规步骤:

  • 导入依赖
  • 修改配置文件(这一步也可以直接写在第三步)
  • 编写xxxxConfig 或者是Enablexxxx

前期准备

这也一样的,另外我这里使用的是 Spring Cache 整合 Redis 做缓存。

 <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-cache</artifactId>
 </dependency>
 <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-data-redis</artifactId>
 </dependency>

一般看到是spring-boot-starter开头的依赖,都可以大胆猜测他们是有一个xxxProperties配置类与之对应的。

修改配置文件:

 spring:
   redis:
     host: xxxxx
     password: xxxx
   #指定缓存类型
   cache:
    type: redis
   #指定存活时间(ms)
    redis.time-to-live: 86400000
   #是否缓存空值,可以防止缓存穿透
    redis.cache-null-values: true

与之对应的配置类,大伙可以自己去看看,能配置些啥image.png另外,在这里进行配置的,在我们的编写xxxConfig类的时候,也同样可以在那里配置。

因为也要配置Redis的配置,就把之前文章里面的东西都粘贴过来了~

 /**
  * @description:
  * @author: Ning Zaichun
  * @date: 2022年10月22日 23:21
  */
 @EnableConfigurationProperties(CacheProperties.class)
 @EnableCaching
 @Configuration
 public class MyRedisConfig {
 ​
     private final Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer(Object.class);
      {
         ObjectMapper objectMapper = new ObjectMapper();
         objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
         objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
         serializer.setObjectMapper(objectMapper);
     }
     /**
      * 1.原来的配置类形式
      * @ConfigurationProperties(prefix = "spring.cache")
      * public class CacheProperties {
      * 因为这个并没有放到容器中,所以要让他生效 @EnableConfigurationProperties(CacheProperties.class)
      * 因为这个和配置文件已经绑定生效了
      * @return
      */
     @Bean
     RedisCacheConfiguration redisCacheConfiguration(CacheProperties CacheProperties) {
         RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig();
         //因为key的序列化默认就是 StringRedisSerializer
 //        config = config.serializeKeysWith(RedisSerializationContext
 //                .SerializationPair
 //                .fromSerializer(new StringRedisSerializer()));
 ​
         config = config.serializeValuesWith(RedisSerializationContext
                 .SerializationPair
                 .fromSerializer(serializer));
 ​
         CacheProperties.Redis redisProperties = CacheProperties.getRedis();
         if (redisProperties.getTimeToLive() != null) {
             config = config.entryTtl(redisProperties.getTimeToLive());
         }
         if (!redisProperties.isCacheNullValues()) {
             config = config.disableCachingNullValues();
         }
         if (!redisProperties.isUseKeyPrefix()) {
             config = config.disableKeyPrefix();
         }
         return config;
     }
 ​
     @Bean
     public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
         RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
 ​
         //设置value 值的序列化
         redisTemplate.setValueSerializer(serializer);
         //key的序列化
         redisTemplate.setKeySerializer(new StringRedisSerializer());
 ​
         // set hash  hashkey 值的序列化
         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
         // set hash value 值的序列化
         redisTemplate.setHashValueSerializer(serializer);
 ​
         redisTemplate.setConnectionFactory(redisConnectionFactory);
         redisTemplate.afterPropertiesSet();
         return redisTemplate;
     }
 ​
     @Bean
     public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
         return new StringRedisTemplate(redisConnectionFactory);
     }
 }

前期准备结束,直接上手使用~

开始使用

controller-- service--mapper 一路到底,我这里是连接了数据库,只是测试的话,直接在service 的返回结果中存一串字符串即可。

 /**
  * @description:
  * @author: Ning Zaichun
  * @date: 2022年09月06日 22:16
  */
 @RestController
 @RequestMapping("/cache")
 @RequiredArgsConstructor
 public class CacheController {
 ​
     private final IUseSpringCache useSpringCache;
 ​
     @GetMapping("/test")
     public String getTest() {
         return useSpringCache.getTest();
     }
 ​
 ​
     @GetMapping("/test2")
     public String getTest2() {
         return useSpringCache.getTest2();
     }
 ​
 ​
     @GetMapping("/test/clear")
     public String clearTest() {
         useSpringCache.clearTest();
         return "clearTest";
     }
 ​
     @GetMapping
     public List<MenuEntity> getMenuList() {
         return useSpringCache.getMenuList();
     }
 ​
     @GetMapping("/clear")
     public String updateMenu() {
         MenuEntity menuEntity = new MenuEntity();
         menuEntity.setCatId(33L);
         menuEntity.setName("其他测试数据");
         useSpringCache.updateMenuById(menuEntity);
         return "成功清空缓存";
     }
 }
 /**
  * @description:
  * @author: Ning Zaichun
  * @date: 2022年09月21日 20:30
  */
 public interface IUseSpringCache {
 ​
     String getTest();
 ​
     String getTest2();
 ​
     void clearTest();
 ​
     List<MenuEntity> getMenuList();
 ​
     void updateMenuById(MenuEntity menuEntity);
 }
 /**
  * @description:
  * @author: Ning Zaichun
  * @date: 2022年09月21日 20:30
  */
 @Service
 @RequiredArgsConstructor
 public class UseSpringCacheImpl implements IUseSpringCache {
 ​
     private final MenuMapper menuMapper;
 ​
     @Cacheable(value = {"menu"}, key = "'getMenuList'")
     @Override
     public List<MenuEntity> getMenuList() {
         System.out.println("查询数据库======");
         List<MenuEntity> menuEntityList = menuMapper.selectList(new QueryWrapper<>());
         return menuEntityList;
     }
 ​
     /**
      * 级联更新所有关联的数据
      *
      * @param menuEntity
      * @CacheEvict:失效模式
      * @CachePut:双写模式,需要有返回值 1、同时进行多种缓存操作:@Caching
      * 2、指定删除某个分区下的所有数据 @CacheEvict(value = "menu",allEntries = true)
      * 3、存储同一类型的数据,都可以指定为同一分区
      */
     // @Caching(evict = {
     //         @CacheEvict(value = "category",key = "'getLevel1Categorys'"),
     //         @CacheEvict(value = "category",key = "'getCatalogJson'")
     // })
     @CacheEvict(value = "menu", allEntries = true)       //删除某个分区下的所有数据
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void updateMenuById(MenuEntity menuEntity) {
         System.out.println("清空缓存======");
         menuMapper.updateById(menuEntity);
     }
 ​
     @Cacheable(value = {"test"}, key = "#root.methodName")
     @Override
     public String getTest() {
         System.out.println("测试查询了数据库");
         return "我是测试缓存数据";
     }
 ​
     @Cacheable(value = {"test"}, key = "'getTest2'")
     @Override
     public String getTest2() {
         System.out.println("测试查询了数据库2");
         return "我是测试缓存数据2";
     }
 ​
      @Caching(evict = {
              @CacheEvict(value = "test",key = "'getTest'")
      })
     @Override
     public void clearTest() {
          System.out.println("清空了test缓存");
     }
 }

测试

上面就是简单的使用,上面的注解啥的,马上就开说哈

先讲讲案例中的两个删除缓存的注解

 @CacheEvict(value = "menu", allEntries = true)  
 @Caching(evict = {
          @CacheEvict(value = "test",key = "'getTest'")
  })

两种方式,allEntries = true表示直接清空掉整个分区,

而第二种方式,只会清掉getTest的分区。

Redis的缓存,它的格式是这样的。

image.png

采用第二种方式时,只会清理掉getTest的分区。

变成下面这样:

image.png上面的案例,我只是使用最简单的方式使用了一下 Spring Cache

但其实注解上远不止这么一点东西,接下来慢慢说一说👇

大家也不用刻意记,就大致知道Spring cache可以解决什么问题即可。

Spring Cache 注解

只有使用public定义的方法才可以被缓存,而private方法、protected 方法或者使用default 修饰符的方法都不能被缓存。 当在一个类上使用注解时,该类中每个公共方法的返回值都将被缓存到指定的缓存项中或者从中移除。

  • @Cacheable
  • @CachePut
  • @CacheEvict
  • @Caching
  • @CacheConfig

@Cacheable

属性名 作用与描述
cacheNames/value 指定缓存的名字,缓存使用CacheManager管理多个缓存Cache,这些Cache就是根据该属性进行区分。对缓存的真正增删改查操作在Cache中定义,每个缓存Cache都有自己唯一的名字。
key 缓存数据时的key的值,默认是使用方法所有入参的值。1、可以使用SpEL表达式表示key的值。2、可以使用字符串,3、可以使用方法名
keyGenerator 缓存的生成策略(键生成器),和key二选一,作用是生成键值key,keyGenerator可自定义。
cacheManager 指定缓存管理器(例如ConcurrentHashMap、Redis等)。
cacheResolver 和cacheManager作用一样,使用时二选一。
condition 指定缓存的条件(对参数判断,满足什么条件时才缓存),可用SpEL表达式,例如:方法入参为对象user则表达式可以写为condition = "#user.age>18",表示当入参对象user的属性age大于18才进行缓存。
unless 否定缓存的条件(对结果判断,满足什么条件时不缓存),即满足unless指定的条件时,对调用方法获取的结果不进行缓存,例如:unless = "result==null",表示如果结果为null时不缓存。
sync 是否使用异步模式进行缓存,默认false。

@Cacheable指定了被注解方法的返回值是可被缓存的。其工作原理是就是AOP机制,实际上,Spring 首先查找的是缓存,缓存中没有再查询的数据库。

接下来就说说几种用法:



 @Cacheable(value = "users") 
 //Spring 从4.0开始新增了value别名cacheNames比value更达意,推荐使用
 @Cacheable(cacheNames = "users")
 ​
 //综合使用
 @Cacheable(cacheNames = {"test"}, key = "'getTest3'",condition = "#number>12",unless = "#number<12")

测试~

image.png

当我不传值,因为不满足条件,Redis 中是不会缓存的

image.png

只有满足number>12 时才会进行缓存

image.png

下面的注解中含有的condition和unless属性的都是同样的用法。

@CachePut

@CachePut的注解属性就比@Cacheable 少了一个sync,其余都一样。

@CachePut注解你就直接理解为执行后更新缓存就好。

就比如我一个方法是缓存某个学生或者是某个用户信息。

然后我修改了我的个人信息什么之类的,这个时候就可以直接用上@CachePut注解了。

比如:

 /**
  * studentCache
  * 缓存键值key未指定默认为userNumber+userName组合字符串
  */
 @Cacheable(cacheNames = "studentCache")
 @Override
 public Student getStudentById(String id) {
     // 方法内部实现不考虑缓存逻辑,直接实现业务
     return getFromDB(id);
 }
 ​
 /**
  * 注解@CachePut:确保方法体内方法一定执行,执行完之后更新缓存;
  * 相同的缓存userCache和key(缓存键值使用spEl表达式指定为userId字符串)以实现对该缓存更新;
  * @param student
  * @return 返回
  */
 @CachePut(cacheNames = "studentCache", key = "(#student.id)")
 @Override
 public Student updateStudent(Student student) {
     return updateData(student);
 }
 ​
 private Student updateData(Student student) {
     System.out.println("real updating db..." + student.getId());
     return student;
 }
 ​
 private Student getFromDB(String id) {
     System.out.println("querying id from db..." + id);
     return new Student(id,"宁在春","社会",19);
 }

结果:

image.png

更新之后

image.png

@CacheEvict

@CacheEvict注解是@Cachable注解的反向操作,它负责从给定的缓存中移除一个值。大多数缓存框架都提供了缓存数据的有效期,使用该注解可以显式地从缓存中删除失效的缓存数据。

cacheNames/value、key、keyGenerator、cacheManager、cacheResolver、condition这些和上面一样的属性就不说了

它还有两个其他的属性:

allEntries:allEntries是布尔类型的,用来表示是否需要清除这个缓存分区中的的所有元素。默认值为false,表示不需要。

beforeInvocation: 清除操作默认是在对应方法执行成功后触发的(beforeInvocation = false),即方法如果因为抛出异常而未能成功返回时则不会触发清除操作。使用beforeInvocation属性可以改变触发清除操作的时间。当指定该属性值为true时,Spring会在调用该方法之前清除缓存中的指定元素。

之前也简单的使用过了,就不多测试啦,让我偷个懒~

大伙想要啥骚操作的话,就得多去尝试~

@Caching

@Caching注解属性一览:

属性名 作用与描述
cacheable 取值为基于@Cacheable注解的数组,定义对方法返回结果进行缓存的多个缓存。
put 取值为基于@CachePut注解的数组,定义执行方法后,对返回方的方法结果进行更新的多个缓存。
evict 取值为基于@CacheEvict注解的数组。定义多个移除缓存。

总结来说,@Caching是一个组注解,可以为一个方法定义提供基于@Cacheable@CacheEvict或者@CachePut注解的数组。

就比如:

你如果使用@CacheEvict(value = "test",key = "'getTest'")这条注解,只能清理某一个分区的缓存,test下的getTest所缓存的数据,你没办法再清理其他分区的缓存。

使用了@Caching就可以一次清理多个。

 @Caching(evict = {
     @CacheEvict(value = "test",key = "'getTest'"),
     @CacheEvict(value = "test",key = "'getTest2'"),
     @CacheEvict(value = "test",key = "'getTest3'"),
 })

其他的也类似。

@CacheConfig

@CacheConfig注解属性一览:cacheNames/value、keyGenerator、cacheManager、cacheResolver.

一个类中可能会有多个缓存操作,而这些缓存操作可能是重复的。这个时候可以使用 @CacheConfig是一个类级别的注解.

简单举个例子吧:

image.png

我们发现在同个service类下,对不同方法添加的注解都要指定同一个缓存组件我们可以在类头上统一抽取缓存组件,或者是缓存名称之类的~

大伙私下多试一试,就可以啦,很简单的~

其实还有一些知识的,但是说难也不难,就没有再说啦,大伙慢慢发掘吧~

注意事项

1)不建议缓存分页查询的结果。

2)基于 proxyspring aop 带来的内部调用问题

这个问题不仅仅是出现在这里,其实只要牵扯到Spring AOP 切面的问题,都有这个问题,就像@Transactional(rollbackFor = Exception.class)注解一样。

假设对象的方法是内部调用(即 this 引用)而不是外部引用,则会导致 proxy 失效,那么切面就失效,也就是说 @Cacheable、@CachePut 和 @CacheEvict 都会失效。

解决方法:

  • 启动类添加@EnableAspectJAutoProxy(exposeProxy = true),方法内使用AopContext.currentProxy()获得代理类,使用事务。
 @Autowired
 private ApplicationContext applicationContext;
 ​
 // 在方法中手动获取bean,再调用
 applicationContext.getBean(xxxxServiceImpl.class);

3)@Cache注解的方法必须为 public

4)默认情况下,@CacheEvict标注的方法执行期间抛出异常,则不会清空缓存。

后记

不知道这篇文章有没有帮助到你,希望看完的你,开开心心~


今天这个文章就写到了这里啦,我是 宁在春,一个宁愿永远活在有你的春天里的那个人

如果你觉得有所收获,就给我点点赞,点点关注吧~ 哈哈,希望收到来自你的正向反馈,下一篇文章再见。

image.png

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
打赏
0
0
1
0
28
分享
相关文章
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
本文介绍在 Spring Boot 中集成 Redis 的方法。Redis 是一种支持多种数据结构的非关系型数据库(NoSQL),具备高并发、高性能和灵活扩展的特点,适用于缓存、实时数据分析等场景。其数据以键值对形式存储,支持字符串、哈希、列表、集合等类型。通过将 Redis 与 Mysql 集群结合使用,可实现数据同步,提升系统稳定性。例如,在网站架构中优先从 Redis 获取数据,故障时回退至 Mysql,确保服务不中断。
28 0
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
Redis--缓存击穿、缓存穿透、缓存雪崩
缓存击穿、缓存穿透和缓存雪崩是Redis使用过程中可能遇到的常见问题。理解这些问题的成因并采取相应的解决措施,可以有效提升系统的稳定性和性能。在实际应用中,应根据具体场景,选择合适的解决方案,并持续监控和优化缓存策略,以应对不断变化的业务需求。
56 29
Redis应用—8.相关的缓存框架
本文介绍了Ehcache和Guava Cache两个缓存框架及其使用方法,以及如何自定义缓存。主要内容包括:Ehcache缓存框架、Guava Cache缓存框架、自定义缓存。总结:Ehcache适合用作本地缓存或与Redis结合使用,Guava Cache则提供了更灵活的缓存管理和更高的并发性能。自定义缓存可以根据具体需求选择不同的数据结构和引用类型来实现特定的缓存策略。
Redis应用—8.相关的缓存框架
Redis缓存设计与性能优化
Redis缓存设计与性能优化涵盖缓存穿透、击穿、雪崩及热点key重建等问题。针对缓存穿透,可采用缓存空对象或布隆过滤器;缓存击穿通过随机设置过期时间避免集中失效;缓存雪崩需确保高可用性并使用限流熔断组件;热点key重建利用互斥锁防止大量线程同时操作。此外,开发规范强调键值设计、命令使用和客户端配置优化,如避免bigkey、合理使用批量操作和连接池管理。系统内核参数如vm.swappiness、vm.overcommit_memory及文件句柄数的优化也至关重要。慢查询日志帮助监控性能瓶颈。
44 9
缓存与数据库的一致性方案,Redis与Mysql一致性方案,大厂P8的终极方案(图解+秒懂+史上最全)
缓存与数据库的一致性方案,Redis与Mysql一致性方案,大厂P8的终极方案(图解+秒懂+史上最全)
解决Redis缓存数据类型丢失问题
解决Redis缓存数据类型丢失问题
216 85
Redis,分布式缓存演化之路
本文介绍了基于Redis的分布式缓存演化,探讨了分布式锁和缓存一致性问题及其解决方案。首先分析了本地缓存和分布式缓存的区别与优劣,接着深入讲解了分布式远程缓存带来的并发、缓存失效(穿透、雪崩、击穿)等问题及应对策略。文章还详细描述了如何使用Redis实现分布式锁,确保高并发场景下的数据一致性和系统稳定性。最后,通过双写模式和失效模式讨论了缓存一致性问题,并提出了多种解决方案,如引入Canal中间件等。希望这些内容能为读者在设计分布式缓存系统时提供有价值的参考。感谢您的阅读!
136 6
Redis,分布式缓存演化之路
|
4天前
|
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Spring Boot 集成 Redis
本文介绍了在Spring Boot中集成Redis的方法,包括依赖导入、Redis配置及常用API的使用。通过导入`spring-boot-starter-data-redis`依赖和配置`application.yml`文件,可轻松实现Redis集成。文中详细讲解了StringRedisTemplate的使用,适用于字符串操作,并结合FastJSON将实体类转换为JSON存储。还展示了Redis的string、hash和list类型的操作示例。最后总结了Redis在缓存和高并发场景中的应用价值,并提供课程源代码下载链接。
19 0
|
4天前
|
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 安装
本教程介绍在 VMware 虚拟机(CentOS 7)或阿里云服务器中安装 Redis 的过程,包括安装 gcc 编译环境、下载 Redis(官网或 wget)、解压安装、修改配置文件(如 bind、daemonize、requirepass 等设置)、启动 Redis 服务及测试客户端连接。通过 set 和 get 命令验证安装是否成功。适用于初学者快速上手 Redis 部署。
13 0
云端问道21期方案教学-应对高并发,利用云数据库 Tair(兼容 Redis®*)缓存实现极速响应
云端问道21期方案教学-应对高并发,利用云数据库 Tair(兼容 Redis®*)缓存实现极速响应