| | |
|---|
| | | package com.ruoyi.framework.config;
|
|---|
| | |
|
|---|
| | | import org.springframework.cache.annotation.CachingConfigurerSupport;
|
|---|
| | | import org.springframework.cache.annotation.EnableCaching;
|
|---|
| | | import org.springframework.context.annotation.Bean;
|
|---|
| | | import org.springframework.context.annotation.Configuration;
|
|---|
| | | import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|---|
| | | import org.springframework.data.redis.core.RedisTemplate;
|
|---|
| | | import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|---|
| | | import com.fasterxml.jackson.annotation.JsonAutoDetect;
|
|---|
| | | import com.fasterxml.jackson.annotation.JsonTypeInfo;
|
|---|
| | | import com.fasterxml.jackson.annotation.PropertyAccessor;
|
|---|
| | | import com.fasterxml.jackson.databind.ObjectMapper;
|
|---|
| | | import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * redis配置
|
|---|
| | | * |
|---|
| | | * @author ruoyi
|
|---|
| | | */
|
|---|
| | | @Configuration
|
|---|
| | | @EnableCaching
|
|---|
| | | public class RedisConfig extends CachingConfigurerSupport
|
|---|
| | | {
|
|---|
| | | @Bean
|
|---|
| | | @SuppressWarnings(value = { "unchecked", "rawtypes" })
|
|---|
| | | public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory)
|
|---|
| | | {
|
|---|
| | | RedisTemplate<Object, Object> template = new RedisTemplate<>();
|
|---|
| | | template.setConnectionFactory(connectionFactory);
|
|---|
| | |
|
|---|
| | | FastJson2JsonRedisSerializer serializer = new FastJson2JsonRedisSerializer(Object.class);
|
|---|
| | |
|
|---|
| | | ObjectMapper mapper = new ObjectMapper();
|
|---|
| | | mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
|---|
| | | mapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
|
|---|
| | | serializer.setObjectMapper(mapper);
|
|---|
| | |
|
|---|
| | | template.setValueSerializer(serializer);
|
|---|
| | | // 使用StringRedisSerializer来序列化和反序列化redis的key值
|
|---|
| | | template.setKeySerializer(new StringRedisSerializer());
|
|---|
| | | template.afterPropertiesSet();
|
|---|
| | | return template;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | package com.ruoyi.framework.config; |
|---|
| | | |
|---|
| | | import cn.hutool.core.util.ObjectUtil; |
|---|
| | | import com.ruoyi.common.utils.StringUtils; |
|---|
| | | import com.ruoyi.framework.config.properties.RedissonProperties; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.redisson.Redisson; |
|---|
| | | import org.redisson.api.RedissonClient; |
|---|
| | | import org.redisson.codec.JsonJacksonCodec; |
|---|
| | | import org.redisson.config.Config; |
|---|
| | | import org.redisson.spring.cache.CacheConfig; |
|---|
| | | import org.redisson.spring.cache.RedissonSpringCacheManager; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.boot.autoconfigure.data.redis.RedisProperties; |
|---|
| | | import org.springframework.cache.CacheManager; |
|---|
| | | import org.springframework.cache.annotation.CachingConfigurerSupport; |
|---|
| | | 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 java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * redis配置 |
|---|
| | | * |
|---|
| | | * @author Lion Li |
|---|
| | | */ |
|---|
| | | @Slf4j |
|---|
| | | @Configuration |
|---|
| | | @EnableCaching |
|---|
| | | public class RedisConfig extends CachingConfigurerSupport { |
|---|
| | | |
|---|
| | | private static final String REDIS_PROTOCOL_PREFIX = "redis://"; |
|---|
| | | private static final String REDISS_PROTOCOL_PREFIX = "rediss://"; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private RedisProperties redisProperties; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private RedissonProperties redissonProperties; |
|---|
| | | |
|---|
| | | @Primary |
|---|
| | | @Bean(destroyMethod = "shutdown") |
|---|
| | | public RedissonClient redisson() { |
|---|
| | | String prefix = REDIS_PROTOCOL_PREFIX; |
|---|
| | | if (redisProperties.isSsl()) { |
|---|
| | | prefix = REDISS_PROTOCOL_PREFIX; |
|---|
| | | } |
|---|
| | | Config config = new Config(); |
|---|
| | | config.setThreads(redissonProperties.getThreads()) |
|---|
| | | .setNettyThreads(redissonProperties.getNettyThreads()) |
|---|
| | | .setCodec(JsonJacksonCodec.INSTANCE); |
|---|
| | | |
|---|
| | | RedissonProperties.SingleServerConfig singleServerConfig = redissonProperties.getSingleServerConfig(); |
|---|
| | | if (ObjectUtil.isNotNull(singleServerConfig)) { |
|---|
| | | // 使用单机模式 |
|---|
| | | config.useSingleServer() |
|---|
| | | .setAddress(prefix + redisProperties.getHost() + ":" + redisProperties.getPort()) |
|---|
| | | .setConnectTimeout(((Long) redisProperties.getTimeout().toMillis()).intValue()) |
|---|
| | | .setDatabase(redisProperties.getDatabase()) |
|---|
| | | .setPassword(StringUtils.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null) |
|---|
| | | .setTimeout(singleServerConfig.getTimeout()) |
|---|
| | | .setClientName(singleServerConfig.getClientName()) |
|---|
| | | .setIdleConnectionTimeout(singleServerConfig.getIdleConnectionTimeout()) |
|---|
| | | .setSubscriptionConnectionPoolSize(singleServerConfig.getSubscriptionConnectionPoolSize()) |
|---|
| | | .setConnectionMinimumIdleSize(singleServerConfig.getConnectionMinimumIdleSize()) |
|---|
| | | .setConnectionPoolSize(singleServerConfig.getConnectionPoolSize()); |
|---|
| | | } |
|---|
| | | // 集群配置方式 参考下方注释 |
|---|
| | | RedissonProperties.ClusterServersConfig clusterServersConfig = redissonProperties.getClusterServersConfig(); |
|---|
| | | if (ObjectUtil.isNotNull(clusterServersConfig)) { |
|---|
| | | // 使用集群模式 |
|---|
| | | String finalPrefix = prefix; |
|---|
| | | List<String> nodes = redisProperties.getCluster().getNodes() |
|---|
| | | .stream() |
|---|
| | | .map(node -> finalPrefix + node) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | config.useClusterServers() |
|---|
| | | .setConnectTimeout(((Long) redisProperties.getTimeout().toMillis()).intValue()) |
|---|
| | | .setPassword(StringUtils.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null) |
|---|
| | | .setTimeout(clusterServersConfig.getTimeout()) |
|---|
| | | .setClientName(clusterServersConfig.getClientName()) |
|---|
| | | .setIdleConnectionTimeout(clusterServersConfig.getIdleConnectionTimeout()) |
|---|
| | | .setSubscriptionConnectionPoolSize(clusterServersConfig.getSubscriptionConnectionPoolSize()) |
|---|
| | | .setMasterConnectionMinimumIdleSize(clusterServersConfig.getMasterConnectionMinimumIdleSize()) |
|---|
| | | .setMasterConnectionPoolSize(clusterServersConfig.getMasterConnectionPoolSize()) |
|---|
| | | .setSlaveConnectionMinimumIdleSize(clusterServersConfig.getSlaveConnectionMinimumIdleSize()) |
|---|
| | | .setSlaveConnectionPoolSize(clusterServersConfig.getSlaveConnectionPoolSize()) |
|---|
| | | .setReadMode(clusterServersConfig.getReadMode()) |
|---|
| | | .setSubscriptionMode(clusterServersConfig.getSubscriptionMode()) |
|---|
| | | .setNodeAddresses(nodes); |
|---|
| | | } |
|---|
| | | RedissonClient redissonClient = Redisson.create(config); |
|---|
| | | log.info("初始化 redis 配置"); |
|---|
| | | return redissonClient; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 整合spring-cache |
|---|
| | | */ |
|---|
| | | @Bean |
|---|
| | | public CacheManager cacheManager(RedissonClient redissonClient) { |
|---|
| | | List<RedissonProperties.CacheGroup> cacheGroup = redissonProperties.getCacheGroup(); |
|---|
| | | Map<String, CacheConfig> config = new HashMap<>(); |
|---|
| | | for (RedissonProperties.CacheGroup group : cacheGroup) { |
|---|
| | | CacheConfig cacheConfig = new CacheConfig(group.getTtl(), group.getMaxIdleTime()); |
|---|
| | | cacheConfig.setMaxSize(group.getMaxSize()); |
|---|
| | | config.put(group.getGroupId(), cacheConfig); |
|---|
| | | } |
|---|
| | | return new RedissonSpringCacheManager(redissonClient, config, JsonJacksonCodec.INSTANCE); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * redis集群配置 yml |
|---|
| | | * |
|---|
| | | * --- # redis 集群配置(单机与集群只能开启一个另一个需要注释掉) |
|---|
| | | * spring: |
|---|
| | | * redis: |
|---|
| | | * cluster: |
|---|
| | | * nodes: |
|---|
| | | * - 192.168.0.100:6379 |
|---|
| | | * - 192.168.0.101:6379 |
|---|
| | | * - 192.168.0.102:6379 |
|---|
| | | * # 密码 |
|---|
| | | * password: |
|---|
| | | * # 连接超时时间 |
|---|
| | | * timeout: 10s |
|---|
| | | * # 是否开启ssl |
|---|
| | | * ssl: false |
|---|
| | | * |
|---|
| | | * redisson: |
|---|
| | | * # 线程池数量 |
|---|
| | | * threads: 16 |
|---|
| | | * # Netty线程池数量 |
|---|
| | | * nettyThreads: 32 |
|---|
| | | * # 集群配置 |
|---|
| | | * clusterServersConfig: |
|---|
| | | * # 客户端名称 |
|---|
| | | * clientName: ${ruoyi.name} |
|---|
| | | * # master最小空闲连接数 |
|---|
| | | * masterConnectionMinimumIdleSize: 32 |
|---|
| | | * # master连接池大小 |
|---|
| | | * masterConnectionPoolSize: 64 |
|---|
| | | * # slave最小空闲连接数 |
|---|
| | | * slaveConnectionMinimumIdleSize: 32 |
|---|
| | | * # slave连接池大小 |
|---|
| | | * slaveConnectionPoolSize: 64 |
|---|
| | | * # 连接空闲超时，单位：毫秒 |
|---|
| | | * idleConnectionTimeout: 10000 |
|---|
| | | * # 命令等待超时，单位：毫秒 |
|---|
| | | * timeout: 3000 |
|---|
| | | * # 发布和订阅连接池大小 |
|---|
| | | * subscriptionConnectionPoolSize: 50 |
|---|
| | | * # 读取模式 |
|---|
| | | * readMode: "SLAVE" |
|---|
| | | * # 订阅模式 |
|---|
| | | * subscriptionMode: "MASTER" |
|---|
| | | */ |
|---|
| | | |
|---|
| | | } |
|---|
