【7】Spring Boot 3 集成组件：缓存组件 spring cache + spring data redis

个人主页: 【⭐️个人主页】
需要您的【💖 点赞+关注】支持 💯

---

【7】Spring Boot 3 集成组件：缓存组件 spring cache + spring data redis

📖 本文核心知识点：

• spring cache 抽象和注解
• cache 支持的缓存类型
• spring cache + spring data redis 配置
• redis序列化

本章使用的spring版本
spring boot version: 3.1.5

什么是缓存抽象

• 官网-缓存抽象
  使用翻译软件阅读
• 主要阅读的知识点

1. 缓存抽象的作用
2. spring缓存的声明式注解
3. spring缓存的生成key策略和如何自定义keyGenerator
4. 缓存支持的后端类型

声明式注解

JSR-107对应

SpEL上下文数据

引入依赖

    implementation 'org.springframework.boot:spring-boot-starter-cache'
1

添加启用缓存注解@EnableCaching

@SpringBootApplication(scanBasePackages = {"com.kongxiang"})
@EnableAutoConfiguration
@EnableCaching
public class StudySpring3Application {

	public static void main(String[] args) {
		SpringApplication.run(StudySpring3Application.class, args);
	}
}
1
2
3
4
5
6
7
8
9

cache 支持的缓存类型

spring cache支持的缓存类型
查看类org.springframework.boot.autoconfigure.cache.CacheType

public enum CacheType {

	/**
	 * Generic caching using 'Cache' beans from the context.
	 */
	GENERIC,

	/**
	 * JCache (JSR-107) backed caching.
	 */
	JCACHE,

	/**
	 * Hazelcast backed caching.
	 */
	HAZELCAST,

	/**
	 * Couchbase backed caching.
	 */
	COUCHBASE,

	/**
	 * Infinispan backed caching.
	 */
	INFINISPAN,

	/**
	 * Redis backed caching.
	 */
	REDIS,

	/**
	 * Cache2k backed caching.
	 */
	CACHE2K,

	/**
	 * Caffeine backed caching.
	 */
	CAFFEINE,

	/**
	 * Simple in-memory caching.
	 */
	SIMPLE,

	/**
	 * No caching.
	 */
	NONE

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

缓存类型配置

NONE

无缓存

spring:
  cache:
    type: NONE

1
2
3
4

SIMPLE

内存缓存

spring:
  cache:
    type: SIMPLE

1
2
3
4

REDIS

Redis 缓存

spring:
  cache:
    type: REDIS
  data:
    redis:
      host: '127.0.0.1'
      username:
      port: 6379
      password:
      database: 1
      lettuce:
        pool:
          enabled: true
          max-active: 8
          max-wait: 1000
          max-idle: 8
      connect-timeout: 5000

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

自定义配置

默认情况下会有两个模板类被注入Spring IoC供我们使用，需要个性化配置来满足实际的开发。

一个是RedisTemplate，主要用于对象缓存，其默认使用JDK序列化，我们需要更改其序列化方式解决一些问题，比如Java 8日期问题、JSON序列化问题。需要我们重写一下。

1. RedisTemplate自定义配置

 @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<Object, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        // 使用Jackson2JsonRedisSerialize 替换默认序列化
        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = initJacksonSerializer();
        // 设置value的序列化规则和 key的序列化规则
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.setKeySerializer(new StringRedisSerializer());
        template.afterPropertiesSet();
        return template;
    }
    /**
     * 处理redis序列化问题
     * @return Jackson2JsonRedisSerializer
     */
    private Jackson2JsonRedisSerializer<Object> initJacksonSerializer() {
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        //以下替代旧版本 om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        om.activateDefaultTyping(om.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);
        //bugFix Jackson2反序列化数据处理LocalDateTime类型时出错
        om.disable(SerializationFeature.WRITE_DATE_KEYS_AS_TIMESTAMPS);
        // java8 时间支持
        om.registerModule(new JavaTimeModule());
        return new Jackson2JsonRedisSerializer<>(om,Object.class);
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

2. 缓存管理器自定义配置
   使用Spring Cache做缓存的时候，有针对不同的key设置不同过期时间的场景。比如Jwt Token我想设置为一周过期，而验证码我想设置为五分钟过期。这个怎么实现呢？需要我们个性化配置RedisCacheManager。首先我通过枚举来定义这些缓存及其TTL时间

我们通过向Spring IoC分别注入RedisCacheConfiguration和RedisCacheManagerBuilderCustomizer来个性化配置

 /**
     * Redis cache configuration.
     *
     * @param redisTemplate the redis template
     * @return the redis cache configuration
     */
    @Bean
    public RedisCacheConfiguration redisCacheConfiguration(RedisTemplate<Object, Object> redisTemplate, CacheProperties cacheProperties) {
        // 参见 spring.cache.redis
        CacheProperties.Redis redisProperties = cacheProperties.getRedis();

        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                // 缓存的序列化问题
                .serializeValuesWith(RedisSerializationContext.SerializationPair
                        .fromSerializer(redisTemplate.getValueSerializer()));

        if (redisProperties.getTimeToLive() != null) {
            // 全局 TTL 时间
            redisCacheConfiguration = redisCacheConfiguration.entryTtl(redisProperties.getTimeToLive());
        }
        if (redisProperties.getKeyPrefix() != null) {
            // key 前缀值
            redisCacheConfiguration = redisCacheConfiguration.prefixCacheNameWith(redisProperties.getKeyPrefix());
        }
        if (!redisProperties.isCacheNullValues()) {
            // 默认缓存null值 可以防止缓存穿透
            redisCacheConfiguration = redisCacheConfiguration.disableCachingNullValues();
        }
        if (!redisProperties.isUseKeyPrefix()) {
            // 不使用key前缀
            redisCacheConfiguration = redisCacheConfiguration.disableKeyPrefix();
        }
        return redisCacheConfiguration;
    }

    /**
     * Redis cache manager 个性化配置缓存过期时间.
     *
     * @return the redis cache manager builder customizer
     */
    @Bean
    public RedisCacheManagerBuilderCustomizer redisCacheManagerBuilderCustomizer(RedisCacheConfiguration redisCacheConfiguration) {
        return builder -> builder.cacheDefaults(redisCacheConfiguration);
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

CAFFEINE

引入依赖

    implementation 'com.github.ben-manes.caffeine:caffeine:3.1.8'
1

修改配置

spring:
  cache:
    type: CAFFEINE
1
2
3

直接启动即可

Hazelcast

…

总结

spring cache 缓存抽象加上spring data包和spring boot autoconfig 配置包的能力，可以快速接入一个具体的缓存实现。redis是我们公司基本使用的缓存策略。所以针对redis的一些自定义配置，通过 java bean的方式实现。着重强调一下。