兰宝车间质量管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
602003139@qq.com
2021-10-21 2489c46a7ffe23a95da201a35c40424f2b79dba2 
 ruoyi-framework/src/main/java/com/ruoyi/framework/config/RedisConfig.java


@@ -1,7 +1,9 @@


package com.ruoyi.framework.config;




import cn.hutool.core.util.StrUtil;


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;


@@ -19,6 +21,7 @@




import java.io.IOException;


import java.util.HashMap;


import java.util.List;


import java.util.Map;




/**


@@ -26,6 +29,7 @@


 *


 * @author Lion Li


 */


@Slf4j


@Configuration


@EnableCaching


public class RedisConfig extends CachingConfigurerSupport {


@@ -53,24 +57,55 @@


         .setTransportMode(redissonProperties.getTransportMode());




      RedissonProperties.SingleServerConfig singleServerConfig = redissonProperties.getSingleServerConfig();


      // 使用单机模式


      config.useSingleServer()


         .setAddress(prefix + redisProperties.getHost() + ":" + redisProperties.getPort())


         .setConnectTimeout(((Long) redisProperties.getTimeout().toMillis()).intValue())


         .setDatabase(redisProperties.getDatabase())


         .setPassword(StrUtil.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null)


         .setTimeout(singleServerConfig.getTimeout())


         .setRetryAttempts(singleServerConfig.getRetryAttempts())


         .setRetryInterval(singleServerConfig.getRetryInterval())


         .setSubscriptionsPerConnection(singleServerConfig.getSubscriptionsPerConnection())


         .setClientName(singleServerConfig.getClientName())


         .setIdleConnectionTimeout(singleServerConfig.getIdleConnectionTimeout())


         .setSubscriptionConnectionMinimumIdleSize(singleServerConfig.getSubscriptionConnectionMinimumIdleSize())


         .setSubscriptionConnectionPoolSize(singleServerConfig.getSubscriptionConnectionPoolSize())


         .setConnectionMinimumIdleSize(singleServerConfig.getConnectionMinimumIdleSize())


         .setConnectionPoolSize(singleServerConfig.getConnectionPoolSize())


         .setDnsMonitoringInterval(singleServerConfig.getDnsMonitoringInterval());


      return Redisson.create(config);


      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())


               .setRetryAttempts(singleServerConfig.getRetryAttempts())


               .setRetryInterval(singleServerConfig.getRetryInterval())


               .setSubscriptionsPerConnection(singleServerConfig.getSubscriptionsPerConnection())


               .setClientName(singleServerConfig.getClientName())


               .setIdleConnectionTimeout(singleServerConfig.getIdleConnectionTimeout())


               .setSubscriptionConnectionMinimumIdleSize(singleServerConfig.getSubscriptionConnectionMinimumIdleSize())


               .setSubscriptionConnectionPoolSize(singleServerConfig.getSubscriptionConnectionPoolSize())


               .setConnectionMinimumIdleSize(singleServerConfig.getConnectionMinimumIdleSize())


               .setConnectionPoolSize(singleServerConfig.getConnectionPoolSize())


               .setDnsMonitoringInterval(singleServerConfig.getDnsMonitoringInterval());


      }




      RedissonProperties.ClusterServersConfig clusterServersConfig = redissonProperties.getClusterServersConfig();


      if (ObjectUtil.isNotNull(clusterServersConfig)) {


         // 使用集群模式


         config.useClusterServers()


               .setConnectTimeout(((Long) redisProperties.getTimeout().toMillis()).intValue())


               .setPassword(StringUtils.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null)


               .setTimeout(clusterServersConfig.getTimeout())


               .setRetryAttempts(clusterServersConfig.getRetryAttempts())


               .setRetryInterval(clusterServersConfig.getRetryInterval())


               .setSubscriptionsPerConnection(clusterServersConfig.getSubscriptionsPerConnection())


               .setClientName(clusterServersConfig.getClientName())


               .setIdleConnectionTimeout(clusterServersConfig.getIdleConnectionTimeout())


               .setPingConnectionInterval(clusterServersConfig.getPingConnectionInterval())


               .setSubscriptionConnectionMinimumIdleSize(clusterServersConfig.getSubscriptionConnectionMinimumIdleSize())


               .setSubscriptionConnectionPoolSize(clusterServersConfig.getSubscriptionConnectionPoolSize())


               .setMasterConnectionMinimumIdleSize(clusterServersConfig.getMasterConnectionMinimumIdleSize())


               .setMasterConnectionPoolSize(clusterServersConfig.getMasterConnectionPoolSize())


               .setSlaveConnectionMinimumIdleSize(clusterServersConfig.getSlaveConnectionMinimumIdleSize())


               .setSlaveConnectionPoolSize(clusterServersConfig.getSlaveConnectionPoolSize())


               .setDnsMonitoringInterval(clusterServersConfig.getDnsMonitoringInterval())


               .setFailedSlaveReconnectionInterval(clusterServersConfig.getFailedSlaveReconnectionInterval())


               .setScanInterval(clusterServersConfig.getScanInterval())


               .setReadMode(clusterServersConfig.getReadMode())


               .setSubscriptionMode(clusterServersConfig.getSubscriptionMode())


               .setNodeAddresses(redisProperties.getCluster().getNodes());


      }


      RedissonClient redissonClient = Redisson.create(config);


      log.info("初始化 redis 配置");


      return redissonClient;


   }




   /**


@@ -78,8 +113,13 @@


    */


   @Bean


   public CacheManager cacheManager(RedissonClient redissonClient) {


      List<RedissonProperties.CacheGroup> cacheGroup = redissonProperties.getCacheGroup();


      Map<String, CacheConfig> config = new HashMap<>();


      config.put("redissonCacheMap", new CacheConfig(30*60*1000, 10*60*1000));


      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);


   }