查看原文
其他

Spring cache整合Redis,并给它一个过期时间!

吕一明 MarkerHub 2022-11-04

小Hub领读:

不知道你们有没给cache设置过过期时间,来试试?


上一篇文章中,我们使用springboot集成了redis,并使用RedisTemplate来操作缓存数据,可以灵活使用。

我才懂!SpringBoot的StringRedisTemplate与RedisTemplate的序列化策略有啥不同~

今天我们要讲的是Spring为我们提供的缓存注解Spring Cache。Spring支持多种缓存技术:RedisCacheManager、EhCacheCacheManager、GuavaCacheManager等,使用之前需要配置一个CacheManager的Bean。

配置好之后使用常用的三个注解来缓存数据:

  • @Cacheable

  • @CachePut

  • @CacheEvict。

这三个注解方别代表着什么意思,等会我们一一来解剖。

1、配置RedisCacheManager

刚才说了,首先我们需要配置一个缓存管理器,然后才能使用缓存注解来管理缓存。上一篇文章中我们已经整合了redis,接下来,我们只需要直接去配置RedisCacheManager即可。

  • com.markerhub.config.RedisConfig

  1. /**

  2. * 配置一个CacheManager才能使用@Cacheable等注解

  3. *

  4. * 公众号:MarkerHub

  5. */

  6. @Bean

  7. public CacheManager cacheManager(RedisTemplate<String, Object> template) {


  8. // 基本配置

  9. RedisCacheConfiguration defaultCacheConfiguration =

  10. RedisCacheConfiguration

  11. .defaultCacheConfig()

  12. // 设置key为String

  13. .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(template.getStringSerializer()))

  14. // 设置value 为自动转Json的Object

  15. .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(template.getValueSerializer()))

  16. // 不缓存null

  17. .disableCachingNullValues()

  18. // 缓存数据保存1小时

  19. .entryTtl(Duration.ofHours(1));


  20. // 够着一个redis缓存管理器

  21. RedisCacheManager redisCacheManager =

  22. RedisCacheManager.RedisCacheManagerBuilder

  23. // Redis 连接工厂

  24. .fromConnectionFactory(template.getConnectionFactory())

  25. // 缓存配置

  26. .cacheDefaults(defaultCacheConfiguration)

  27. // 配置同步修改或删除 put/evict

  28. .transactionAware()

  29. .build();


  30. return redisCacheManager;

  31. }

上面的配置中,大部分代码都给出了注释,我们只需要根据需求配置一下即可。其中反序列策略延用了原来RedisTemplate的参数。

  • RedisCacheConfiguration

  • RedisCacheManager

还有一个重要的步骤不能忘记了,需要开启Spring Cache的缓存功能支持,很简单,只需要在RedisConfig上添加一个注解:

  1. @EnableCaching

写一个例子

上面我们已经已经配置了RedisCacheManager帮我们管理缓存,接下来我们就去使用Spring Cache的注解来完成我们的代码测试。

下面的例子我写得可能有点粗,如果你对一些参数还不了解,建议你看看这篇文章: https://blog.csdn.net/dreamhai/article/details/80642010

1、@Cacheable

标记在方法或者类上,标识该方法或类支持缓存。Spring调用注解标识方法后会将返回值缓存到redis,以保证下次同条件调用该方法时直接从缓存中获取返回值。这样就不需要再重新执行该方法的业务处理过程,提高效率。

@Cacheable常用的三个参数如下:

  • cacheNames 缓存名称

  • key 缓存的key,需要注意key的写法哈

  • condition 缓存执行的条件,返回true时候执行

  1. @Slf4j

  2. @Service

  3. public class UserServiceImpl implements UserService {


  4. @Override

  5. @Cacheable(cacheNames = "cache_user", key="'user_' + #id")

  6. public User getById(long id) {


  7. log.info("进来查库了--------->{}", id);


  8. User user = new User();

  9. user.setId(1L);

  10. user.setUsername("MarkerHub" + id);

  11. return user;

  12. }


  13. }

然后写一个具体的调用:

  1. @RestController

  2. public class UserController {


  3. @Autowired

  4. UserService userService;


  5. @GetMapping("/u/{id}")

  6. public User index(@PathVariable("id") Long id) {


  7. User user = userService.getById(id);

  8. return user;


  9. }

  10. }

测试下访问结果,访问链接: http://localhost:8080/u/12

第一次调用时候控制台输出:

  1. 进来查库了--------->12

第二次再访问的时候,就没有再输出,说明没有进入业务方法,就是在redis中获取结果直接返回。

看一下redis的可视化工具:

这里大家需要注意一下,在配置redis的序列化方式的时候,一定要配置下面的代码,这个在之前Springboot配置redis中已经说过了。

  1. Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<Object>(Object.class);


  2. ObjectMapper objectMapper = new ObjectMapper();

  3. objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

  4. objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

  5. serializer.setObjectMapper(objectMapper);

如果你序列化之后的value只是一个简单的json数据,这样会引起强转错误的。需要注意一下!

2、@CacheEvict

标记在方法上,方法执行完毕之后根据条件或key删除对应的缓存。常用的属性:

  • allEntries boolean类型,表示是否需要清除缓存中的所有元素

  • key 需要删除的缓存的key

  1. @Override

  2. @CacheEvict(cacheNames = "cache_user", allEntries = true)

  3. public void update(User user) {


  4. // 更新逻辑...

  5. }

