feat: 使用 Spring 项目 jackson 配置创建 RedisTemplate 序列化

Author: cadecode

common/plugin/cache/src/main/java/top/cadecode/uniboot/common/plugin/cache/config/CacheConfig.java

@@ -55,8 +55,8 @@ public CacheManager caffeineCacheManager5s() {
      * @return RedisCacheManager 实例
      */
     @Bean(name = CacheConfig.RCM_5M)
-    public CacheManager redisCacheManager5m(RedisTemplate<String, ?> jsonRedisTemplate) {
-        return geneRedisCacheManager(jsonRedisTemplate, 5);
+    public CacheManager redisCacheManager5m(RedisTemplate<String, Object> redisTemplate) {
+        return geneRedisCacheManager(redisTemplate, 5);
     }
 
     /**
@@ -67,16 +67,16 @@ public CacheManager redisCacheManager5m(RedisTemplate<String, ?> jsonRedisTempla
      */
     @Primary
     @Bean(name = CacheConfig.RCM_30M)
-    public CacheManager redisCacheManager30m(RedisTemplate<String, ?> jsonRedisTemplate) {
-        return geneRedisCacheManager(jsonRedisTemplate, 30);
+    public CacheManager redisCacheManager30m(RedisTemplate<String, Object> redisTemplate) {
+        return geneRedisCacheManager(redisTemplate, 30);
     }
 
-    private static RedisCacheManager geneRedisCacheManager(RedisTemplate<String, ?> jsonRedisTemplate, long minutes) {
+    private static RedisCacheManager geneRedisCacheManager(RedisTemplate<String, Object> redisTemplate, long minutes) {
         RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
-                .serializeKeysWith(SerializationPair.fromSerializer(jsonRedisTemplate.getStringSerializer()))
-                .serializeValuesWith(SerializationPair.fromSerializer(jsonRedisTemplate.getValueSerializer()))
+                .serializeKeysWith(SerializationPair.fromSerializer(redisTemplate.getStringSerializer()))
+                .serializeValuesWith(SerializationPair.fromSerializer(redisTemplate.getValueSerializer()))
                 .entryTtl(Duration.ofMinutes(minutes));
-        return RedisCacheManager.builder(jsonRedisTemplate.getConnectionFactory())
+        return RedisCacheManager.builder(redisTemplate.getConnectionFactory())
                 .cacheDefaults(cacheConfiguration)
                 .transactionAware()
                 .build();

common/plugin/cache/src/main/java/top/cadecode/uniboot/common/plugin/cache/config/RedisConfig.java

@@ -1,12 +1,18 @@
 package top.cadecode.uniboot.common.plugin.cache.config;
 
+import com.fasterxml.jackson.annotation.JsonTypeInfo.As;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.ObjectMapper.DefaultTyping;
 import lombok.RequiredArgsConstructor;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.listener.RedisMessageListenerContainer;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
 import org.springframework.data.redis.serializer.RedisSerializer;
+import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
 
 /**
  * Redis 配置类
@@ -18,25 +24,35 @@
 @Configuration
 public class RedisConfig {
 
-    private final RedisConnectionFactory factory;
-
     @Bean
-    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
+    RedisMessageListenerContainer container(RedisConnectionFactory factory) {
         RedisMessageListenerContainer container = new RedisMessageListenerContainer();
-        container.setConnectionFactory(connectionFactory);
+        container.setConnectionFactory(factory);
         return container;
     }
 
+    /**
+     * 全局默认 RedisTemplate
+     * key string, val json
+     */
+    @Primary
     @Bean
-    public RedisTemplate<String, ?> jsonRedisTemplate() {
-        RedisTemplate<String, ?> template = new RedisTemplate<>();
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory, Jackson2ObjectMapperBuilder builder) {
+        // 创建 ObjectMapper，并复用 Spring 项目配置
+        ObjectMapper objectMapper = new ObjectMapper();
+        builder.configure(objectMapper);
+        // 启用序列化类型
+        objectMapper.activateDefaultTyping(objectMapper.getPolymorphicTypeValidator(), DefaultTyping.NON_FINAL, As.PROPERTY);
+        // 创建 Redis Jackson 序列化器
+        GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer(objectMapper);
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
         template.setConnectionFactory(factory);
         // 设置 k v 的序列化方式
         template.setKeySerializer(RedisSerializer.string());
-        template.setValueSerializer(RedisSerializer.json());
+        template.setValueSerializer(jsonRedisSerializer);
         // 设置 hash k v 的序列化方式
         template.setHashKeySerializer(RedisSerializer.string());
-        template.setHashValueSerializer(RedisSerializer.json());
+        template.setHashValueSerializer(jsonRedisSerializer);
         return template;
     }
 }