package com.thhy.general.config.redis;
|
|
import org.redisson.Redisson;
|
import org.redisson.api.RedissonClient;
|
import org.redisson.codec.JsonJacksonCodec;
|
import org.redisson.config.Config;
|
import org.redisson.config.SingleServerConfig;
|
import org.redisson.spring.cache.CacheConfig;
|
import org.redisson.spring.cache.RedissonSpringCacheManager;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
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.util.StringUtils;
|
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Configuration
|
@EnableCaching
|
@ConditionalOnProperty(prefix="redisson",name = "enable", havingValue = "true")
|
public class RedissonConfig {
|
|
@Bean(destroyMethod = "shutdown")
|
RedissonClient redissonClient(RedissonProperties redssionProperties) {
|
Config config = new Config().setCodec(new JsonJacksonCodec());
|
SingleServerConfig singleServerConfig = config.useSingleServer()
|
.setAddress(redssionProperties.getAddress())//连接地址
|
.setConnectTimeout(redssionProperties.getConnectTimeout())//连接超时
|
.setTimeout(redssionProperties.getTimeout())//Redis服务器响应超时
|
.setConnectionPoolSize(redssionProperties.getConnectionPoolSize())//Redis连接的最大池大小
|
.setConnectionMinimumIdleSize(redssionProperties.getConnectionMinimumIdleSize())//最小空闲Redis连接量
|
.setRetryAttempts(redssionProperties.getRetryAttempts())//命令失败重试次数
|
.setRetryInterval(redssionProperties.getRetryInterval());//命令重试发送时间间隔
|
if (!StringUtils.isEmpty(redssionProperties.getPassword())) {
|
singleServerConfig.setPassword(redssionProperties.getPassword());
|
}
|
/*ObjectMapper om = new ObjectMapper();
|
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
// 解决jackson2无法反序列化LocalDateTime的问题
|
om.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
|
om.registerModule(new JavaTimeModule());
|
config.setCodec(new JsonJacksonCodec(om));*/
|
return Redisson.create(config);
|
}
|
|
@Primary
|
@Bean
|
CacheManager redissonCacheManager(RedissonClient redissonClient, RedissonProperties redssionProperties) {
|
RedissonProperties.RedissonCache redissonCache = redssionProperties.getRedissonCache();
|
String cacheConfigs = redissonCache.getCacheConfigs()==null?"secure:userInfo&2592000000,secure:interfaceAuth&315360000000,secure:interfaceVersion&315360000000":redissonCache.getCacheConfigs()+",secure:userInfo&2592000000,secure:interfaceAuth&315360000000,secure:interfaceVersion&315360000000";
|
Map<String, CacheConfig> configMap = new HashMap<>();
|
if(!cacheConfigs.trim().equals("".trim())){
|
//如果有缓存配置，则逐个加入到管理器
|
String[] cacheConfigsArray = cacheConfigs.split(",");
|
Arrays.stream(cacheConfigsArray).forEach(cacheConfig -> {
|
String[] params = cacheConfig.split("&");
|
String cacheName = params[0];//缓存名字
|
CacheConfig config = new CacheConfig();
|
//如果设置了TTL
|
if(params.length>1){
|
config.setTTL(Long.valueOf(params[1]));
|
//如果设置了MaxIdleTime
|
if(params.length>2){
|
config.setMaxIdleTime(Long.valueOf(params[2]));
|
}else {
|
//如果没设置MaxIdleTime，则使用和TTL一样的值
|
config.setMaxIdleTime(Long.valueOf(params[1]));
|
}
|
}else{
|
//如果没设置TTL和MaxIdleTime，则使用默认值
|
config.setTTL(redssionProperties.getRedissonCacheDefault());
|
config.setMaxIdleTime(redssionProperties.getRedissonCacheDefault());
|
}
|
configMap.put(cacheName, config);
|
});
|
}
|
return new RedissonSpringCacheManager(redissonClient, configMap, new JsonJacksonCodec());
|
}
|
}
|
