redis多数据源

liquidnet-bus-common/pom.xml

@@ -19,19 +19,6 @@
         <druid.version>1.1.22</druid.version>
     </properties>
 
-    <distributionManagement>
-        <repository>
-            <id>release</id>
-            <name>release</name>
-            <url>http://192.168.31.205:8081/repository/maven-releases/</url>
-        </repository>
-        <snapshotRepository>
-            <id>snapshots</id>
-            <name>snapshots</name>
-            <url>http://192.168.31.205:8081/repository/maven-snapshots/</url>
-        </snapshotRepository>
-    </distributionManagement>
-
     <modules>
         <module>liquidnet-common-base</module>
         <module>liquidnet-common-cache</module>

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

@@ -37,10 +37,26 @@ liquidnet:
     port: 6379
     password: 3Xa%8p
     dragon:
+      dbs: 0,16
+      database: 15
       host: 39.106.122.201
       port: 6379
       password: 3Xa%8p
     sweet:
+      dbs: 0,16
+      database: 15
+      host: 39.106.122.201
+      port: 6379
+      password: 3Xa%8p
+    adam:
+      dbs: 0,16
+      database: 15
+      host: 39.106.122.201
+      port: 6379
+      password: 3Xa%8p
+    candy:
+      dbs: 0,16
+      database: 15
       host: 39.106.122.201
       port: 6379
       password: 3Xa%8p
@@ -50,8 +66,8 @@ liquidnet:
     user: admin
     pwd: S&y$6d*JwJ
     chime:
-      host: s-2ze04ffc16a54af4-pub.mongodb.rds.aliyuncs.com:3717
-      port: 3717
+      host: 39.106.122.201:27017
+      port: 27017
       user: admin
       pwd: S&y$6d*JwJ
   service:

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

@@ -87,6 +87,55 @@ 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
+
     redisson:
       singleServerConfig:
         address: redis://${liquidnet.redis.host}:${liquidnet.redis.port}

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/docu/mongo_db_ddl-prod.sql

@@ -6,7 +6,7 @@ db.createCollection("ChimeUserInfoVo");
 #创建索引
 db.ChimeUserInfoVo.createIndex({userId:"hashed"});
 db.ChimeUserInfoVo.createIndex({sex:"hashed"});
-db.ChimeUserInfoVo.createIndex( {"userTagsVoList.tagCode": "hashed"});
+db.ChimeUserInfoVo.createIndex( {"userTagsVoList.tagCode": 1});
 db.ChimeUserInfoVo.createIndex({joinPerformanceId:"hashed"});
 
 #创建分片

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/test/java/com/liquidnet/service/platform/test/TestRedis.java

