diff --git a/project/src/main/java/com/nageoffer/shortlink/project/mq/idempotent/MessageQueueIdempotentHandler.java b/project/src/main/java/com/nageoffer/shortlink/project/mq/idempotent/MessageQueueIdempotentHandler.java
index ad50b18a28cbad82870c983f8f9349fe1de9deb2..c65541f4dee0513ddf8fe25cfc8a3d1730f5c7a7 100644
--- a/project/src/main/java/com/nageoffer/shortlink/project/mq/idempotent/MessageQueueIdempotentHandler.java
+++ b/project/src/main/java/com/nageoffer/shortlink/project/mq/idempotent/MessageQueueIdempotentHandler.java
@@ -65,7 +65,9 @@ public class MessageQueueIdempotentHandler {
      */
     public void setAccomplish(String messageId) {
         String key = IDEMPOTENT_KEY_PREFIX + messageId;
-        stringRedisTemplate.opsForValue().set(key, "1", 2, TimeUnit.MINUTES);
+        if (Objects.equals(stringRedisTemplate.opsForValue().get(key), "0")) {
+            stringRedisTemplate.opsForValue().set(key, "1", 2, TimeUnit.MINUTES);
+        }
     }
 
     /**