stone 消费迁移

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

+package com.liquidnet.service.consumer.base.config.stone;
+
+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.stone.RedisInsertLogReceiver;
+import lombok.var;
+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;
+
+@Configuration
+public class ConsumerStoneLogsRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    RedisInsertLogReceiver redisInsertLogReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean
+    public List<Subscription> insertLogs(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_INSERT_LOGS;
+        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()), redisInsertLogReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+    /* -------------------------------------------------------- ｜  */
+}

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

+package com.liquidnet.service.consumer.base.config.stone;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.stone.RedisInsertOrderReceiver;
+import lombok.var;
+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;
+
+@Configuration
+public class ConsumerStoneOrderRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    RedisInsertOrderReceiver redisInsertOrderReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+
+    @Bean
+    public List<Subscription> insertOrder(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_ORDER_COUPON;
+        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()), redisInsertOrderReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+    /* -------------------------------------------------------- ｜  */
+}

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

+package com.liquidnet.service.consumer.base.config.stone;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.stone.RedisInsertUserReceiver;
+import lombok.var;
+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;
+
+@Configuration
+public class ConsumerStoneUserRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    RedisInsertUserReceiver redisInsertUserReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean
+    public List<Subscription> insertUser(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_INSERT_USER;
+        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()), redisInsertUserReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+    /* -------------------------------------------------------- ｜  */
+}

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

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

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

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

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

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

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/config/ConsumerStoneLogsRedisStreamConfig.java

