cache manager配置

cash-api/api-config/pom.xml

@@ -28,6 +28,12 @@
             <groupId>com.czg</groupId>
             <artifactId>cash-common-tools</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>com.czg</groupId>
+            <artifactId>cash-common-redis</artifactId>
+            <version>1.0.0</version>
+        </dependency>
     </dependencies>
 
 

cash-api/api-config/src/main/java/com/czg/config/CacheConfig.java

@@ -0,0 +1,43 @@
+package com.czg.config;
+
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import java.time.Duration;
+
+
+/**
+ * @author GYJoker
+ */
+@Configuration
+@EnableCaching
+public class CacheConfig {
+
+    @Bean(name = "redisCacheManager")
+    @Primary
+    public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
+        // 使用自定义的 FastJson2RedisSerializer 进行值的序列化
+        FastJson2RedisSerializer<Object> fastJson2RedisSerializer = new FastJson2RedisSerializer<>(Object.class);
+
+        // 配置 Redis 缓存的默认配置
+        RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
+                // 设置键的序列化方式
+                .serializeKeysWith(org.springframework.data.redis.serializer.RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
+                // 设置值的序列化方式，使用 Fastjson2 序列化
+                .serializeValuesWith(org.springframework.data.redis.serializer.RedisSerializationContext.SerializationPair.fromSerializer(fastJson2RedisSerializer))
+                // 设置缓存过期时间为 30 分钟
+                .entryTtl(Duration.ofMinutes(30));
+
+        // 创建 Redis 缓存管理器
+        return RedisCacheManager.builder(redisConnectionFactory)
+                .cacheDefaults(cacheConfiguration)
+                .build();
+    }
+}

cash-api/system-server/src/main/java/com/czg/SystemApplication.java

@@ -3,13 +3,11 @@ package com.czg;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 
 /**
  * @author ww
  */
-@EnableCaching
 @SpringBootApplication
 @EnableDiscoveryClient
 @MapperScan("com.czg.service.system.mapper")

cash-common/cash-common-redis/src/main/java/com/czg/config/FastJson2RedisSerializer.java

@@ -0,0 +1,38 @@
+package com.czg.config;
+
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONReader;
+import com.alibaba.fastjson2.JSONWriter;
+import org.springframework.data.redis.serializer.RedisSerializer;
+import org.springframework.data.redis.serializer.SerializationException;
+
+import java.nio.charset.StandardCharsets;
+
+/**
+ * @author GYJoker
+ */
+public class FastJson2RedisSerializer<T> implements RedisSerializer<T> {
+
+    private final Class<T> clazz;
+
+    public FastJson2RedisSerializer(Class<T> clazz) {
+        this.clazz = clazz;
+    }
+
+    @Override
+    public byte[] serialize(T t) throws SerializationException {
+        if (t == null) {
+            return new byte[0];
+        }
+        return JSON.toJSONString(t, JSONWriter.Feature.WriteClassName).getBytes(StandardCharsets.UTF_8);
+    }
+
+    @Override
+    public T deserialize(byte[] bytes) throws SerializationException {
+        if (bytes == null || bytes.length == 0) {
+            return null;
+        }
+        String str = new String(bytes, StandardCharsets.UTF_8);
+        return JSON.parseObject(str, clazz, JSONReader.Feature.SupportAutoType);
+    }
+}