refactor(redisConfig): 1.redis配置代码重构

Author: yaozhichao

mqtt-broker/src/main/java/joey/mqtt/broker/redis/RedisFactory.java

@@ -5,6 +5,8 @@
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPoolConfig;
 
+import java.time.Duration;
+
 /**
  * redis工厂
  * @author Joey
@@ -23,29 +25,31 @@ private RedisFactory() {
      */
     public static RedisClient createRedisClient(RedisConfig redisConfig) {
         JedisPoolConfig config = new JedisPoolConfig();
-        //最大空闲连接数, 默认8个
-        config.setMaxIdle(redisConfig.getPool().getMaxIdle());
 
-        //最大连接数, 默认8个
-        config.setMaxTotal(redisConfig.getPool().getMaxActive());
+        // 最大空闲连接数, 默认8个
+        RedisConfig.Pool pool = redisConfig.getPool();
+        config.setMaxIdle(pool.getMaxIdle());
+
+        // 最大连接数, 默认8个
+        config.setMaxTotal(pool.getMaxActive());
 
-        //获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间,  默认-1
-        config.setMaxWaitMillis(redisConfig.getPool().getMaxWait());
+        // 获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间,  默认-1
+        config.setMaxWait(Duration.ofMillis(pool.getMaxWait()));
 
-        //逐出连接的最小空闲时间 默认1800000毫秒(30分钟)
-        config.setMinEvictableIdleTimeMillis(redisConfig.getPool().getMinEvictableIdleTimeMillis());
+        // 逐出连接的最小空闲时间 默认1800000毫秒(30分钟)
+        config.setMinEvictableIdleTime(Duration.ofMillis(pool.getMinEvictableIdleTimeMillis()));
 
-        //最小空闲连接数, 默认0
-        config.setMinIdle(redisConfig.getPool().getMinIdle());
+        // 最小空闲连接数, 默认0
+        config.setMinIdle(pool.getMinIdle());
 
-        //在获取连接的时候检查有效性, 默认false
-        config.setTestOnBorrow(redisConfig.getPool().isTestOnBorrow());
+        // 在获取连接的时候检查有效性, 默认false
+        config.setTestOnBorrow(pool.isTestOnBorrow());
 
-        //在空闲时检查有效性, 默认false
-        config.setTestWhileIdle(redisConfig.getPool().isTestWhileIdle());
+        // 在空闲时检查有效性, 默认false
+        config.setTestWhileIdle(pool.isTestWhileIdle());
 
-        //逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
-        config.setTimeBetweenEvictionRunsMillis(redisConfig.getPool().getTimeBetweenEvictionRunsMillis());
+        // 逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
+        config.setTimeBetweenEvictionRuns(Duration.ofMillis(pool.getTimeBetweenEvictionRunsMillis()));
 
         String password = StrUtil.trimToNull(redisConfig.getPassword());
         JedisPool jedisPool = new JedisPool(config, redisConfig.getHost(),