From f9a916dacb587788edb3e6b6b5cbeffcf1c203e4 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Thu, 17 Aug 2023 09:43:35 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E9=BB=98=E8=AE=A4key?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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();
 
     /**
      * 发送消息来源，用于排查问题