redis多数据源

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisDb3Config.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisAdamConfig.java

@@ -18,24 +18,24 @@ import java.util.List;
  */
 @Slf4j
 @Configuration
-public class RedisDb3Config extends AbstractRedisConfig{
+public class RedisAdamConfig extends AbstractRedisConfig {
 
-    @Value("${spring.redis.db3.host:null}")
+    @Value("${spring.redis.adam.host:null}")
     private String host;
-    @Value("${spring.redis.db3.port:-1}")
+    @Value("${spring.redis.adam.port:-1}")
     private int port;
-    @Value("${spring.redis.db3.password:null}")
+    @Value("${spring.redis.adam.password:null}")
     private String password;
-    @Value("${spring.redis.db3.lettuce.pool.max-active:-1}")
+    @Value("${spring.redis.adam.lettuce.pool.max-active:-1}")
     private int maxActive;
-    @Value("${spring.redis.db3.lettuce.pool.max-idle:-1}")
+    @Value("${spring.redis.adam.lettuce.pool.max-idle:-1}")
     private int maxIdle;
-    @Value("${spring.redis.db3.lettuce.pool.min-idle:-1}")
+    @Value("${spring.redis.adam.lettuce.pool.min-idle:-1}")
     private int minIdle;
-    @Value("${spring.redis.db3.lettuce.pool.max-wait:-1}")
+    @Value("${spring.redis.adam.lettuce.pool.max-wait:-1}")
     private int maxWait;
 
-    @Value("${spring.redis.db3.dbs:${spring.redis.db3.database:-1}}")
+    @Value("${spring.redis.adam.dbs:${spring.redis.adam.database:-1}}")
     private List<Integer> dbs;
 
     String getHost(){

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisDb5Config.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisCandyConfig.java

@@ -18,24 +18,24 @@ import java.util.List;
  */
 @Slf4j
 @Configuration
-public class RedisDb5Config extends AbstractRedisConfig {
+public class RedisCandyConfig extends AbstractRedisConfig {
 
-    @Value("${spring.redis.db5.host:null}")
+    @Value("${spring.redis.candy.host:null}")
     private String host;
-    @Value("${spring.redis.db5.port:-1}")
+    @Value("${spring.redis.candy.port:-1}")
     private int port;
-    @Value("${spring.redis.db5.password:null}")
+    @Value("${spring.redis.candy.password:null}")
     private String password;
-    @Value("${spring.redis.db5.lettuce.pool.max-active:-1}")
+    @Value("${spring.redis.candy.lettuce.pool.max-active:-1}")
     private int maxActive;
-    @Value("${spring.redis.db5.lettuce.pool.max-idle:-1}")
+    @Value("${spring.redis.candy.lettuce.pool.max-idle:-1}")
     private int maxIdle;
-    @Value("${spring.redis.db5.lettuce.pool.min-idle:-1}")
+    @Value("${spring.redis.candy.lettuce.pool.min-idle:-1}")
     private int minIdle;
-    @Value("${spring.redis.db5.lettuce.pool.max-wait:-1}")
+    @Value("${spring.redis.candy.lettuce.pool.max-wait:-1}")
     private int maxWait;
 
-    @Value("${spring.redis.db5.dbs:${spring.redis.db5.database:-1}}")
+    @Value("${spring.redis.candy.dbs:${spring.redis.candy.database:-1}}")
     private List<Integer> dbs;
 
     String getHost(){

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisDb2Config.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisDragonConfig.java

@@ -18,27 +18,27 @@ import java.util.List;
  */
 @Slf4j
 @Configuration
-public class RedisDb2Config extends AbstractRedisConfig{
+public class RedisDragonConfig extends AbstractRedisConfig{
 
-    @Value("${spring.redis.db2.host:null}")
+    @Value("${spring.redis.dragon.host:null}")
     private String host;
-    @Value("${spring.redis.db2.port:-1}")
+    @Value("${spring.redis.dragon.port:-1}")
     private int port;
-    @Value("${spring.redis.db2.password:null}")
+    @Value("${spring.redis.dragon.password:null}")
     private String password;
-    @Value("${spring.redis.db2.lettuce.pool.max-active:-1}")
+    @Value("${spring.redis.dragon.lettuce.pool.max-active:-1}")
     private int maxActive;
-    @Value("${spring.redis.db2.lettuce.pool.max-idle:-1}")
+    @Value("${spring.redis.dragon.lettuce.pool.max-idle:-1}")
     private int maxIdle;
-    @Value("${spring.redis.db2.lettuce.pool.min-idle:-1}")
+    @Value("${spring.redis.dragon.lettuce.pool.min-idle:-1}")
     private int minIdle;
-    @Value("${spring.redis.db2.lettuce.pool.max-wait:-1}")
+    @Value("${spring.redis.dragon.lettuce.pool.max-wait:-1}")
     private int maxWait;
 
-    @Value("${spring.redis.db2.dbs:${spring.redis.db2.database:-1}}")
+    @Value("${spring.redis.dragon.dbs:${spring.redis.dragon.database:-1}}")
     private List<Integer> dbs;
 
-    public RedisDb2Config(){
+    public RedisDragonConfig(){
 
     }
 

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisDb4Config.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisSweetConfig.java

@@ -18,24 +18,24 @@ import java.util.List;
  */
 @Slf4j
 @Configuration
-public class RedisDb4Config extends AbstractRedisConfig {
+public class RedisSweetConfig extends AbstractRedisConfig{
 
-    @Value("${spring.redis.db4.host:null}")
+    @Value("${spring.redis.sweet.host:null}")
     private String host;
-    @Value("${spring.redis.db4.port:-1}")
+    @Value("${spring.redis.sweet.port:-1}")
     private int port;
-    @Value("${spring.redis.db4.password:null}")
+    @Value("${spring.redis.sweet.password:null}")
     private String password;
-    @Value("${spring.redis.db4.lettuce.pool.max-active:-1}")
+    @Value("${spring.redis.sweet.lettuce.pool.max-active:-1}")
     private int maxActive;
-    @Value("${spring.redis.db4.lettuce.pool.max-idle:-1}")
+    @Value("${spring.redis.sweet.lettuce.pool.max-idle:-1}")
     private int maxIdle;
-    @Value("${spring.redis.db4.lettuce.pool.min-idle:-1}")
+    @Value("${spring.redis.sweet.lettuce.pool.min-idle:-1}")
     private int minIdle;
-    @Value("${spring.redis.db4.lettuce.pool.max-wait:-1}")
+    @Value("${spring.redis.sweet.lettuce.pool.max-wait:-1}")
     private int maxWait;
 
-    @Value("${spring.redis.db4.dbs:${spring.redis.db4.database:-1}}")
+    @Value("${spring.redis.sweet.dbs:${spring.redis.sweet.database:-1}}")
     private List<Integer> dbs;
 
     String getHost(){

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisDb4Util.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisAdamUtil.java

 package com.liquidnet.common.cache.redis.util;
 
 import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
-import com.liquidnet.common.cache.redis.config.RedisDb4Config;
+import com.liquidnet.common.cache.redis.config.RedisAdamConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -16,14 +16,14 @@ import org.springframework.stereotype.Component;
  * @date 2020/8/26 13:11
  */
 @Slf4j
-@Component("redisDb4Util")
-public final class RedisDb4Util extends AbstractRedisUtil{
+@Component("redisAdamUtil")
+public final class RedisAdamUtil extends AbstractRedisUtil{
     @Autowired
-    private RedisDb4Config redisConfig;
+    private RedisAdamConfig redisConfig;
 
     @Override
     public int getDbs() {
-        log.info("redisDb4Config.totalDbs===",redisConfig.totalDbs);
+        log.info("redisAdamUtil.totalDbs===",redisConfig.totalDbs);
         return redisConfig.totalDbs;
     }
 

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisDb5Util.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisCandyUtil.java

 package com.liquidnet.common.cache.redis.util;
 
 import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
-import com.liquidnet.common.cache.redis.config.RedisDb5Config;
+import com.liquidnet.common.cache.redis.config.RedisCandyConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -16,14 +16,14 @@ import org.springframework.stereotype.Component;
  * @date 2020/8/26 13:11
  */
 @Slf4j
-@Component("redisDb5Util")
-public final class RedisDb5Util extends AbstractRedisUtil{
+@Component("redisCandyUtil")
+public final class RedisCandyUtil extends AbstractRedisUtil{
     @Autowired
-    private RedisDb5Config redisConfig;
+    private RedisCandyConfig redisConfig;
 
     @Override
     public int getDbs() {
-        log.info("redisDb5Config.totalDbs===",redisConfig.totalDbs);
+        log.info("redisCandyUtil.totalDbs===",redisConfig.totalDbs);
         return redisConfig.totalDbs;
     }
 

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

@@ -15,37 +15,37 @@ import org.springframework.stereotype.Component;
 @Component
 public class RedisDataSourceUtil {
     @Autowired
-    private RedisUtil redisUtil;
+    private RedisKylinUtil redisKylinUtil;
 
     @Autowired
-    private RedisDb2Util redisDb2Util;
+    private RedisDragonUtil redisDragonUtil;
 
     @Autowired
-    private RedisDb3Util redisDb3Util;
+    private RedisSweetUtil redisSweetUtil;
 
     @Autowired
-    private RedisDb4Util redisDb4Util;
+    private RedisAdamUtil redisAdamUtil;
 
     @Autowired
-    private RedisDb5Util redisDb5Util;
+    private RedisCandyUtil redisCandyUtil;
 
-    public AbstractRedisUtil getRedisDb1Util(){
-        return this.redisUtil;
+    public AbstractRedisUtil getRedisKylinUtil(){
+        return this.redisKylinUtil;
     }
 
-    public AbstractRedisUtil getRedisDb2Util(){
-        return this.redisDb2Util;
+    public AbstractRedisUtil getRedisDragonUtil(){
+        return this.redisDragonUtil;
     }
 
-    public AbstractRedisUtil getRedisDb3Util(){
-        return this.redisDb3Util;
+    public AbstractRedisUtil getRedisSweetUtil(){
+        return this.redisSweetUtil;
     }
 
-    public AbstractRedisUtil getRedisDb4Util(){
-        return this.redisDb4Util;
+    public AbstractRedisUtil getRedisAdamUtil(){
+        return this.redisAdamUtil;
     }
 
-    public AbstractRedisUtil getRedisDb5Util(){
-        return this.redisDb5Util;
+    public AbstractRedisUtil getRedisCandyUtil(){
+        return this.redisCandyUtil;
     }
 }

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

+package com.liquidnet.common.cache.redis.util;
+
+import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
+import com.liquidnet.common.cache.redis.config.RedisDragonConfig;
+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("redisDragonUtil")
+public final class RedisDragonUtil extends AbstractRedisUtil{
+    @Autowired
+    private RedisDragonConfig redisConfig;
+
+
+    @Override
+    public int getDbs() {
+        log.info("redisDragonUtil.totalDbs===",redisConfig.totalDbs);
+        return redisConfig.totalDbs;
+    }
+
+
+    @Override
+    AbstractRedisConfig getRedisConfig() {
+        return this.redisConfig;
+    }
+}

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisDb2Util.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisKylinUtil.java

 package com.liquidnet.common.cache.redis.util;
 
 import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
-import com.liquidnet.common.cache.redis.config.RedisDb2Config;
+import com.liquidnet.common.cache.redis.config.RedisConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -16,15 +16,15 @@ import org.springframework.stereotype.Component;
  * @date 2020/8/26 13:11
  */
 @Slf4j
-@Component("redisDb2Util")
-public final class RedisDb2Util extends AbstractRedisUtil{
+@Component("redisKylinUtil")
+public final class RedisKylinUtil extends AbstractRedisUtil{
     @Autowired
-    private RedisDb2Config redisConfig;
+    private RedisConfig redisConfig;
 
 
     @Override
     public int getDbs() {
-        log.info("redisDb2Config.totalDbs===",redisConfig.totalDbs);
+        log.info("redisKylinUtil.totalDbs===",redisConfig.totalDbs);
         return redisConfig.totalDbs;
     }
 

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisDb3Util.java → liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisSweetUtil.java

 package com.liquidnet.common.cache.redis.util;
 
 import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
-import com.liquidnet.common.cache.redis.config.RedisDb3Config;
+import com.liquidnet.common.cache.redis.config.RedisSweetConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -16,14 +16,14 @@ import org.springframework.stereotype.Component;
  * @date 2020/8/26 13:11
  */
 @Slf4j
-@Component("redisDb3Util")
-public final class RedisDb3Util extends AbstractRedisUtil{
+@Component("redisSweetUtil")
+public final class RedisSweetUtil extends AbstractRedisUtil{
     @Autowired
-    private RedisDb3Config redisConfig;
+    private RedisSweetConfig redisConfig;
 
     @Override
     public int getDbs() {
-        log.info("redisDb3Config.totalDbs===",redisConfig.totalDbs);
+        log.info("redisSweetUtil.totalDbs===",redisConfig.totalDbs);
         return redisConfig.totalDbs;
     }
 

liquidnet-bus-config/liquidnet-config/liquidnet-service-platform.yml

@@ -87,54 +87,54 @@ spring:
         max-wait: -1
         max-idle: 8
         min-idle: 0
-#    db2:
-#      database: 15
-#      dbs: ${liquidnet.redis.dragon.dbs}
-#      port: ${liquidnet.redis.dragon.port}
-#      host: ${liquidnet.redis.dragon.host}
-#      password: ${liquidnet.redis.dragon.password}
-#      lettuce:
-#        pool:
-#          max-active: 8
-#          max-wait: -1
-#          max-idle: 8
-#          min-idle: 0
-#    db3:
-#      database: 15
-#      dbs: ${liquidnet.redis.sweet.dbs}
-#      port: ${liquidnet.redis.sweet.port}
-#      host: ${liquidnet.redis.sweet.host}
-#      password: ${liquidnet.redis.sweet.password}
-#      lettuce:
-#        pool:
-#          max-active: 8
-#          max-wait: -1
-#          max-idle: 8
-#          min-idle: 0
-#    db4:
-#      database: 15
-#      dbs: ${liquidnet.redis.adam.dbs}
-#      port: ${liquidnet.redis.adam.port}
-#      host: ${liquidnet.redis.adam.host}
-#      password: ${liquidnet.redis.adam.password}
-#      lettuce:
-#        pool:
-#          max-active: 8
-#          max-wait: -1
-#          max-idle: 8
-#          min-idle: 0
-#    db5:
-#      database: 15
-#      dbs: ${liquidnet.redis.candy.dbs}
-#      port: ${liquidnet.redis.candy.port}
-#      host: ${liquidnet.redis.candy.host}
-#      password: ${liquidnet.redis.candy.password}
-#      lettuce:
-#        pool:
-#          max-active: 8
-#          max-wait: -1
-#          max-idle: 8
-#          min-idle: 0
+    dragon:
+      database: 15
+      dbs: ${liquidnet.redis.dragon.dbs}
+      port: ${liquidnet.redis.dragon.port}
+      host: ${liquidnet.redis.dragon.host}
+      password: ${liquidnet.redis.dragon.password}
+      lettuce:
+        pool:
+          max-active: 8
+          max-wait: -1
+          max-idle: 8
+          min-idle: 0
+    sweet:
+      database: 15
+      dbs: ${liquidnet.redis.sweet.dbs}
+      port: ${liquidnet.redis.sweet.port}
+      host: ${liquidnet.redis.sweet.host}
+      password: ${liquidnet.redis.sweet.password}
+      lettuce:
+        pool:
+          max-active: 8
+          max-wait: -1
+          max-idle: 8
+          min-idle: 0
+    adam:
+      database: 15
+      dbs: ${liquidnet.redis.adam.dbs}
+      port: ${liquidnet.redis.adam.port}
+      host: ${liquidnet.redis.adam.host}
+      password: ${liquidnet.redis.adam.password}
+      lettuce:
+        pool:
+          max-active: 8
+          max-wait: -1
+          max-idle: 8
+          min-idle: 0
+    candy:
+      database: 15
+      dbs: ${liquidnet.redis.candy.dbs}
+      port: ${liquidnet.redis.candy.port}
+      host: ${liquidnet.redis.candy.host}
+      password: ${liquidnet.redis.candy.password}
+      lettuce:
+        pool:
+          max-active: 8
+          max-wait: -1
+          max-idle: 8
+          min-idle: 0
 
     redisson:
       singleServerConfig: