|
@@ -1,8 +1,5 @@
|
|
|
package cn.yoshop.config;
|
|
package cn.yoshop.config;
|
|
|
|
|
|
|
|
-import com.fasterxml.jackson.annotation.JsonAutoDetect;
|
|
|
|
|
-import com.fasterxml.jackson.annotation.PropertyAccessor;
|
|
|
|
|
-import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
|
|
import org.springframework.cache.annotation.EnableCaching;
|
|
import org.springframework.cache.annotation.EnableCaching;
|
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Bean;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
import org.springframework.context.annotation.Configuration;
|
|
@@ -12,7 +9,7 @@ import org.springframework.data.redis.cache.RedisCacheWriter;
|
|
|
import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|
import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
|
|
-import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
|
|
|
|
|
|
|
+import org.springframework.data.redis.serializer.GenericJacksonJsonRedisSerializer;
|
|
|
import org.springframework.data.redis.serializer.RedisSerializationContext;
|
|
import org.springframework.data.redis.serializer.RedisSerializationContext;
|
|
|
import org.springframework.data.redis.serializer.RedisSerializer;
|
|
import org.springframework.data.redis.serializer.RedisSerializer;
|
|
|
import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|
import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|
@@ -21,62 +18,63 @@ import java.net.UnknownHostException;
|
|
|
import java.time.Duration;
|
|
import java.time.Duration;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
- * Description:
|
|
|
|
|
|
|
+ * Redis 配置。
|
|
|
|
|
+ *
|
|
|
|
|
+ * <p>Spring Boot 4 / Jackson 3 迁移说明:Jackson 3 的 ObjectMapper 不可变,
|
|
|
|
|
+ * 原来的 {@code new ObjectMapper().setVisibility(..).enableDefaultTyping(..)} 写法已不可用;
|
|
|
|
|
+ * Spring Data Redis 4 对应提供 {@link GenericJacksonJsonRedisSerializer}(自带类型信息,
|
|
|
|
|
+ * 等价于 Jackson 2 的 GenericJackson2JsonRedisSerializer),由 builder 构建,不再手工配置 mapper。
|
|
|
*
|
|
*
|
|
|
* @author tanlie
|
|
* @author tanlie
|
|
|
- * Date: 2024/1/9 9:07
|
|
|
|
|
*/
|
|
*/
|
|
|
@EnableCaching
|
|
@EnableCaching
|
|
|
@Configuration
|
|
@Configuration
|
|
|
public class RedisConfig {
|
|
public class RedisConfig {
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 带类型信息的 JSON 序列化器:反序列化能还原成原始类型(与原 enableDefaultTyping(NON_FINAL) 行为一致)。
|
|
|
|
|
+ * 仅用于内网 Redis、缓存内容由本服务写入,故沿用无白名单校验的 default typing。
|
|
|
|
|
+ */
|
|
|
|
|
+ static RedisSerializer<Object> jsonSerializer() {
|
|
|
|
|
+ return GenericJacksonJsonRedisSerializer.builder()
|
|
|
|
|
+ .enableUnsafeDefaultTyping()
|
|
|
|
|
+ .build();
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 缓存管理器
|
|
* 缓存管理器
|
|
|
- *
|
|
|
|
|
- * @param factory
|
|
|
|
|
- * @return
|
|
|
|
|
*/
|
|
*/
|
|
|
@Bean
|
|
@Bean
|
|
|
- @SuppressWarnings("all")
|
|
|
|
|
public RedisCacheManager cacheManager(RedisConnectionFactory factory) {
|
|
public RedisCacheManager cacheManager(RedisConnectionFactory factory) {
|
|
|
- ObjectMapper om = new ObjectMapper();
|
|
|
|
|
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
|
|
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
|
|
|
- Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
|
|
|
|
|
- // 解决查询缓存转换异常的问题
|
|
|
|
|
- om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
|
|
|
|
- om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
|
|
|
|
|
- jackson2JsonRedisSerializer.setObjectMapper(om);
|
|
|
|
|
|
|
+ RedisSerializer<Object> valueSerializer = jsonSerializer();
|
|
|
// 配置序列化(解决乱码的问题)
|
|
// 配置序列化(解决乱码的问题)
|
|
|
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
|
|
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
|
|
|
.entryTtl(Duration.ofMillis(-1))
|
|
.entryTtl(Duration.ofMillis(-1))
|
|
|
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
|
|
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
|
|
|
- .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
|
|
|
|
|
|
|
+ .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(valueSerializer))
|
|
|
.disableCachingNullValues();
|
|
.disableCachingNullValues();
|
|
|
RedisCacheWriter cacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(factory);
|
|
RedisCacheWriter cacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(factory);
|
|
|
|
|
|
|
|
return new RedisConfigCacheManager(cacheWriter, config);
|
|
return new RedisConfigCacheManager(cacheWriter, config);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- //重写template配置累
|
|
|
|
|
|
|
+ /** 通用 RedisTemplate(业务侧主要用 StringRedisTemplate,本 bean 供缓存/自定义场景) */
|
|
|
@Bean
|
|
@Bean
|
|
|
- @SuppressWarnings("all")
|
|
|
|
|
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) throws UnknownHostException {
|
|
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) throws UnknownHostException {
|
|
|
|
|
|
|
|
- RedisTemplate<String, Object> template = new RedisTemplate();
|
|
|
|
|
|
|
+ RedisTemplate<String, Object> template = new RedisTemplate<>();
|
|
|
template.setConnectionFactory(factory);
|
|
template.setConnectionFactory(factory);
|
|
|
- //json序列化
|
|
|
|
|
- Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
|
|
|
|
|
- ObjectMapper om = new ObjectMapper();
|
|
|
|
|
- om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
|
|
|
|
- om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
|
|
|
|
|
- jackson2JsonRedisSerializer.setObjectMapper(om);
|
|
|
|
|
- //String 序列化
|
|
|
|
|
|
|
+ // json 序列化
|
|
|
|
|
+ RedisSerializer<Object> valueSerializer = jsonSerializer();
|
|
|
|
|
+ // String 序列化
|
|
|
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
|
|
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
|
|
|
- //key 采用string序列化
|
|
|
|
|
|
|
+ // key 采用 string 序列化
|
|
|
template.setKeySerializer(stringRedisSerializer);
|
|
template.setKeySerializer(stringRedisSerializer);
|
|
|
- template.setHashKeySerializer(stringRedisSerializer); //hash key也采用string
|
|
|
|
|
- //value 采用json
|
|
|
|
|
- template.setValueSerializer(jackson2JsonRedisSerializer);
|
|
|
|
|
- template.setHashValueSerializer(jackson2JsonRedisSerializer);
|
|
|
|
|
|
|
+ template.setHashKeySerializer(stringRedisSerializer); // hash key 也采用 string
|
|
|
|
|
+ // value 采用 json
|
|
|
|
|
+ template.setValueSerializer(valueSerializer);
|
|
|
|
|
+ template.setHashValueSerializer(valueSerializer);
|
|
|
|
|
|
|
|
template.afterPropertiesSet();
|
|
template.afterPropertiesSet();
|
|
|
return template;
|
|
return template;
|
|
@@ -87,4 +85,4 @@ public class RedisConfig {
|
|
|
return new StringRedisTemplate(factory);
|
|
return new StringRedisTemplate(factory);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-}
|
|
|
|
|
|
|
+}
|