~queue:GalaxyQueue.SQL_USER_INFO;

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

@@ -70,6 +70,8 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     ConsumerSlimeSqlLineReceiver consumerSlimeSqlLineReceiver;
     @Autowired
     ConsumerSlimeSqlPerformanceInsertReceiver consumerSlimeSqlPerformanceInsertReceiver;
+    @Autowired
+    ConsumerGalaxySqlUserInfoReceiver consumerGalaxySqlUserInfoReceiver;
     /*------sweet------*/
     @Autowired
     ConsumerSweetAnswerRdsReceiver consumerSweetAnswerRdsReceiver;
@@ -94,6 +96,22 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     @Autowired
     ConsumerSweetUserRdsReceiver consumerSweetUserRdsReceiver;
 
+//    @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;
+//    }
+
     /*------sweet------*/
 
     @Bean // 关注服务号的用户信息
@@ -111,6 +129,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 用户-关系
     public List<Subscription> subscriptionSweetSqlArtistsRelation(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -126,6 +145,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 用户-关系
     public List<Subscription> subscriptionSweetSqlUserMdskRelation(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -141,6 +161,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 用户-抽奖
     public List<Subscription> subscriptionSweetSqlLuckDraw(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -156,6 +177,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 提醒记录
     public List<Subscription> subscriptionSweetSqlRemind(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -171,6 +193,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 用户喜欢的音乐人
     public List<Subscription> subscriptionSweetSqlPoster(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -186,6 +209,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 猫登天空
     public List<Subscription> subscriptionSweetSqlMaoDeng(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -201,6 +225,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 积分抽奖
     public List<Subscription> subscriptionSweetSqlIntegralActivityDraw(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -216,6 +241,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 用户投票记录
     public List<Subscription> subscriptionSweetSqlCityVote(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -231,6 +257,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 防疫答题
     public List<Subscription> subscriptionSweetSqlAntigenicQuestion(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -246,6 +273,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean // 答案
     public List<Subscription> subscriptionSweetSqlAnswer(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -411,6 +439,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
     @Bean// 用户退款发快递
     public List<Subscription> subscriptionKylinSqlOrderRefundExpress(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
@@ -540,4 +569,20 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
+    @Bean// 用户注册信息
+    public List<Subscription> subscriptionGalaxySqlUserInfo(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_USER_INFO;
+        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()), consumerGalaxySqlUserInfoReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
 }

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

+package com.liquidnet.service.consumer.base.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class ConsumerGalaxySqlUserInfoReceiver extends AbstractSqlRedisReceiver {
+
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GalaxyQueue.SQL_USER_INFO.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GalaxyQueue.SQL_USER_INFO.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGalaxySqlUserInfoReceiver.java

-package com.liquidnet.service.consumer.kylin.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-@Slf4j
-@Component
-public class ConsumerGalaxySqlUserInfoReceiver extends AbstractSqlRedisReceiver {
-
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GalaxyQueue.SQL_USER_INFO.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GalaxyQueue.SQL_USER_INFO.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.kylin.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//@Slf4j
+//@Component
+//public class ConsumerGalaxySqlUserInfoReceiver extends AbstractSqlRedisReceiver {
+//
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GalaxyQueue.SQL_USER_INFO.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GalaxyQueue.SQL_USER_INFO.getGroup();
+//    }
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerGalaxySqlUserInfoReceiver;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * @author AnJiabin <anjiabin@zhengzai.tv>
- * @version V1.0
- * @Description: 区块链用户注册
- * @class: ConsumerSqlUserInfoConfig
- * @Package com.liquidnet.service.consumer.dragon.config
- * @Copyright: LightNet @ Copyright (c) 2022
- * @date 2022/3/22 14:45
- */
-@Configuration
-public class ConsumerGalaxySqlUserInfoConfig extends RedisStreamConfig {
-    @Autowired
-    private ConsumerGalaxySqlUserInfoReceiver sqlUserInfoReceiver;
-
-    @Autowired
-    StringRedisTemplate stringRedisTemplate;
-
-    @Bean
-    public List<Subscription> subscriptionSqlUserInfo(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_USER_INFO;
-
-        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()), sqlUserInfoReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-}
+//package com.liquidnet.service.consumer.slowly.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerGalaxySqlUserInfoReceiver;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.core.StringRedisTemplate;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//import java.util.ArrayList;
+//import java.util.List;
+//
+///**
+// * @author AnJiabin <anjiabin@zhengzai.tv>
+// * @version V1.0
+// * @Description: 区块链用户注册
+// * @class: ConsumerSqlUserInfoConfig
+// * @Package com.liquidnet.service.consumer.dragon.config
+// * @Copyright: LightNet @ Copyright (c) 2022
+// * @date 2022/3/22 14:45
+// */
+//@Configuration
+//public class ConsumerGalaxySqlUserInfoConfig extends RedisStreamConfig {
+//    @Autowired
+//    private ConsumerGalaxySqlUserInfoReceiver sqlUserInfoReceiver;
+//
+//    @Autowired
+//    StringRedisTemplate stringRedisTemplate;
+//
+//    @Bean
+//    public List<Subscription> subscriptionSqlUserInfo(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_USER_INFO;
+//
+//        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()), sqlUserInfoReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerGalaxySqlUserInfoReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-@Slf4j
-@Component
-public class ConsumerGalaxySqlUserInfoReceiver extends AbstractSqlRedisReceiver {
-
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GalaxyQueue.SQL_USER_INFO.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GalaxyQueue.SQL_USER_INFO.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//@Slf4j
+//@Component
+//public class ConsumerGalaxySqlUserInfoReceiver extends AbstractSqlRedisReceiver {
+//
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GalaxyQueue.SQL_USER_INFO.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GalaxyQueue.SQL_USER_INFO.getGroup();
+//    }
+//}