by2025/SmartParks
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rocketmq消费者组修改

Browse Source
This commit is contained in:
lxj
2025-08-27 17:59:56 +08:00
parent 9897bb8db7
commit 3c8eb59165
3 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/RocketMqConstants.java
View File

@@ -9,8 +9,10 @@ public interface RocketMqConstants {
// mq topic // mq topic
String TOPIC = "SmartParks"; String TOPIC = "SmartParks";
// mq GROUP // 人比比对消费者组
String GROUP = "SmartParksEqp"; String COMPAREGROUP = "SmartParks-compare";
// 人脸抓拍消费者组
String CAPTUREGROUP = "SmartParks-capture";
/*-----------------------------------消息tag------------------------------------*/ /*-----------------------------------消息tag------------------------------------*/
String HIKADD = "ADD_HIK_DEVICE_TAG"; String HIKADD = "ADD_HIK_DEVICE_TAG";

2
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java
View File

@@ -22,7 +22,7 @@ import org.springframework.stereotype.Component;
@RequiredArgsConstructor @RequiredArgsConstructor
@RocketMQMessageListener( @RocketMQMessageListener(
topic = RocketMqConstants.TOPIC, topic = RocketMqConstants.TOPIC,
consumerGroup = RocketMqConstants.GROUP, consumerGroup = RocketMqConstants.CAPTUREGROUP,
selectorExpression = RocketMqConstants.FACECAPTURE selectorExpression = RocketMqConstants.FACECAPTURE
) )
public class FaceCaptureConsumer implements RocketMQListener<MessageExt> { public class FaceCaptureConsumer implements RocketMQListener<MessageExt> {

4
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java
View File

@@ -21,7 +21,7 @@ import org.springframework.stereotype.Component;
@RequiredArgsConstructor @RequiredArgsConstructor
@RocketMQMessageListener( @RocketMQMessageListener(
topic = RocketMqConstants.TOPIC, topic = RocketMqConstants.TOPIC,
consumerGroup = RocketMqConstants.GROUP, consumerGroup = RocketMqConstants.COMPAREGROUP,
selectorExpression = RocketMqConstants.FACECOMPARE selectorExpression = RocketMqConstants.FACECOMPARE
) )
public class FaceCompareConsumer implements RocketMQListener<MessageExt> { public class FaceCompareConsumer implements RocketMQListener<MessageExt> {
@@ -32,7 +32,7 @@ public class FaceCompareConsumer implements RocketMQListener<MessageExt> {
log.info("消费人脸比对数据，数据长度={}", ext.getBody().length); log.info("消费人脸比对数据，数据长度={}", ext.getBody().length);
try { try {
FaceCompare compare = JSONObject.parseObject(ext.getBody(), FaceCompare.class); FaceCompare compare = JSONObject.parseObject(ext.getBody(), FaceCompare.class);
} catch (Exception e) { } catch (Exception e) {
log.error("消费比对抓拍数据处理失败，", e); log.error("消费比对抓拍数据处理失败，", e);
} }