From aba0631b5857714b8359684a997a11f2545ffad8 Mon Sep 17 00:00:00 2001 From: khalil Date: Sat, 19 Oct 2024 21:06:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1-=E7=A4=BC?= =?UTF-8?q?=E7=89=A9-mq-=E8=A1=A5=E5=81=BF=E5=89=8Ddouble=20check?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../accompany/business/service/gift/GiftMessageService.java | 6 ++++++ .../java/com/accompany/mq/consumer/GiftMessageConsumer.java | 5 ----- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/GiftMessageService.java b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/GiftMessageService.java index 51cae7803..a722a108a 100644 --- a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/GiftMessageService.java +++ b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/GiftMessageService.java @@ -48,6 +48,12 @@ public class GiftMessageService extends BaseService { logger.warn("handleGiftMessage giftMessage had handle, mess: " + giftMessage); return; } + + if (!jedisService.hexists(RedisKey.mq_gift_status.getKey(), giftMessage.getMessId())){ + logger.warn("handleGiftMessage giftMessage had handle, mess: " + giftMessage); + return; + } + logger.info("【处理礼物mq】 giftMessage: {}", giftMessage); long totalGoldNum = giftMessage.getGoldNum(); diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GiftMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GiftMessageConsumer.java index 6df569b2c..872298133 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GiftMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GiftMessageConsumer.java @@ -27,11 +27,6 @@ public class GiftMessageConsumer extends AbstractMessageListener { @Override public void onMessage(GiftMessage giftMessage) { log.info("onMessage giftMessage: {}", giftMessage.toString()); - // 判断该消息是否已经消费过 - String messStatus = jedisService.hget(RedisKey.mq_gift_status.getKey(), giftMessage.getMessId()); - if (BlankUtil.isBlank(messStatus)) { - return; - } giftMessageService.handleGiftMessage(giftMessage); }