|
|
@@ -0,0 +1,86 @@
|
|
|
+package org.jeecg.modules.redis;
|
|
|
+
|
|
|
+import static org.springframework.data.redis.serializer.RedisSerializationContext.SerializationPair;
|
|
|
+
|
|
|
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
|
|
|
+import com.fasterxml.jackson.annotation.PropertyAccessor;
|
|
|
+import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
+
|
|
|
+import org.jeecg.common.modules.redis.config.RedisConfig;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.cache.CacheManager;
|
|
|
+import org.springframework.cache.annotation.Cacheable;
|
|
|
+import org.springframework.cache.annotation.EnableCaching;
|
|
|
+import org.springframework.cache.interceptor.CacheAspectSupport;
|
|
|
+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.RedisCacheWriter;
|
|
|
+import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|
|
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
|
|
|
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
|
|
|
+import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|
|
+
|
|
|
+import java.time.Duration;
|
|
|
+
|
|
|
+/**
|
|
|
+ * Redis cache配置
|
|
|
+ *
|
|
|
+ * @author wfansh
|
|
|
+ */
|
|
|
+@Configuration
|
|
|
+@EnableCaching
|
|
|
+public class CacheConfig {
|
|
|
+
|
|
|
+ public static final String PRIMARY_CACHE_MANAGER = "primaryCacheManager";
|
|
|
+
|
|
|
+ public static final String TTL_CACHE_MANAGER = "ttlCacheManager";
|
|
|
+
|
|
|
+ private static final int DEFAULT_TTL_HOURS = 5;
|
|
|
+
|
|
|
+ /** Jeecg默认Redis cache配置 */
|
|
|
+ @Autowired private RedisConfig redisConfig;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Workaround - 重新注册Jeecg默认的{@link CacheManager}，标识为Primary
|
|
|
+ *
|
|
|
+ * <p>当有多个{@link CacheManager} beans时，需标识出@Prinary
|
|
|
+ *
|
|
|
+ * <p>参考{@link RedisConfig#cacheManager(LettuceConnectionFactory)}方法
|
|
|
+ *
|
|
|
+ * <p>参考{@link CacheAspectSupport#setCacheManager(CacheManager)}方法
|
|
|
+ */
|
|
|
+ @Bean(name = PRIMARY_CACHE_MANAGER)
|
|
|
+ @Primary
|
|
|
+ public CacheManager primaryCacheManager(LettuceConnectionFactory connectionFactory) {
|
|
|
+ return redisConfig.cacheManager(connectionFactory);
|
|
|
+ }
|
|
|
+
|
|
|
+ /** 注册{@link CacheManager}，支持在{@link Cacheable#cacheNames()}中设置Redis TTL */
|
|
|
+ @Bean(name = TTL_CACHE_MANAGER)
|
|
|
+ public CacheManager ttlCacheManager(RedisConnectionFactory connectionFactory) {
|
|
|
+ ObjectMapper objectMapper = new ObjectMapper();
|
|
|
+ // 解决缓存对象转换异常的问题
|
|
|
+ objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
|
|
+ objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
|
|
|
+
|
|
|
+ // 配置序列化（解决乱码的问题）,并配置缓存默认TTL
|
|
|
+ RedisCacheConfiguration cacheConfiguration =
|
|
|
+ RedisCacheConfiguration.defaultCacheConfig()
|
|
|
+ .entryTtl(Duration.ofHours(DEFAULT_TTL_HOURS))
|
|
|
+ .serializeKeysWith(
|
|
|
+ SerializationPair.fromSerializer(new StringRedisSerializer()))
|
|
|
+ .serializeValuesWith(
|
|
|
+ SerializationPair.fromSerializer(
|
|
|
+ new Jackson2JsonRedisSerializer(
|
|
|
+ objectMapper, Object.class)))
|
|
|
+ .disableCachingNullValues();
|
|
|
+
|
|
|
+ // 非锁写入方式
|
|
|
+ RedisCacheWriter cacheWriter =
|
|
|
+ RedisCacheWriter.nonLockingRedisCacheWriter(connectionFactory);
|
|
|
+
|
|
|
+ return new TTLCacheManager(cacheWriter, cacheConfiguration);
|
|
|
+ }
|
|
|
+}
|
wfansh