redis多数据源

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisKylinConfig.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.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.core.StringRedisTemplate;
+
+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 RedisKylinConfig extends AbstractRedisConfig{
+
+    @Value("${spring.redis.kylin.host:null}")
+    private String host;
+    @Value("${spring.redis.kylin.port:-1}")
+    private int port;
+    @Value("${spring.redis.kylin.password:null}")
+    private String password;
+    @Value("${spring.redis.kylin.lettuce.pool.max-active:-1}")
+    private int maxActive;
+    @Value("${spring.redis.kylin.lettuce.pool.max-idle:-1}")
+    private int maxIdle;
+    @Value("${spring.redis.kylin.lettuce.pool.min-idle:-1}")
+    private int minIdle;
+    @Value("${spring.redis.kylin.lettuce.pool.max-wait:-1}")
+    private int maxWait;
+
+    @Value("${spring.redis.kylin.dbs:${spring.redis.kylin.database:-1}}")
+    private List<Integer> dbs;
+
+    @Bean
+    public StringRedisTemplate stringRedisTemplate() {
+        return this.getStringRedisTemplate();
+    }
+
+    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/MathUtil.java

 package com.liquidnet.common.cache.redis.util;
 
-import com.liquidnet.common.cache.redis.config.RedisConfig;
+import com.liquidnet.common.cache.redis.config.RedisKylinConfig;
 import lombok.extern.slf4j.Slf4j;
 
 /**
@@ -38,7 +38,7 @@ public class MathUtil {
     }
 
     public static void main(String[] args) {
-        RedisConfig redisConfig = new RedisConfig();
+        RedisKylinConfig redisConfig = new RedisKylinConfig();
         log.info("redisConfig.defaultDb===",redisConfig.defaultDb);
         log.info("redisConfig.totalDbs===",redisConfig.totalDbs);
 //        redisConfig.getRedisTemplateByDb(MathUtil.getIndex("1",redisConfig.defaultDb,redisConfig.totalDbs));

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.RedisConfig;
+import com.liquidnet.common.cache.redis.config.RedisKylinConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -19,7 +19,7 @@ import org.springframework.stereotype.Component;
 @Component("redisKylinUtil")
 public final class RedisKylinUtil extends AbstractRedisUtil{
     @Autowired
-    private RedisConfig redisConfig;
+    private RedisKylinConfig redisConfig;
 
 
     @Override

liquidnet-bus-config/liquidnet-config/application-dev.yml

@@ -31,11 +31,12 @@ liquidnet:
   knife4j:
     disable: false
   redis:
-    dbs: 0,16
-    database: 15
-    host: 39.106.122.201
-    port: 6379
-    password: 3Xa%8p
+    kylin:
+      dbs: 0,256
+      database: 255
+      host: r-2ze3sf1ll8er966uucpd.redis.rds.aliyuncs.com
+      port: 6380
+      password: Zhengzai@2021
     dragon:
       database: 255
       dbs: 0,256

liquidnet-bus-config/liquidnet-config/liquidnet-client-admin-web.yml

@@ -109,18 +109,66 @@ spring:
       sslEnabled: ${liquidnet.mongodb.sslEnabled}
       database: ${liquidnet.mongodb.database}
   redis:
-    database: 15
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
-    lettuce:
-      pool:
-        max-active: 8
-        max-wait: -1
-        max-idle: 8
-        min-idle: 0
-
+    kylin:
+      database: 15
+      dbs: ${liquidnet.redis.dbs}
+      port: ${liquidnet.redis.port}
+      host: ${liquidnet.redis.host}
+      password: ${liquidnet.redis.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
 # MyBatis
 mybatis:
   # 搜索指定包别名

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

@@ -75,10 +75,10 @@ spring:
       - org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration
   redis:
     database: 15
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    dbs: ${liquidnet.redis.adam.dbs}
+    port: ${liquidnet.redis.adam.port}
+    host: ${liquidnet.redis.adam.host}
+    password: ${liquidnet.redis.adam.password}
     lettuce:
       pool:
         max-active: 5

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

@@ -75,10 +75,10 @@ spring:
       - org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
   redis:
     database: 15
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    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

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

@@ -73,18 +73,18 @@ spring:
     exclude:
       - org.springframework.cloud.bus.BusAutoConfiguration
       - org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
-  redis:
-    database: 15
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
-    lettuce:
-      pool:
-        max-active: 8
-        max-wait: -1
-        max-idle: 8
-        min-idle: 0
+#  redis:
+#    database: 15
+#    dbs: ${liquidnet.redis.dbs}
+#    port: ${liquidnet.redis.port}
+#    host: ${liquidnet.redis.host}
+#    password: ${liquidnet.redis.password}
+#    lettuce:
+#      pool:
+#        max-active: 8
+#        max-wait: -1
+#        max-idle: 8
+#        min-idle: 0
     redisson:
       singleServerConfig:
         address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-adam.yml

@@ -57,11 +57,11 @@ spring:
   profiles:
     include: common-service #这里加载management相关公共配置
   redis:
-    database: ${liquidnet.redis.database}
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    database: ${liquidnet.redis.adam.database}
+    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

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-candy.yml

@@ -57,11 +57,11 @@ spring:
   profiles:
     include: common-service #这里加载management相关公共配置
   redis:
-    database: ${liquidnet.redis.database}
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    database: ${liquidnet.redis.candy.database}
+    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

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-dragon.yml

@@ -57,7 +57,7 @@ spring:
   profiles:
     include: common-service #这里加载management相关公共配置
   redis:
-    database: ${liquidnet.dragon.redis.database}
+    database: ${liquidnet.redis.dragon.database}
     port: ${liquidnet.redis.dragon.port}
     host: ${liquidnet.redis.dragon.host}
     password: ${liquidnet.redis.dragon.password}

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-kylin.yml

@@ -57,11 +57,11 @@ spring:
   profiles:
     include: common-service #这里加载management相关公共配置
   redis:
-    database: ${liquidnet.redis.database}
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    database: ${liquidnet.redis.kylin.database}
+    dbs: ${liquidnet.redis.kylin.dbs}
+    port: ${liquidnet.redis.kylin.port}
+    host: ${liquidnet.redis.kylin.host}
+    password: ${liquidnet.redis.kylin.password}
     lettuce:
       pool:
         max-active: 8

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-sweet.yml

@@ -57,16 +57,17 @@ spring:
   profiles:
     include: common-service #这里加载management相关公共配置
   redis:
-    database: 15
-    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
+    sweet:
+      database: 15
+      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
 #    redisson:
 #      singleServerConfig:
 #        address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}

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

@@ -77,7 +77,7 @@ spring:
     database: 0
     #如果配置了dbs，则database配置失效 格式为0,16   0为分库初始索引(目前只支持从0开始)，16为redis总的db数，队列会自动创建在db15
     #如果配置了dbs为具体dbNo 如：0  则作用同database配置一样
-    dbs: ${liquidnet.redis.dbs}
+    dbs: ${liquidnet.redis.dragon.dbs}
     port: ${liquidnet.redis.dragon.port}
     host: ${liquidnet.redis.dragon.host}
     password: ${liquidnet.redis.dragon.password}
@@ -87,28 +87,28 @@ spring:
         max-wait: -1
         max-idle: 8
         min-idle: 0
-    redisson:
-      singleServerConfig:
-        address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}
-        password: ${liquidnet.redis.password}
-        clientName: null
-        database: 7 #选择使用哪个数据库0~15
-        idleConnectionTimeout: 10000
-        connectTimeout: 10000
-        timeout: 3000
-        retryAttempts: 3
-        retryInterval: 1500
-        subscriptionsPerConnection: 5
-        subscriptionConnectionMinimumIdleSize: 1
-        subscriptionConnectionPoolSize: 50
-        connectionMinimumIdleSize: 32
-        connectionPoolSize: 64
-        dnsMonitoringInterval: 5000
-      threads: 16
-      nettyThreads: 32
-      codec:
-        class: "org.redisson.codec.JsonJacksonCodec"
-      transportMode: "NIO"
+#    redisson:
+#      singleServerConfig:
+#        address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}
+#        password: ${liquidnet.redis.password}
+#        clientName: null
+#        database: 7 #选择使用哪个数据库0~15
+#        idleConnectionTimeout: 10000
+#        connectTimeout: 10000
+#        timeout: 3000
+#        retryAttempts: 3
+#        retryInterval: 1500
+#        subscriptionsPerConnection: 5
+#        subscriptionConnectionMinimumIdleSize: 1
+#        subscriptionConnectionPoolSize: 50
+#        connectionMinimumIdleSize: 32
+#        connectionPoolSize: 64
+#        dnsMonitoringInterval: 5000
+#      threads: 16
+#      nettyThreads: 32
+#      codec:
+#        class: "org.redisson.codec.JsonJacksonCodec"
+#      transportMode: "NIO"
   data:
     mongodb:
       uri: mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}/?authSource=admin&maxPoolSize=2000&waitQueueMultiple=100

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

@@ -75,38 +75,38 @@ spring:
       - org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
   redis:
     database: 15
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    dbs: ${liquidnet.redis.kylin.dbs}
+    port: ${liquidnet.redis.kylin.port}
+    host: ${liquidnet.redis.kylin.host}
+    password: ${liquidnet.redis.kylin.password}
     lettuce:
       pool:
         max-active: 8
         max-wait: -1
         max-idle: 8
         min-idle: 0
-    redisson:
-      singleServerConfig:
-        address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}
-        password: ${liquidnet.redis.password}
-        clientName: null
-        database: 7 #选择使用哪个数据库0~15
-        idleConnectionTimeout: 10000
-        connectTimeout: 10000
-        timeout: 3000
-        retryAttempts: 3
-        retryInterval: 1500
-        subscriptionsPerConnection: 5
-        subscriptionConnectionMinimumIdleSize: 1
-        subscriptionConnectionPoolSize: 50
-        connectionMinimumIdleSize: 32
-        connectionPoolSize: 64
-        dnsMonitoringInterval: 5000
-      threads: 16
-      nettyThreads: 32
-      codec:
-        class: "org.redisson.codec.JsonJacksonCodec"
-      transportMode: "NIO"
+#    redisson:
+#      singleServerConfig:
+#        address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}
+#        password: ${liquidnet.redis.password}
+#        clientName: null
+#        database: 7 #选择使用哪个数据库0~15
+#        idleConnectionTimeout: 10000
+#        connectTimeout: 10000
+#        timeout: 3000
+#        retryAttempts: 3
+#        retryInterval: 1500
+#        subscriptionsPerConnection: 5
+#        subscriptionConnectionMinimumIdleSize: 1
+#        subscriptionConnectionPoolSize: 50
+#        connectionMinimumIdleSize: 32
+#        connectionPoolSize: 64
+#        dnsMonitoringInterval: 5000
+#      threads: 16
+#      nettyThreads: 32
+#      codec:
+#        class: "org.redisson.codec.JsonJacksonCodec"
+#      transportMode: "NIO"
   data:
     mongodb:
       uri: mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}/?authSource=admin&maxPoolSize=2000&waitQueueMultiple=100

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

@@ -84,7 +84,7 @@ spring:
     database: 0
     #如果配置了dbs，则database配置失效 格式为0,16   0为分库初始索引(目前只支持从0开始)，16为redis总的db数，队列会自动创建在db15
     #如果配置了dbs为具体dbNo 如：0  则作用同database配置一样
-    dbs: ${liquidnet.redis.dbs}
+    dbs: ${liquidnet.redis.dragon.dbs}
     port: ${liquidnet.redis.dragon.port}
     host: ${liquidnet.redis.dragon.host}
     password: ${liquidnet.redis.dragon.password}
@@ -94,28 +94,28 @@ spring:
         max-wait: -1
         max-idle: 8
         min-idle: 0
-    redisson:
-      singleServerConfig:
-        address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}
-        password: ${liquidnet.redis.password}
-        clientName: null
-        database: 7 #选择使用哪个数据库0~15
-        idleConnectionTimeout: 10000
-        connectTimeout: 10000
-        timeout: 3000
-        retryAttempts: 3
-        retryInterval: 1500
-        subscriptionsPerConnection: 5
-        subscriptionConnectionMinimumIdleSize: 1
-        subscriptionConnectionPoolSize: 50
-        connectionMinimumIdleSize: 32
-        connectionPoolSize: 64
-        dnsMonitoringInterval: 5000
-      threads: 16
-      nettyThreads: 32
-      codec:
-        class: "org.redisson.codec.JsonJacksonCodec"
-      transportMode: "NIO"
+#    redisson:
+#      singleServerConfig:
+#        address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}
+#        password: ${liquidnet.redis.password}
+#        clientName: null
+#        database: 7 #选择使用哪个数据库0~15
+#        idleConnectionTimeout: 10000
+#        connectTimeout: 10000
+#        timeout: 3000
+#        retryAttempts: 3
+#        retryInterval: 1500
+#        subscriptionsPerConnection: 5
+#        subscriptionConnectionMinimumIdleSize: 1
+#        subscriptionConnectionPoolSize: 50
+#        connectionMinimumIdleSize: 32
+#        connectionPoolSize: 64
+#        dnsMonitoringInterval: 5000
+#      threads: 16
+#      nettyThreads: 32
+#      codec:
+#        class: "org.redisson.codec.JsonJacksonCodec"
+#      transportMode: "NIO"
   data:
     mongodb:
       uri: mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}/?authSource=admin&maxPoolSize=2000&waitQueueMultiple=100

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

@@ -75,10 +75,10 @@ spring:
       - org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
   redis:
     database: 15
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    dbs: ${liquidnet.redis.kylin.dbs}
+    port: ${liquidnet.redis.kylin.port}
+    host: ${liquidnet.redis.kylin.host}
+    password: ${liquidnet.redis.kylin.password}
     lettuce:
       pool:
         max-active: 8

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

@@ -77,10 +77,10 @@ spring:
     connection-timeout: ${liquidnet.rabbitmq.connection-timeout}
   redis:
     database: 15
-    dbs: ${liquidnet.redis.dbs}
-    port: ${liquidnet.redis.port}
-    host: ${liquidnet.redis.host}
-    password: ${liquidnet.redis.password}
+    dbs: ${liquidnet.redis.kylin.dbs}
+    port: ${liquidnet.redis.kylin.port}
+    host: ${liquidnet.redis.kylin.host}
+    password: ${liquidnet.redis.kylin.password}
     lettuce:
       pool:
         max-active: 8