diff --git a/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java b/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java
index 8d533f9..b83d893 100644
--- a/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java
+++ b/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java
@@ -1,5 +1,6 @@
 package com.njcn.middle.rocket.domain;
 
+import cn.hutool.core.util.IdUtil;
 import lombok.Data;
 
 import java.time.LocalDateTime;
@@ -15,7 +16,7 @@ public abstract class BaseMessage {
     /**
      * 业务键，用于RocketMQ控制台查看消费情况
      */
-    protected String key;
+    protected String key = IdUtil.getSnowflake().nextIdStr();
 
     /**
      * 发送消息来源，用于排查问题