-package com.liquidnet.servce.consumer.stone.service.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.servce.consumer.stone.service.receiver.RedisInsertLogReceiver;
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.var;
-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.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerStoneLogsRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    RedisInsertLogReceiver redisInsertLogReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveSqlStoneInsertLog(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.StoneQueue.STONE_INSERT_LOGS.getGroup(), getConsumerName(MQConst.StoneQueue.STONE_INSERT_LOGS.name() + t)),
-                StreamOffset.create(MQConst.StoneQueue.STONE_INSERT_LOGS.getKey(), ReadOffset.lastConsumed()), redisInsertLogReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertLog0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertLog(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertLog1(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertLog(listenerContainer, 1);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertLog2(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertLog(listenerContainer, 2);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//package com.liquidnet.servce.consumer.stone.service.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.servce.consumer.stone.service.receiver.RedisInsertLogReceiver;
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.var;
+//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.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//@Configuration
+//public class ConsumerStoneLogsRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    RedisInsertLogReceiver redisInsertLogReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveSqlStoneInsertLog(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.StoneQueue.STONE_INSERT_LOGS.getGroup(), getConsumerName(MQConst.StoneQueue.STONE_INSERT_LOGS.name() + t)),
+//                StreamOffset.create(MQConst.StoneQueue.STONE_INSERT_LOGS.getKey(), ReadOffset.lastConsumed()), redisInsertLogReceiver);
+//    }
+//
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertLog0(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertLog(listenerContainer, 0);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertLog1(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertLog(listenerContainer, 1);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertLog2(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertLog(listenerContainer, 2);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/config/ConsumerStoneOrderRedisStreamConfig.java

-package com.liquidnet.servce.consumer.stone.service.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.servce.consumer.stone.service.receiver.RedisInsertOrderReceiver;
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.var;
-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.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerStoneOrderRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    RedisInsertOrderReceiver redisInsertOrderReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveSqlStoneInsertOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.StoneQueue.STONE_ORDER_COUPON.getGroup(), getConsumerName(MQConst.StoneQueue.STONE_ORDER_COUPON.name() + t)),
-                StreamOffset.create(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(), ReadOffset.lastConsumed()), redisInsertOrderReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertOrder0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertOrder(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertOrder1(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertOrder(listenerContainer, 1);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertOrder2(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertOrder(listenerContainer, 2);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//package com.liquidnet.servce.consumer.stone.service.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.servce.consumer.stone.service.receiver.RedisInsertOrderReceiver;
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.var;
+//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.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//@Configuration
+//public class ConsumerStoneOrderRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    RedisInsertOrderReceiver redisInsertOrderReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveSqlStoneInsertOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.StoneQueue.STONE_ORDER_COUPON.getGroup(), getConsumerName(MQConst.StoneQueue.STONE_ORDER_COUPON.name() + t)),
+//                StreamOffset.create(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(), ReadOffset.lastConsumed()), redisInsertOrderReceiver);
+//    }
+//
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertOrder0(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertOrder(listenerContainer, 0);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertOrder1(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertOrder(listenerContainer, 1);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertOrder2(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertOrder(listenerContainer, 2);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/config/ConsumerStoneUserRedisStreamConfig.java

-package com.liquidnet.servce.consumer.stone.service.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.servce.consumer.stone.service.receiver.RedisInsertUserReceiver;
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.var;
-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.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerStoneUserRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    RedisInsertUserReceiver redisInsertUserReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveSqlStoneInsertUser(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.StoneQueue.STONE_INSERT_USER.getGroup(), getConsumerName(MQConst.StoneQueue.STONE_INSERT_USER.name() + t)),
-                StreamOffset.create(MQConst.StoneQueue.STONE_INSERT_USER.getKey(), ReadOffset.lastConsumed()), redisInsertUserReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertUser0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertUser(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertUser1(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertUser(listenerContainer, 1);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    @Bean
-    public Subscription subscriptionSqlStoneInsertUser2(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlStoneInsertUser(listenerContainer, 2);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//package com.liquidnet.servce.consumer.stone.service.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.servce.consumer.stone.service.receiver.RedisInsertUserReceiver;
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.var;
+//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.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//@Configuration
+//public class ConsumerStoneUserRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    RedisInsertUserReceiver redisInsertUserReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveSqlStoneInsertUser(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.StoneQueue.STONE_INSERT_USER.getGroup(), getConsumerName(MQConst.StoneQueue.STONE_INSERT_USER.name() + t)),
+//                StreamOffset.create(MQConst.StoneQueue.STONE_INSERT_USER.getKey(), ReadOffset.lastConsumed()), redisInsertUserReceiver);
+//    }
+//
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertUser0(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertUser(listenerContainer, 0);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertUser1(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertUser(listenerContainer, 1);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    @Bean
+//    public Subscription subscriptionSqlStoneInsertUser2(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlStoneInsertUser(listenerContainer, 2);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/receiver/RedisInsertLogReceiver.java

-package com.liquidnet.servce.consumer.stone.service.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-@Slf4j
-@Component
-public class RedisInsertLogReceiver extends AbstractRedisReceiver {
-
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.StoneQueue.STONE_INSERT_LOGS.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.StoneQueue.STONE_INSERT_LOGS.getGroup();
-    }
-}
+//package com.liquidnet.servce.consumer.stone.service.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//@Slf4j
+//@Component
+//public class RedisInsertLogReceiver extends AbstractRedisReceiver {
+//
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.StoneQueue.STONE_INSERT_LOGS.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.StoneQueue.STONE_INSERT_LOGS.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/receiver/RedisInsertOrderReceiver.java

-package com.liquidnet.servce.consumer.stone.service.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-@Slf4j
-@Component
-public class RedisInsertOrderReceiver extends AbstractRedisReceiver {
-
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.StoneQueue.STONE_ORDER_COUPON.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.StoneQueue.STONE_ORDER_COUPON.getGroup();
-    }
-}
+//package com.liquidnet.servce.consumer.stone.service.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//@Slf4j
+//@Component
+//public class RedisInsertOrderReceiver extends AbstractRedisReceiver {
+//
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.StoneQueue.STONE_ORDER_COUPON.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.StoneQueue.STONE_ORDER_COUPON.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/receiver/RedisInsertUserReceiver.java

-package com.liquidnet.servce.consumer.stone.service.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-@Slf4j
-@Component
-public class RedisInsertUserReceiver extends AbstractRedisReceiver {
-
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.StoneQueue.STONE_INSERT_USER.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.StoneQueue.STONE_INSERT_USER.getGroup();
-    }
-}
+//package com.liquidnet.servce.consumer.stone.service.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//@Slf4j
+//@Component
+//public class RedisInsertUserReceiver extends AbstractRedisReceiver {
+//
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.StoneQueue.STONE_INSERT_USER.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.StoneQueue.STONE_INSERT_USER.getGroup();
+//    }
+//}