!201 redission处理增加前缀 * redission处理判断无前缀则不处理 * redission处理增加前缀

抓蛙师

2022-07-14 ce7536df9f82833044c9cbc479f0de42de2beffe

 ruoyi-framework/src/main/java/com/ruoyi/framework/config/properties/RedissonProperties.java

@@ -4,7 +4,6 @@
import lombok.NoArgsConstructor;
import org.redisson.config.ReadMode;
import org.redisson.config.SubscriptionMode;
import org.redisson.config.TransportMode;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@@ -19,218 +18,153 @@
@Component
@ConfigurationProperties(prefix = "redisson")
public class RedissonProperties {
    
    /**
     * redis缓存key前缀
     */
    private String keyPrefix;
    
    /**
     * 线程池数量,默认值 = 当前处理核数量 * 2
     */
    private int threads;

   /**
    * 线程池数量,默认值 = 当前处理核数量 * 2
    */
   private int threads;
    /**
     * Netty线程池数量,默认值 = 当前处理核数量 * 2
     */
    private int nettyThreads;

   /**
    * Netty线程池数量,默认值 = 当前处理核数量 * 2
    */
   private int nettyThreads;
    /**
     * 单机服务配置
     */
    private SingleServerConfig singleServerConfig;

   /**
    * 传输模式
    */
   private TransportMode transportMode;
    /**
     * 集群服务配置
     */
    private ClusterServersConfig clusterServersConfig;

   /**
    * 单机服务配置
    */
   private SingleServerConfig singleServerConfig;
    /**
     * 缓存组
     */
    private List<CacheGroup> cacheGroup;

   /**
    * 集群服务配置
    */
   private ClusterServersConfig clusterServersConfig;
    @Data
    @NoArgsConstructor
    public static class SingleServerConfig {

   /**
    * 缓存组
    */
   private List<CacheGroup> cacheGroup;
        /**
         * 客户端名称
         */
        private String clientName;

   @Data
   @NoArgsConstructor
   public static class SingleServerConfig {
        /**
         * 最小空闲连接数
         */
        private int connectionMinimumIdleSize;

      /**
       * 客户端名称
       */
      private String clientName;
        /**
         * 连接池大小
         */
        private int connectionPoolSize;

      /**
       * 最小空闲连接数
       */
      private int connectionMinimumIdleSize;
        /**
         * 连接空闲超时，单位：毫秒
         */
        private int idleConnectionTimeout;

      /**
       * 连接池大小
       */
      private int connectionPoolSize;
        /**
         * 命令等待超时，单位：毫秒
         */
        private int timeout;

      /**
       * 连接空闲超时，单位：毫秒
       */
      private int idleConnectionTimeout;
        /**
         * 发布和订阅连接池大小
         */
        private int subscriptionConnectionPoolSize;

      /**
       * 命令等待超时，单位：毫秒
       */
      private int timeout;
    }

      /**
       * 如果尝试在此限制之内发送成功，则开始启用 timeout 计时。
       */
      private int retryAttempts;
    @Data
    @NoArgsConstructor
    public static class ClusterServersConfig {

      /**
       * 命令重试发送时间间隔，单位：毫秒
       */
      private int retryInterval;
        /**
         * 客户端名称
         */
        private String clientName;

      /**
       * 发布和订阅连接的最小空闲连接数
       */
      private int subscriptionConnectionMinimumIdleSize;
        /**
         * master最小空闲连接数
         */
        private int masterConnectionMinimumIdleSize;

      /**
       * 发布和订阅连接池大小
       */
      private int subscriptionConnectionPoolSize;
        /**
         * master连接池大小
         */
        private int masterConnectionPoolSize;

      /**
       * 单个连接最大订阅数量
       */
      private int subscriptionsPerConnection;
        /**
         * slave最小空闲连接数
         */
        private int slaveConnectionMinimumIdleSize;

      /**
       * DNS监测时间间隔，单位：毫秒
       */
      private int dnsMonitoringInterval;
        /**
         * slave连接池大小
         */
        private int slaveConnectionPoolSize;

   }
        /**
         * 连接空闲超时，单位：毫秒
         */
        private int idleConnectionTimeout;

   @Data
   @NoArgsConstructor
   public static class ClusterServersConfig {
        /**
         * 命令等待超时，单位：毫秒
         */
        private int timeout;

      /**
       * 客户端名称
       */
      private String clientName;
        /**
         * 发布和订阅连接池大小
         */
        private int subscriptionConnectionPoolSize;

      /**
       * master最小空闲连接数
       */
      private int masterConnectionMinimumIdleSize;
        /**
         * 读取模式
         */
        private ReadMode readMode;

      /**
       * master连接池大小
       */
      private int masterConnectionPoolSize;
        /**
         * 订阅模式
         */
        private SubscriptionMode subscriptionMode;

      /**
       * slave最小空闲连接数
       */
      private int slaveConnectionMinimumIdleSize;
    }

      /**
       * slave连接池大小
       */
      private int slaveConnectionPoolSize;
    @Data
    @NoArgsConstructor
    public static class CacheGroup {

      /**
       * 连接空闲超时，单位：毫秒
       */
      private int idleConnectionTimeout;
        /**
         * 组id
         */
        private String groupId;

      /**
       * ping超时
       */
      private int pingConnectionInterval;
        /**
         * 组过期时间
         */
        private long ttl;

      /**
       * 命令等待超时，单位：毫秒
       */
      private int timeout;
        /**
         * 组最大空闲时间
         */
        private long maxIdleTime;

      /**
       * 如果尝试在此限制之内发送成功，则开始启用 timeout 计时。
       */
      private int retryAttempts;
        /**
         * 组最大长度
         */
        private int maxSize;

      /**
       * 命令重试发送时间间隔，单位：毫秒
       */
      private int retryInterval;

      /**
       * 错误重试次数
       */
      private int failedSlaveReconnectionInterval;

      /**
       * 发布和订阅连接池最小空闲连接数
       */
      private int subscriptionConnectionMinimumIdleSize;

      /**
       * 发布和订阅连接池大小
       */
      private int subscriptionConnectionPoolSize;

      /**
       * 单个连接最大订阅数量
       */
      private int subscriptionsPerConnection;

      /**
       * 扫描间隔
       */
      private int scanInterval;

      /**
       * DNS监测时间间隔，单位：毫秒
       */
      private int dnsMonitoringInterval;

      /**
       * 读取模式
       */
      private ReadMode readMode;

      /**
       * 订阅模式
       */
      private SubscriptionMode subscriptionMode;

   }

   @Data
   @NoArgsConstructor
   public static class CacheGroup {

      /**
       * 组id
       */
      private String groupId;

      /**
       * 组过期时间
       */
      private long ttl;

      /**
       * 组最大空闲时间
       */
      private long maxIdleTime;

      /**
       * 组最大长度
       */
      private int maxSize;

   }
    }

}