提交 goblin redis

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisGoblinConfig.java

+package com.liquidnet.common.cache.redis.config;//package com.liquidnet.common.cache.redis.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: RedisConfig
+ * @Package com.liquidnet.common.cache.redis.config
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/8/10 16:28
+ */
+@Slf4j
+@Configuration
+public class RedisGoblinConfig extends AbstractRedisConfig {
+
+    @Value("${spring.redis.goblin.host:null}")
+    private String host;
+    @Value("${spring.redis.goblin.port:-1}")
+    private int port;
+    @Value("${spring.redis.goblin.password:null}")
+    private String password;
+    @Value("${spring.redis.goblin.lettuce.pool.max-active:-1}")
+    private int maxActive;
+    @Value("${spring.redis.goblin.lettuce.pool.max-idle:-1}")
+    private int maxIdle;
+    @Value("${spring.redis.goblin.lettuce.pool.min-idle:-1}")
+    private int minIdle;
+    @Value("${spring.redis.goblin.lettuce.pool.max-wait:-1}")
+    private int maxWait;
+
+    @Value("${spring.redis.goblin.dbs:${spring.redis.goblin.database:-1}}")
+    private List<Integer> dbs;
+
+    String getHost(){
+        return this.host;
+    }
+
+    int getPort(){
+        return this.port;
+    }
+    String getPassword(){
+        return this.password;
+    }
+    int getMaxActive(){
+        return this.maxActive;
+    }
+    int getMaxIdle(){
+        return this.maxIdle;
+    }
+    int getMinIdle(){
+        return this.minIdle;
+    }
+    int getMaxWait(){
+        return this.maxWait;
+    }
+    List<Integer> getDbs(){
+        return this.dbs;
+    }
+}
\ No newline at end of file

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisDataSourceUtil.java

@@ -26,6 +26,9 @@ public class RedisDataSourceUtil {
     @Autowired
     private RedisAdamUtil redisAdamUtil;
 
+    @Autowired
+    private RedisGoblinUtil redisGoblinUtil;
+
     @Autowired
     private RedisCandyUtil redisCandyUtil;
 
@@ -52,4 +55,8 @@ public class RedisDataSourceUtil {
     public AbstractRedisUtil getRedisCandyUtil(){
         return this.redisCandyUtil;
     }
+
+    public AbstractRedisUtil getRedisGoblinUtil(){
+        return this.redisGoblinUtil;
+    }
 }

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisGoblinUtil.java

+package com.liquidnet.common.cache.redis.util;
+
+import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
+import com.liquidnet.common.cache.redis.config.RedisAdamConfig;
+import com.liquidnet.common.cache.redis.config.RedisGoblinConfig;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author AnJiabin <jiabin.an@lightnet.io>
+ * @version V1.0
+ * @Description: Redis工具类
+ * @class: RedisUtil
+ * @Package com.liquidnet.stellar.utils
+ * @Copyright: LightNet @ Copyright (c) 2020
+ * @date 2020/8/26 13:11
+ */
+@Slf4j
+@Component("redisAdamUtil")
+public final class RedisGoblinUtil extends AbstractRedisUtil {
+    @Autowired
+    private RedisGoblinConfig redisConfig;
+
+    @Override
+    public int getDbs() {
+        log.info("redisAdamUtil.totalDbs===", redisConfig.totalDbs);
+        return redisConfig.totalDbs;
+    }
+
+    @Override
+    AbstractRedisConfig getRedisConfig() {
+        return this.redisConfig;
+    }
+}