~consumer:order.replace.redisTemplate;

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-slowly.yml

@@ -58,27 +58,27 @@ spring:
   profiles:
     include: common-service #这里加载management相关公共配置
   redis:
-    queue:
+#    queue:
+#      database: ${liquidnet.redis.queue.database}
+#      port: ${liquidnet.redis.queue.port}
+#      host: ${liquidnet.redis.queue.host}
+#      password: ${liquidnet.redis.queue.password}
+#      lettuce:
+#        pool:
+#          max-active: 8
+#          max-wait: -1
+#          max-idle: 8
+#          min-idle: 0
     database: ${liquidnet.redis.queue.database}
+    dbs: ${liquidnet.redis.queue.dbs}
     port: ${liquidnet.redis.queue.port}
     host: ${liquidnet.redis.queue.host}
     password: ${liquidnet.redis.queue.password}
     lettuce:
       pool:
-          max-active: 8
+        max-active: 30
         max-wait: -1
-          max-idle: 8
-          min-idle: 0
-    database: ${liquidnet.redis.kylin.database}
-    dbs: ${liquidnet.redis.kylin.dbs}
-    port: ${liquidnet.redis.kylin.port}
-    host: ${liquidnet.redis.kylin.host}
-    password: ${liquidnet.redis.kylin.password}
-    lettuce:
-      pool:
-        max-active: 20
-        max-wait: -1
-        max-idle: 8
+        max-idle: 20
         min-idle: 0
   data:
     mongodb:

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/config/ConsumerOrderCloseRedisStreamConfig.java

 package com.liquidnet.service.consumer.order.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.consumer.order.receiver.*;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,8 +21,11 @@ import java.util.List;
 
 @Configuration
 public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    StringRedisTemplate stringRedisTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
+    StringRedisTemplate stringRedisTemplate = redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate();
     @Autowired
     ConsumerOrderClose0RdsReceiver consumerOrderClose0RdsReceiver;
     @Autowired

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/receiver/AbstractOrderCloseReceiver.java

 package com.liquidnet.service.consumer.order.receiver;
 
 import com.alibaba.fastjson.JSON;
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.fasterxml.jackson.core.type.TypeReference;
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
@@ -16,7 +16,6 @@ import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.constant.GoblinStatusConst;
 import com.liquidnet.service.goblin.dto.vo.*;
 import com.liquidnet.service.goblin.param.BackCouponParam;
-import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
@@ -46,8 +45,11 @@ import java.util.*;
 
 @Slf4j
 public abstract class AbstractOrderCloseReceiver implements StreamListener<String, MapRecord<String, String, String>> {
+//    @Autowired
+//    StringRedisTemplate stringRedisTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
+    StringRedisTemplate stringRedisTemplate = redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate();
     @Autowired
     private RedisUtil redisUtil;
     @Autowired