~queue:goblin.SQL_STORE、SQL_GOODS、SQL_COUPON、SQL_ARTWORK_GEN;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/ConsumerCommonSqlRedisStreamConfig.java

@@ -2,8 +2,7 @@ package com.liquidnet.service.consumer.base.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.base.receiver.ConsumerCommonSQL0Receiver;
-import com.liquidnet.service.consumer.base.receiver.ConsumerGoblinNftOrderRdsReceiver;
+import com.liquidnet.service.consumer.base.receiver.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -34,6 +33,30 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
 
     @Autowired
     ConsumerGoblinNftOrderRdsReceiver consumerGoblinNftOrderRdsReceiver;
+    @Autowired
+    ConsumerGoblinSqlStoreRdsReceiver consumerGoblinSqlStoreRdsReceiver;
+    @Autowired
+    ConsumerGoblinSqlGoodsRdsReceiver consumerGoblinSqlGoodsRdsReceiver;
+    @Autowired
+    ConsumerGoblinSqlCouponRdsReceiver consumerGoblinSqlCouponRdsReceiver;
+    @Autowired
+    ConsumerGoblinSqlArtworkGenRdsReceiver consumerGoblinSqlArtworkGenRdsReceiver;
+
+//    @Bean
+//    public List<Subscription> subscriptionSQL0(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.CommonQueue stream = MQConst.CommonQueue.SQL0;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 5; i++) {
+//            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//            subscriptionList.add(listenerContainer.receiveAutoAck(
+//                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+//                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerCommonSQL0Receiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
 
     /**
      * goblinNFT订单
@@ -56,19 +79,67 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         return subscriptionList;
     }
 
-//    @Bean
-//    public List<Subscription> subscriptionSQL0(RedisConnectionFactory factory) {
-//        List<Subscription> subscriptionList = new ArrayList<>();
-//        MQConst.CommonQueue stream = MQConst.CommonQueue.SQL0;
-//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-//        for (int i = 0; i < 5; i++) {
-//            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//            subscriptionList.add(listenerContainer.receiveAutoAck(
-//                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
-//                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerCommonSQL0Receiver
-//            ));
-//            listenerContainer.start();
-//        }
-//        return subscriptionList;
-//    }
+    @Bean// 店铺相关
+    public List<Subscription> subscriptionGoblinSqlStore(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_STORE;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; i++) {
+            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+            subscriptionList.add(listenerContainer.receiveAutoAck(
+                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlStoreRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+    @Bean// 商品相关
+    public List<Subscription> subscriptionGoblinSqlGoods(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_GOODS;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; i++) {
+            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+            subscriptionList.add(listenerContainer.receiveAutoAck(
+                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlGoodsRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+    @Bean// 店铺优惠券相关
+    public List<Subscription> subscriptionGoblinSqlStoreCoupon(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_COUPON;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; i++) {
+            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+            subscriptionList.add(listenerContainer.receiveAutoAck(
+                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlCouponRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+    @Bean// 藏品生成
+    public List<Subscription> subscriptionGoblinSqlArtworkGen(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_ARTWORK_GEN;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 5; i++) {
+            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+            subscriptionList.add(listenerContainer.receiveAutoAck(
+                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlArtworkGenRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
 }

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlArtworkGenRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinSqlArtworkGenRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.SQL_ARTWORK_GEN.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlCouponRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinSqlCouponRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.SQL_COUPON.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.SQL_COUPON.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlGoodsRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinSqlGoodsRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.SQL_GOODS.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.SQL_GOODS.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlStoreRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinSqlStoreRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.SQL_STORE.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.SQL_STORE.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerCommonSqlRedisStreamConfig.java

@@ -22,80 +22,80 @@ import java.util.List;
 public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     @Autowired
     StringRedisTemplate stringRedisTemplate;
-    @Autowired
-    ConsumerGoblinSqlStoreRdsReceiver consumerGoblinSqlStoreRdsReceiver;
-    @Autowired
-    ConsumerGoblinSqlGoodsRdsReceiver consumerGoblinSqlGoodsRdsReceiver;
-    @Autowired
-    ConsumerGoblinSqlCouponRdsReceiver consumerGoblinSqlCouponRdsReceiver;
-    @Autowired
-    ConsumerGoblinSqlArtworkGenRdsReceiver consumerGoblinSqlArtworkGenRdsReceiver;
+//    @Autowired
+//    ConsumerGoblinSqlStoreRdsReceiver consumerGoblinSqlStoreRdsReceiver;
+//    @Autowired
+//    ConsumerGoblinSqlGoodsRdsReceiver consumerGoblinSqlGoodsRdsReceiver;
+//    @Autowired
+//    ConsumerGoblinSqlCouponRdsReceiver consumerGoblinSqlCouponRdsReceiver;
+//    @Autowired
+//    ConsumerGoblinSqlArtworkGenRdsReceiver consumerGoblinSqlArtworkGenRdsReceiver;
 //    @Autowired
 //    ConsumerGoblinNftOrderRdsReceiver consumerGoblinNftOrderRdsReceiver;
 
-    @Bean// 店铺相关
-    public List<Subscription> subscriptionSqlStore(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_STORE;
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 1; i++) {
-            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
-            subscriptionList.add(listenerContainer.receiveAutoAck(
-                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
-                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlStoreRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-
-    @Bean// 商品相关
-    public List<Subscription> subscriptionSqlGoods(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_GOODS;
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 1; i++) {
-            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
-            subscriptionList.add(listenerContainer.receiveAutoAck(
-                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
-                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlGoodsRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-
-    @Bean// 店铺优惠券相关
-    public List<Subscription> subscriptionSqlStoreCoupon(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_COUPON;
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 1; i++) {
-            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
-            subscriptionList.add(listenerContainer.receiveAutoAck(
-                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
-                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlCouponRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-
-    @Bean// 藏品生成
-    public List<Subscription> subscriptionSqlArtworkGen(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_ARTWORK_GEN;
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; i++) {
-            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
-            subscriptionList.add(listenerContainer.receiveAutoAck(
-                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
-                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlArtworkGenRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
+//    @Bean// 店铺相关
+//    public List<Subscription> subscriptionSqlStore(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_STORE;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 1; i++) {
+//            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//            subscriptionList.add(listenerContainer.receiveAutoAck(
+//                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+//                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlStoreRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//
+//    @Bean// 商品相关
+//    public List<Subscription> subscriptionSqlGoods(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_GOODS;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 1; i++) {
+//            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//            subscriptionList.add(listenerContainer.receiveAutoAck(
+//                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+//                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlGoodsRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//
+//    @Bean// 店铺优惠券相关
+//    public List<Subscription> subscriptionSqlStoreCoupon(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_COUPON;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 1; i++) {
+//            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//            subscriptionList.add(listenerContainer.receiveAutoAck(
+//                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+//                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlCouponRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//
+//    @Bean// 藏品生成
+//    public List<Subscription> subscriptionSqlArtworkGen(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_ARTWORK_GEN;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 5; i++) {
+//            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//            subscriptionList.add(listenerContainer.receiveAutoAck(
+//                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
+//                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlArtworkGenRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
 
 //    @Bean// NFT订单
 //    public List<Subscription> subscriptionSqlNftOrder(RedisConnectionFactory factory) {