于是, update方法执行之后, cacheNames="cache_user"里面的所有缓存都会被删除!这也是很常用的方法。当然了,你还可以这样写,根据key来删除某个指定缓存:

  1. @Override

  2. @CacheEvict(cacheNames = "cache_user", key = "'user_' + #user.id")

  3. public void update(User user) {


  4. // 更新逻辑...

  5. }

3、@@CachePut

标注的方法在执行前不会去检查缓存中是否存在之前执行过的结果,而是每次都会执行该方法,并将执行结果以键值对的形式存入指定的缓存中。

4、@Caching

可以在一个注解上标注多种注解,其拥有三个属性:cacheable、put和evict,分别用于指定@Cacheable、@CachePut和@CacheEvict

过期时间

我们已经实现了Spring Cache的基本功能,整合了Redis作为 RedisCacheManger,但众所周知,我们在使用 @Cacheable注解的时候是无法给缓存这是过期时间的。但有时候在一些场景中我们的确需要给缓存一个过期时间!

在缓存与库数据不一致的时候,自动过期就显得尤为重要,这是一个保底的方式。那么,如何给Spring cache一个过期时间呢?

其实不需要我们去整合第三方的包,比如Redission等,我们在配置 RedisCacheManager的时候其实就可以配置过期时间,只是,这个过期时间是针对cache的。

这是什么意思?比如你使用了如下注解:

  1. @Cacheable(cacheNames = "cache_user", key="'user_' + #id")

我们可以在初始化的时候指定cacheNames为 cache_user的cache的过期时间。我们先来回顾一下 RedisCacheManager的初始化配置。

上面在 RedisCacheConfiguration上我们配置一个关于过期时间的配置 .entryTtl(Duration.ofHours(1)),缓存数据保存一个小时。并且在 RedisCacheManager上通过 .cacheDefaults(defaultCacheConfiguration)进行了配置。这两行代码其实是在说,所有的缓存数据默认保存一个小时。

相比于以前,我们统一配置了缓存的过期时间是1个小时。但这还是写得比较固定,一般来说,我们想给不同的cache不同的过期时间,比如 cache_post和 cache_user不一样的过期时间,那么这个怎么弄呢?能否在配置中实现吗?

答案是可以的,很简单,在 RedisCacheManager中有这个方法:

  1. RedisCacheManagerBuilder withCacheConfiguration(String cacheName, RedisCacheConfiguration cacheConfiguration)

可以给每个cacheName不同的RedisCacheConfiguration,之前的配置,我们是配置了一个默认的缓存配置,有个这个方法之后,我们就可以指定某个cache的缓存配置。每个缓存配置的不同的地方其实就是过期时间。因此,我们抽个方法出来生成缓存配置,代码如下:

  1. RedisCacheConfiguration getCacheConfigurationWithTtl(RedisTemplate<String, Object> template, long seconds) {


  2. return RedisCacheConfiguration

  3. .defaultCacheConfig()

  4. // 设置key为String

  5. .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(template.getStringSerializer()))

  6. // 设置value 为自动转Json的Object

  7. .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(template.getValueSerializer()))

  8. // 不缓存null

  9. .disableCachingNullValues()

  10. // 缓存数据保存1小时

  11. .entryTtl(Duration.ofSeconds(seconds));

  12. }

参数seconds指定缓存的过期时间,因此,我们在RedisCacheManager中应该这样配置:

  1. RedisCacheManager redisCacheManager =

  2. RedisCacheManager.RedisCacheManagerBuilder

  3. // Redis 连接工厂

  4. .fromConnectionFactory(template.getConnectionFactory())

  5. .cacheDefaults(getCacheConfigurationWithTtl(template, 60 * 60))

  6. .withCacheConfiguration("cache_user", getCacheConfigurationWithTtl(template, 60))

  7. .withCacheConfiguration("cache_post", getCacheConfigurationWithTtl(template, 120))

  8. // 配置同步修改或删除 put/evict

  9. .transactionAware()

  10. .build();


  11. return redisCacheManager;

  12. }

根据上面的配置,我们指定了cacheName如下:

  • cache_user过期时间为60秒

  • cache_post过期时间为120秒

  • 其他默认过期时间为1小时

这也是我建议大家的写法!

很多人还有其他实现写法,比如在cacheNames后面添加 #3600,截取 #后面的数字作为过期时间。

  1. @Cacheable(cacheNames = "cache_user#3600", key="'user_' + #id")

更有一些人想给key一个过期时间,于是又有这种写法:

  1. @Cacheable(cacheNames = "cache_user#3600", key="'user_' + #id + '#3600'")

其实在我看来没有必要。直接在配置中写好,简单方便!

结束语

好啦,今天的文章到此结束啦,右下角点个在看再走呗,哈哈。


(完)

MarkerHub文章索引:(点击阅读原文直达)

https://github.com/MarkerHub/JavaIndex


【推荐阅读】

月薪10K、15K、20K的Java程序员分别需要掌握哪些技术?

传统@ServerEndpoint方式开发WebSocket应用和SpringBoot构建WebSocket应用程序

小白教程,Springboot项目搭建(前端到数据库,超详细)

Spring 和 Spring Boot 最核心的 3 大区别,详解!

就几条命令,一键学会Docker部署SpringBoot项目




好文!必须点赞

您可能也对以下帖子感兴趣

文章有问题?点此查看未经处理的缓存