116 lines
4.9 KiB
Java
116 lines
4.9 KiB
Java
package com.zhgd.redis.config;
|
||
|
||
import com.fasterxml.jackson.annotation.JsonAutoDetect;
|
||
import com.fasterxml.jackson.annotation.PropertyAccessor;
|
||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||
import com.zhgd.redis.lock.RedisRepository;
|
||
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
||
import org.springframework.cache.annotation.EnableCaching;
|
||
import org.springframework.cache.interceptor.KeyGenerator;
|
||
import org.springframework.context.annotation.Bean;
|
||
import org.springframework.context.annotation.Configuration;
|
||
import org.springframework.data.redis.cache.RedisCacheConfiguration;
|
||
import org.springframework.data.redis.cache.RedisCacheManager;
|
||
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.serializer.Jackson2JsonRedisSerializer;
|
||
import org.springframework.data.redis.serializer.RedisSerializationContext;
|
||
import org.springframework.data.redis.serializer.StringRedisSerializer;
|
||
|
||
import java.time.Duration;
|
||
|
||
/**
|
||
* @program: wisdomSite
|
||
* @description: redis配置
|
||
* @author: Mr.Peng
|
||
* @create: 2021-07-26 17:38
|
||
**/
|
||
//@EnableConfigurationProperties({RedisProperties.class})
|
||
@Configuration
|
||
@EnableCaching
|
||
public class RedisConfig {
|
||
|
||
/**
|
||
* 定义缓存
|
||
* @param redisTemplate
|
||
* @return
|
||
*/
|
||
@Bean
|
||
public RedisCacheManager redisCacheManager(RedisTemplate redisTemplate) {
|
||
// 初始化一个RedisCacheWriter
|
||
RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisTemplate.getConnectionFactory());
|
||
// 设置默认过期时间30M
|
||
RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
|
||
.computePrefixWith(cacheName -> "cache".concat(":").concat(cacheName).concat(":"))
|
||
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
|
||
//.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new RedisObjectSerializer()));
|
||
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisTemplate.getValueSerializer()))
|
||
//.entryTtl(Duration.ofMinutes(30L))
|
||
.entryTtl(Duration.ofHours(1));
|
||
// .disableCachingNullValues();
|
||
// 初始化RedisCacheManager
|
||
RedisCacheManager redisCacheManager = new RedisCacheManager(redisCacheWriter, redisCacheConfiguration);
|
||
return redisCacheManager;
|
||
}
|
||
|
||
|
||
/**
|
||
* retemplate相关配置
|
||
* springboot2.x 之后默认使用lettuce客户端连接（线程安全）
|
||
*
|
||
* @param factory
|
||
* @return
|
||
*/
|
||
@Bean(name = "redisTemplate")
|
||
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
|
||
|
||
RedisTemplate<String, Object> template = new RedisTemplate<>();
|
||
// 配置连接工厂
|
||
template.setConnectionFactory(factory);
|
||
//使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）
|
||
Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);
|
||
ObjectMapper om = new ObjectMapper();
|
||
// 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
|
||
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
||
// 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会跑出异常
|
||
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
|
||
jacksonSeial.setObjectMapper(om);
|
||
|
||
//使用StringRedisSerializer来序列化和反序列化redis的key值
|
||
template.setKeySerializer(new StringRedisSerializer());
|
||
// 值采用json序列化
|
||
template.setValueSerializer(jacksonSeial);
|
||
// 设置hash key 和value序列化模式
|
||
template.setHashKeySerializer(new StringRedisSerializer());
|
||
template.setHashValueSerializer(jacksonSeial);
|
||
template.afterPropertiesSet();
|
||
return template;
|
||
}
|
||
|
||
/**
|
||
* Redis repository redis repository.
|
||
*
|
||
* @param redisTemplate the redis template
|
||
* @return the redis repository
|
||
*/
|
||
@Bean
|
||
@ConditionalOnMissingBean
|
||
public RedisRepository redisRepository(RedisTemplate<String, Object> redisTemplate) {
|
||
return new RedisRepository(redisTemplate);
|
||
}
|
||
|
||
@Bean
|
||
public KeyGenerator keyGenerator() {
|
||
return (target, method, objects) -> {
|
||
StringBuilder sb = new StringBuilder();
|
||
sb.append(target.getClass().getName());
|
||
sb.append(":" + method.getName() + ":");
|
||
for (Object obj : objects) {
|
||
sb.append(obj.toString());
|
||
}
|
||
return sb.toString();
|
||
};
|
||
}
|
||
}
|