From 3c8eb59165f770a7cd1b36ada535a23ab8ab3d75 Mon Sep 17 00:00:00 2001 From: lxj <15683799673@163.com> Date: Wed, 27 Aug 2025 17:59:56 +0800 Subject: [PATCH] =?UTF-8?q?rocketmq=E6=B6=88=E8=B4=B9=E8=80=85=E7=BB=84?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/dromara/sis/rocketmq/RocketMqConstants.java | 6 ++++-- .../dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java | 2 +- .../dromara/sis/rocketmq/consumer/FaceCompareConsumer.java | 4 ++-- 3 files changed, 7 insertions(+), 5 deletions(-) diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/RocketMqConstants.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/RocketMqConstants.java index d40423a5..1cfafe7a 100644 --- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/RocketMqConstants.java +++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/RocketMqConstants.java @@ -9,8 +9,10 @@ public interface RocketMqConstants { // mq topic String TOPIC = "SmartParks"; - // mq GROUP - String GROUP = "SmartParksEqp"; + // 人比比对消费者组 + String COMPAREGROUP = "SmartParks-compare"; + // 人脸抓拍消费者组 + String CAPTUREGROUP = "SmartParks-capture"; /*-----------------------------------消息tag------------------------------------*/ String HIKADD = "ADD_HIK_DEVICE_TAG"; diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java index 13f68f6c..6e25325c 100644 --- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java +++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java @@ -22,7 +22,7 @@ import org.springframework.stereotype.Component; @RequiredArgsConstructor @RocketMQMessageListener( topic = RocketMqConstants.TOPIC, - consumerGroup = RocketMqConstants.GROUP, + consumerGroup = RocketMqConstants.CAPTUREGROUP, selectorExpression = RocketMqConstants.FACECAPTURE ) public class FaceCaptureConsumer implements RocketMQListener { diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java index c67ce6ac..95b348dd 100644 --- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java +++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java @@ -21,7 +21,7 @@ import org.springframework.stereotype.Component; @RequiredArgsConstructor @RocketMQMessageListener( topic = RocketMqConstants.TOPIC, - consumerGroup = RocketMqConstants.GROUP, + consumerGroup = RocketMqConstants.COMPAREGROUP, selectorExpression = RocketMqConstants.FACECOMPARE ) public class FaceCompareConsumer implements RocketMQListener { @@ -32,7 +32,7 @@ public class FaceCompareConsumer implements RocketMQListener { log.info("消费人脸比对数据,数据长度={}", ext.getBody().length); try { FaceCompare compare = JSONObject.parseObject(ext.getBody(), FaceCompare.class); - + } catch (Exception e) { log.error("消费比对抓拍数据处理失败,", e); }