修改 redis 添加 购物车消费

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

@@ -34,50 +34,50 @@ liquidnet:
     kylin:
       database: 255
       dbs: 0,256
-      host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
+      host: r-2zetgw7zdxea5wtnr8.redis.rds.aliyuncs.com
       port: 6380
-      password: PO@B!Iud32
+      password: Zhengzai@2021
     slime:
       database: 255
       dbs: 0,256
-      host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
+      host: r-2zetgw7zdxea5wtnr8.redis.rds.aliyuncs.com
       port: 6380
-      password: PO@B!Iud32
+      password: Zhengzai@2021
     dragon:
       database: 255
       dbs: 0,256
-      host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
+      host: r-2zetgw7zdxea5wtnr8.redis.rds.aliyuncs.com
       port: 6380
-      password: PO@B!Iud32
+      password: Zhengzai@2021
     sweet:
       database: 255
       dbs: 0,256
-      host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
+      host: r-2zetgw7zdxea5wtnr8.redis.rds.aliyuncs.com
       port: 6380
-      password: PO@B!Iud32
+      password: Zhengzai@2021
     adam:
       database: 255
       dbs: 0,256
-      host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
+      host: r-2zetgw7zdxea5wtnr8.redis.rds.aliyuncs.com
       port: 6380
-      password: PO@B!Iud32
+      password: Zhengzai@2021
     candy:
       database: 255
       dbs: 0,256
-      host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
+      host: r-2zetgw7zdxea5wtnr8.redis.rds.aliyuncs.com
       port: 6380
-      password: PO@B!Iud32
+      password: Zhengzai@2021
     goblin:
       database: 255
       dbs: 0,256
-      host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
+      host: r-2zetgw7zdxea5wtnr8.redis.rds.aliyuncs.com
       port: 6380
-      password: PO@B!Iud32
+      password: Zhengzai@2021
   mongodb:
-    host: 39.107.71.112:27017
-    port: 27017
+    host: s-2zeb52774ceac644.mongodb.rds.aliyuncs.com:3717,s-2ze8994d25d37d74.mongodb.rds.aliyuncs.com:3717
+    port: 3717
     user: admin
-    pwd: S&y$6d*JwJ
+    pwd: Zhengzai@2022
   service:
     adam:
       url-pay:

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-goblin/src/main/java/com/liquidnet/service/consumer/goblin/config/ConsumerGoblinShopCartStreamConfig.java

@@ -59,4 +59,20 @@ public class ConsumerGoblinShopCartStreamConfig {
         return subscription;
     }
 
+    @Bean
+    public Subscription subscriptionSqlShopCart3(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlShopCart(listenerContainer, 2);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionSqlShopCart4(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlShopCart(listenerContainer, 2);
+        listenerContainer.start();
+        return subscription;
+    }
+
 }