|
|
@@ -1,8 +1,7 @@
|
|
|
package cn.qinys.platform.base.redis;
|
|
|
|
|
|
-import com.fasterxml.jackson.annotation.JsonAutoDetect;
|
|
|
-import com.fasterxml.jackson.annotation.PropertyAccessor;
|
|
|
-import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
+
|
|
|
+import jakarta.annotation.Resource;
|
|
|
import org.springframework.cache.annotation.EnableCaching;
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
@@ -12,12 +11,9 @@ import org.springframework.data.redis.cache.RedisCacheWriter;
|
|
|
import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
|
|
-import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
|
|
|
import org.springframework.data.redis.serializer.RedisSerializationContext;
|
|
|
import org.springframework.data.redis.serializer.RedisSerializer;
|
|
|
-import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|
|
|
|
|
-import java.net.UnknownHostException;
|
|
|
import java.time.Duration;
|
|
|
|
|
|
/**
|
|
|
@@ -29,61 +25,43 @@ import java.time.Duration;
|
|
|
@EnableCaching
|
|
|
@Configuration
|
|
|
public class RedisConfig {
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private RedisConnectionFactory factory;
|
|
|
/**
|
|
|
* 缓存管理器
|
|
|
- *
|
|
|
- * @param factory
|
|
|
- * @return
|
|
|
*/
|
|
|
@Bean
|
|
|
- @SuppressWarnings("all")
|
|
|
- public RedisCacheManager cacheManager(RedisConnectionFactory factory) {
|
|
|
- ObjectMapper om = new ObjectMapper();
|
|
|
- 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);
|
|
|
- // 配置序列化(解决乱码的问题)
|
|
|
+ public RedisCacheManager cacheManager() {
|
|
|
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
|
|
|
.entryTtl(Duration.ofMillis(-1))
|
|
|
- .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
|
|
|
- .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
|
|
|
+ .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(RedisSerializer.string()))
|
|
|
+ .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(RedisSerializer.json()))
|
|
|
.disableCachingNullValues();
|
|
|
- RedisCacheWriter cacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(factory);
|
|
|
|
|
|
+ RedisCacheWriter cacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(factory);
|
|
|
return new RedisConfigCacheManager(cacheWriter, config);
|
|
|
}
|
|
|
|
|
|
- //重写template配置累
|
|
|
+ /**
|
|
|
+ * RedisTemplate 配置
|
|
|
+ */
|
|
|
@Bean
|
|
|
- @SuppressWarnings("all")
|
|
|
- public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) throws UnknownHostException {
|
|
|
-
|
|
|
- RedisTemplate<String, Object> template = new RedisTemplate();
|
|
|
+ public RedisTemplate<String, Object> redisTemplate() {
|
|
|
+ RedisTemplate<String, Object> template = new RedisTemplate<>();
|
|
|
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 序列化
|
|
|
- StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
|
|
|
- //key 采用string序列化
|
|
|
- template.setKeySerializer(stringRedisSerializer);
|
|
|
- template.setHashKeySerializer(stringRedisSerializer); //hash key也采用string
|
|
|
- //value 采用json
|
|
|
- template.setValueSerializer(jackson2JsonRedisSerializer);
|
|
|
- template.setHashValueSerializer(jackson2JsonRedisSerializer);
|
|
|
+
|
|
|
+ template.setKeySerializer(RedisSerializer.string());
|
|
|
+ template.setHashKeySerializer(RedisSerializer.string());
|
|
|
+ template.setValueSerializer(RedisSerializer.json());
|
|
|
+ template.setHashValueSerializer(RedisSerializer.json());
|
|
|
|
|
|
template.afterPropertiesSet();
|
|
|
return template;
|
|
|
}
|
|
|
|
|
|
@Bean
|
|
|
- public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory factory) {
|
|
|
+ public StringRedisTemplate stringRedisTemplate() {
|
|
|
return new StringRedisTemplate(factory);
|
|
|
}
|
|
|
|