From 0f532033b02c6c058febfdb81f4a0ba2ad972a98 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Thu, 7 May 2026 13:29:08 +0800
Subject: [PATCH] =?UTF-8?q?fix(mq):=20=E4=BF=AE=E6=AD=A3=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E6=B6=88=E8=B4=B9=E6=88=90=E5=8A=9F=E5=90=8E=E7=9A=84Redis?=
 =?UTF-8?q?=E7=BC=93=E5=AD=98=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/njcn/message/consumer/AppAutoDataConsumer.java  | 5 +++--
 .../java/com/njcn/message/consumer/CldHeartConsumer.java     | 5 +++--
 .../java/com/njcn/message/consumer/RealDataConsumer.java     | 4 ++--
 3 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
index afcc328..ef09f4b 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
@@ -86,11 +86,12 @@ public class AppAutoDataConsumer extends EnhanceConsumerMessageHandler<AppAutoDa
     }
 
     /**
-     * 消费成功，缓存到redis72小时，避免重复消费
+     * 消费成功，缓存到redis 5分钟，避免重复消费
      */
     @Override
     protected void consumeSuccess(AppAutoDataMessage message) {
-        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+//        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, 5 * 60L);
     }
 
     /**
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java
index ee6defd..0a63fd7 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java
@@ -68,11 +68,12 @@ public class CldHeartConsumer extends EnhanceConsumerMessageHandler<CldHeartBeat
     }
 
     /**
-     * 消费成功，缓存到redis72小时，避免重复消费
+     * 消费成功，缓存到redis 5分钟，避免重复消费
      */
     @Override
     protected void consumeSuccess(CldHeartBeatMessage message) {
-        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+//        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, 5 * 60L);
     }
 
     /**
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java
index 341753b..c49979a 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java
@@ -71,11 +71,11 @@ public class RealDataConsumer extends EnhanceConsumerMessageHandler<AppAutoDataM
     }
 
     /**
-     * 消费成功，缓存到redis72小时，避免重复消费
+     * 消费成功，缓存到redis 5分钟，避免重复消费
      */
     @Override
     protected void consumeSuccess(AppAutoDataMessage message) {
-        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, 5 * 60L);
     }
 
     /**