redis多数据源

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

@@ -10,6 +10,7 @@ import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.data.redis.connection.stream.StreamRecords;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.util.ArrayList;
@@ -32,6 +33,8 @@ import java.util.Set;
 public class TestRedis {
     @Autowired
     private RedisUtil redisUtil;
+    @Autowired
+    private StringRedisTemplate stringRedisTemplate;
 
     @Autowired
     private RedisDataSourceUtil redisDataSourceUtil;
@@ -55,6 +58,26 @@ public class TestRedis {
 
     @Test
     public void getRedisQueue(){
+        HashMap<String, String> map = CollectionUtil.mapStringString();
+        map.put("message", "oldtest20211022-001");
+        log.info("getRedisKylinUtil.stream===",stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("dragon:stream:dragon-pay")));
+    }
+
+    /**
+     * 兼容测试
+     */
+    @Test
+    public void oldPringRedisInitInfo(){
+        redisUtil.set("testoldRedis","12345");
+        System.out.println("getRedisKylinUtil.get==="+ redisUtil.get("testoldRedis"));
+        System.out.println("getRedisDragonUtil.totalDbs==="+ redisDataSourceUtil.getRedisDragonUtil().getDbs());
+    }
+
+    /**
+     * 兼容测试队列
+     */
+    @Test
+    public void oldGetRedisQueue(){
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put("message", "test20211022-001");
         log.info("getRedisKylinUtil.stream===",redisDataSourceUtil.getRedisKylinUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("dragon:stream:dragon-pay")));
@@ -72,6 +95,8 @@ public class TestRedis {
 //        log.info("getRedisCandyUtil.stream===",redisDataSourceUtil.getRedisCandyUtil().getStringRedisTemplate().opsForStream().size("abc"));
     }
 
+
+
     @Test
     public void getPayCodeList(){
 //        List<Object> payCodeList = this.getPrefixKeyValue("dragon:pay:code:*");