+package com.liquidnet.service.platform.test;
+
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
+import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.service.dragon.dto.DragonOrdersDto;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: TestRedis
+ * @Package com.liquidnet.service.adam.test
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/29 13:36
+ */
+@Slf4j
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringBootTest
+public class TestRedis {
+    @Autowired
+    private RedisUtil redisUtil;
+
+    @Autowired
+    private RedisDataSourceUtil redisDataSourceUtil;
+
+    @Test
+    public void pringRedisInitInfo(){
+//        log.info("redisConfig.defaultDb===",redisConfig.defaultDb);
+//        log.info("redisConfig.totalDbs===",redisConfig.totalDbs);
+//        redisConfig.getRedisTemplateByDb(MathUtil.getIndex("1",redisConfig.defaultDb,redisConfig.totalDbs));
+//
+        System.out.println("RedisConfig.totalDbs==="+ redisDataSourceUtil.getRedisDb1Util().getDbs());
+        System.out.println("RedisDb2Config.totalDbs==="+ redisDataSourceUtil.getRedisDb2Util().getDbs());
+        System.out.println("RedisDb3Config.totalDbs==="+ redisDataSourceUtil.getRedisDb3Util().getDbs());
+        System.out.println("RedisDb4Config.totalDbs==="+ redisDataSourceUtil.getRedisDb4Util().getDbs());
+        System.out.println("RedisDb5Config.totalDbs==="+ redisDataSourceUtil.getRedisDb5Util().getDbs());
+    }
+
+    @Test
+    public void getPayCodeList(){
+//        List<Object> payCodeList = this.getPrefixKeyValue("dragon:pay:code:*");
+//        for(Object payCode:payCodeList){
+//            System.out.println("object=== "+ JsonUtils.toJson(payCode));
+//        }
+        //设置新的redis
+        List<String> keys = getPrefixKeys("dragon:pay:code:*");
+        log.info("总共迁移数据条数==="+keys.size());
+        DragonOrdersDto dragonOrdersDto = DragonOrdersDto.getNew();
+        for(String key:keys){
+            Object obj = redisUtil.getRedisTemplateByDb(0).opsForValue().get(key);
+            if(obj!=null){
+                dragonOrdersDto =  (DragonOrdersDto) obj;
+            }
+//            redisUtil.set(key,dragonOrdersDto);
+        }
+//        System.out.println(redisUtil.sGet("kylin:agent:info"));
+//        System.out.println(redisUtil.sHasKey("kylin:agent:info",14));
+
+//        System.out.println(redisUtil.getRedisTemplateByDb(0).opsForValue().get("dragon:pay:code:PAY20210810193315191566757"));
+//
+//        List<Object> values = null;
+//        // 获取所有的key
+//        Set<String> keys = redisUtil.getRedisTemplateByDb(0).keys("dragon:pay:code:*");
+//        if (null != keys){
+//            for(String ss:keys){
+//                System.out.println("ss====="+ss);
+//            }
+//            // 批量获取数据
+//            values = redisUtil.getRedisTemplateByDb(0).opsForValue().multiGet(keys);
+//        }
+//        for(Object payCode:values){
+//            System.out.println("object=== "+ JsonUtils.toJson(payCode));
+//        }
+    }
+
+    @Test
+    public void getRefundList(){
+//        List<Object> payCodeList = this.getPrefixKeyValue("dragon:pay:code:*");
+//        for(Object payCode:payCodeList){
+//            System.out.println("object=== "+ JsonUtils.toJson(payCode));
+//        }
+        //设置新的redis
+        List<String> keys = getPrefixKeys("dragon:refund:refundCode:dragon:refund:refundCode:*");
+        String url = "";
+        log.info("总共迁移数据条数==="+keys.size());
+        for(String key:keys){
+            Object obj = redisUtil.getRedisTemplateByDb(0).opsForValue().get(key);
+            if(obj!=null){
+                url =  (String) obj;
+            }
+            key = key.substring(25,key.length());
+            redisUtil.set(key,url);
+        }
+//        System.out.println(redisUtil.sGet("kylin:agent:info"));
+//        System.out.println(redisUtil.sHasKey("kylin:agent:info",14));
+
+//        System.out.println(redisUtil.getRedisTemplateByDb(0).opsForValue().get("dragon:pay:code:PAY20210810193315191566757"));
+//
+//        List<Object> values = null;
+//        // 获取所有的key
+//        Set<String> keys = redisUtil.getRedisTemplateByDb(0).keys("dragon:pay:code:*");
+//        if (null != keys){
+//            for(String ss:keys){
+//                System.out.println("ss====="+ss);
+//            }
+//            // 批量获取数据
+//            values = redisUtil.getRedisTemplateByDb(0).opsForValue().multiGet(keys);
+//        }
+//        for(Object payCode:values){
+//            System.out.println("object=== "+ JsonUtils.toJson(payCode));
+//        }
+    }
+
+    @Test
+    public void deleteDataFromDb(){
+
+    }
+
+    /**
+     * 获取指定前缀的值
+     * @param prefix key前缀
+     * @return
+     */
+    public List<Object> getPrefixKeyValue(String prefix) {
+        List<Object> values = null;
+        // 获取所有的key
+        Set<String> keys = redisUtil.getRedisTemplateByDb(0).keys(prefix);
+        if (null != keys){
+            for(String ss:keys){
+                System.out.println("ss====="+ss);
+            }
+            // 批量获取数据
+            values = redisUtil.getRedisTemplateByDb(0).opsForValue().multiGet(keys);
+        }
+        return values;
+    }
+
+    /**
+     * 获取指定前缀的key
+     * @param prefix key前缀
+     * @return
+     */
+    public List<String> getPrefixKeys(String prefix) {
+        List<String> keysList = new ArrayList<>();
+        // 获取所有的key
+        Set<String> keys = redisUtil.getRedisTemplateByDb(0).keys(prefix);
+        if (null != keys){
+            for(String ss:keys){
+                keysList.add(ss);
+            }
+        }
+        return keysList;
+    }
+
+    private void switchRedisDbs(){
+
+    }
+}