From 528f376f6dce849bc14b589378d87bb1aec1881a Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Tue, 4 Nov 2025 14:09:51 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=91=E5=89=8D=E7=BD=AE=E6=94=B9=E9=80=A0?=
 =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/njcn/message/consumer/BzConsumer.java   | 4 +++-
 .../main/java/com/njcn/message/consumer/CldEventConsumer.java | 2 ++
 .../java/com/njcn/message/consumer/UpdateLedgerConsumer.java  | 4 +++-
 3 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java
index 2057c81..db29ea5 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java
@@ -13,6 +13,7 @@ import com.njcn.redis.utils.RedisUtil;
 import com.njcn.system.api.RocketMqLogFeignClient;
 import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.ConsumeMode;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.stereotype.Service;
@@ -30,8 +31,9 @@ import java.util.Objects;
 @Service
 @RocketMQMessageListener(
         topic = BusinessTopic.REPLY_TOPIC,
-        consumerGroup = BusinessTopic.REPLY_TOPIC,
+        consumerGroup = "RECALL",
         selectorExpression = "RECALL",
+        consumeMode = ConsumeMode.ORDERLY,
         consumeThreadNumber = 10,
         enableMsgTrace = true
 )
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java
index d7ded6d..25d28ef 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java
@@ -12,6 +12,7 @@ import com.njcn.system.api.RocketMqLogFeignClient;
 import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
 import com.njcn.zlevent.api.EventFeignClient;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.ConsumeMode;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.stereotype.Service;
@@ -31,6 +32,7 @@ import java.util.Objects;
         topic = BusinessTopic.LOG_TOPIC,
         consumerGroup = BusinessTopic.LOG_TOPIC,
         consumeThreadNumber = 10,
+        consumeMode = ConsumeMode.ORDERLY,
         enableMsgTrace = true
 )
 @Slf4j
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java
index 2ea56d6..fe2578b 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java
@@ -14,6 +14,7 @@ import com.njcn.redis.utils.RedisUtil;
 import com.njcn.system.api.RocketMqLogFeignClient;
 import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.ConsumeMode;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.stereotype.Service;
@@ -32,8 +33,9 @@ import java.util.Objects;
 @Service
 @RocketMQMessageListener(
         topic = BusinessTopic.REPLY_TOPIC,
-        consumerGroup = BusinessTopic.REPLY_TOPIC,
+        consumerGroup = "LEDGER",
         selectorExpression = "LEDGER",
+        consumeMode = ConsumeMode.ORDERLY,
         consumeThreadNumber = 10,
         enableMsgTrace = true
 )