111

src/main/java/com/fdkankan/contro/mq/listener/AbstrackBuildSceneListener.java

@@ -35,15 +35,15 @@ public class AbstrackBuildSceneListener implements IBuildSceneListener {
     public void preHandle(Channel channel, String queueName, Message message, IBuildSceneService buildSceneService, String bizType) throws IOException {
         // 添加消息幂等处理
         String messageId = message.getMessageProperties().getMessageId();
-        if(!ObjectUtils.isEmpty(messageId)){
-            // 设置消息id幂等性，防止消息重复消费
-            boolean lock = redisLockUtil.lock(RedisConstants.SCENE_PREPARE_BUILDING + messageId, 24 * 3600);
-            if (!lock) {
-                log.error("服务：{}，消息重复消费：{}", "常驻服务", messageId);
-                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-                return;
-            }
-        }
+//        if(!ObjectUtils.isEmpty(messageId)){
+//            // 设置消息id幂等性，防止消息重复消费
+//            boolean lock = redisLockUtil.lock(RedisConstants.SCENE_PREPARE_BUILDING + messageId, 24 * 3600);
+//            if (!lock) {
+//                log.error("服务：{}，消息重复消费：{}", "常驻服务", messageId);
+//                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+//                return;
+//            }
+//        }
 
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
         log.info("开始准备场景计算资源，队列名：{}，id：{},消息体:{}", queueName, messageId, msg);
@@ -74,15 +74,15 @@ public class AbstrackBuildSceneListener implements IBuildSceneListener {
     public void postHandle(Channel channel, String queueName, Message message, IBuildSceneService buildSceneService, String bizType) throws Exception {
         // 添加消息幂等处理
         String messageId = message.getMessageProperties().getMessageId();
-        if(!ObjectUtils.isEmpty(messageId)){
-            // 设置消息id幂等性，防止消息重复消费
-            boolean lock = redisLockUtil.lock(RedisConstants.SCENE_POST_BUILDING + messageId, 24 * 3600);
-            if (!lock) {
-                log.error("服务：{}，消息重复消费：{}", "常驻服务", messageId);
-                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-                return;
-            }
-        }
+//        if(!ObjectUtils.isEmpty(messageId)){
+//            // 设置消息id幂等性，防止消息重复消费
+//            boolean lock = redisLockUtil.lock(RedisConstants.SCENE_POST_BUILDING + messageId, 24 * 3600);
+//            if (!lock) {
+//                log.error("服务：{}，消息重复消费：{}", "常驻服务", messageId);
+//                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+//                return;
+//            }
+//        }
 
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
         log.info("场景计算完成，开始处理场景计算结果，队列名：{}，id：{},消息体:{}", queueName, messageId, msg);