From accafa97cd429c045f432a60ccc7c5d386c3a1f8 Mon Sep 17 00:00:00 2001 From: khalil <842328916@qq.com> Date: Thu, 25 Sep 2025 14:45:21 +0800 Subject: [PATCH] =?UTF-8?q?mq-=E8=B0=83=E4=BD=8E=E6=AF=8F=E4=B8=AA?= =?UTF-8?q?=E6=B6=88=E8=B4=B9=E7=BB=84=E5=BA=95=E5=B1=82=E6=B6=88=E8=B4=B9?= =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E6=B1=A0=E7=9A=84=E6=A0=B8=E5=BF=83=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/accompany/mq/consumer/ActTaskRewardConsumer.java | 2 +- .../java/com/accompany/mq/consumer/ActUserTaskConsumer.java | 2 +- .../com/accompany/mq/consumer/ActivityPackMessageConsumer.java | 2 +- .../java/com/accompany/mq/consumer/BillMessageConsumer.java | 3 +-- .../java/com/accompany/mq/consumer/BravoMessageConsumer.java | 2 +- .../com/accompany/mq/consumer/GameMsgPushMessageConsumer.java | 2 +- .../java/com/accompany/mq/consumer/GiftMessageConsumer.java | 2 +- .../java/com/accompany/mq/consumer/Lucky24MessageConsumer.java | 2 +- .../java/com/accompany/mq/consumer/Lucky25MessageConsumer.java | 2 +- .../mq/consumer/MiniGameMatchRoundMessageConsumer.java | 2 +- .../com/accompany/mq/consumer/OpenBoxPrizeMessageConsumer.java | 2 +- .../com/accompany/mq/consumer/PayFinishMessageConsumer.java | 2 +- .../accompany/mq/consumer/YiDunIMTextAntiMessageConsumer.java | 2 +- 13 files changed, 13 insertions(+), 14 deletions(-) diff --git a/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActTaskRewardConsumer.java b/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActTaskRewardConsumer.java index a72f1983a..0ebe07b16 100644 --- a/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActTaskRewardConsumer.java +++ b/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActTaskRewardConsumer.java @@ -34,7 +34,7 @@ import java.util.concurrent.ThreadPoolExecutor; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.ACT_TASK_REWARD_TOPIC, consumerGroup = MqConstant.ACT_TASK_REWARD_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.ACT_TASK_REWARD_TOPIC, consumerGroup = MqConstant.ACT_TASK_REWARD_CONSUME_GROUP, consumeThreadNumber = 2) public class ActTaskRewardConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActUserTaskConsumer.java b/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActUserTaskConsumer.java index 41d1c24da..fb95c95b7 100644 --- a/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActUserTaskConsumer.java +++ b/accompany-business/accompany-business-festival-activity/fastival-activity-mq/src/main/java/com/accompany/mq/consumer/ActUserTaskConsumer.java @@ -42,7 +42,7 @@ import java.util.stream.Collectors; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.ACT_USER_TASK_TOPIC, consumerGroup = MqConstant.ACT_USER_TASK_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.ACT_USER_TASK_TOPIC, consumerGroup = MqConstant.ACT_USER_TASK_CONSUME_GROUP, consumeThreadNumber = 2) public class ActUserTaskConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/ActivityPackMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/ActivityPackMessageConsumer.java index 2a1dcd5d8..52fd54c43 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/ActivityPackMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/ActivityPackMessageConsumer.java @@ -23,7 +23,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.ACTIVITY_PACK_TOPIC, consumerGroup = MqConstant.ACTIVITY_PACK_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.ACTIVITY_PACK_TOPIC, consumerGroup = MqConstant.ACTIVITY_PACK_CONSUME_GROUP, consumeThreadNumber = 2) public class ActivityPackMessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BillMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BillMessageConsumer.java index 998e9a01b..6a03a7cde 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BillMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BillMessageConsumer.java @@ -13,8 +13,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.BILL_RECORD_TOPIC, consumerGroup = MqConstant.BILL_RECORD_CONSUME_GROUP) -//@RocketMQMessageListener(topic = MqConstant.BILL_RECORD_TOPIC, consumerGroup = MqConstant.BILL_RECORD_CONSUME_GROUP, consumeMode = ConsumeMode.ORDERLY) +@RocketMQMessageListener(topic = MqConstant.BILL_RECORD_TOPIC, consumerGroup = MqConstant.BILL_RECORD_CONSUME_GROUP, consumeThreadNumber = 16) public class BillMessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BravoMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BravoMessageConsumer.java index 3fd825e77..79dda730c 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BravoMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/BravoMessageConsumer.java @@ -13,7 +13,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.BRAVO_TOPIC, consumerGroup = MqConstant.BRAVO_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.BRAVO_TOPIC, consumerGroup = MqConstant.BRAVO_CONSUME_GROUP, consumeThreadNumber = 8) public class BravoMessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GameMsgPushMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GameMsgPushMessageConsumer.java index 82fd4a1e8..d06acdb16 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GameMsgPushMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GameMsgPushMessageConsumer.java @@ -18,7 +18,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.GAME_MSG_PUSH_TOPIC, consumerGroup = MqConstant.GAME_MSG_PUSH_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.GAME_MSG_PUSH_TOPIC, consumerGroup = MqConstant.GAME_MSG_PUSH_CONSUME_GROUP, consumeThreadNumber = 8) public class GameMsgPushMessageConsumer extends AbstractMessageListener { @Autowired 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 22bb9c4b5..e964a6163 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 @@ -13,7 +13,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.GIFT_TOPIC, consumerGroup = MqConstant.GIFT_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.GIFT_TOPIC, consumerGroup = MqConstant.GIFT_CONSUME_GROUP, consumeThreadNumber = 16) //@RocketMQMessageListener(topic = MqConstant.GIFT_TOPIC, consumerGroup = MqConstant.GIFT_CONSUME_GROUP, consumeMode = ConsumeMode.ORDERLY) public class GiftMessageConsumer extends AbstractMessageListener { diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky24MessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky24MessageConsumer.java index 20e3a0c49..5df723719 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky24MessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky24MessageConsumer.java @@ -13,7 +13,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.LUCKY_24_TOPIC, consumerGroup = MqConstant.LUCKY_24_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.LUCKY_24_TOPIC, consumerGroup = MqConstant.LUCKY_24_CONSUME_GROUP, consumeThreadNumber = 16) public class Lucky24MessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky25MessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky25MessageConsumer.java index d64289439..70b08bfaf 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky25MessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/Lucky25MessageConsumer.java @@ -13,7 +13,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.LUCKY_25_TOPIC, consumerGroup = MqConstant.LUCKY_25_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.LUCKY_25_TOPIC, consumerGroup = MqConstant.LUCKY_25_CONSUME_GROUP, consumeThreadNumber = 4) public class Lucky25MessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/MiniGameMatchRoundMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/MiniGameMatchRoundMessageConsumer.java index a58dcfc4c..61820c7c3 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/MiniGameMatchRoundMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/MiniGameMatchRoundMessageConsumer.java @@ -19,7 +19,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.MINI_GAME_MATCH_ROUND_TOPIC, consumerGroup = MqConstant.MINI_GAME_MATCH_ROUND_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.MINI_GAME_MATCH_ROUND_TOPIC, consumerGroup = MqConstant.MINI_GAME_MATCH_ROUND_CONSUME_GROUP, consumeThreadNumber = 4) public class MiniGameMatchRoundMessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/OpenBoxPrizeMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/OpenBoxPrizeMessageConsumer.java index 14f52e825..d870151a2 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/OpenBoxPrizeMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/OpenBoxPrizeMessageConsumer.java @@ -21,7 +21,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.OPEN_BOX_TOPIC, consumerGroup = MqConstant.OPEN_BOX_CONSUME_GROUP, consumeMode = ConsumeMode.ORDERLY) +@RocketMQMessageListener(topic = MqConstant.OPEN_BOX_TOPIC, consumerGroup = MqConstant.OPEN_BOX_CONSUME_GROUP, consumeMode = ConsumeMode.ORDERLY, consumeThreadNumber = 4) public class OpenBoxPrizeMessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/PayFinishMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/PayFinishMessageConsumer.java index b02581593..88aff2b1c 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/PayFinishMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/PayFinishMessageConsumer.java @@ -24,7 +24,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.PAY_FINISH_TOPIC, consumerGroup = MqConstant.PAY_FINISH_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.PAY_FINISH_TOPIC, consumerGroup = MqConstant.PAY_FINISH_CONSUME_GROUP, consumeThreadNumber = 4) public class PayFinishMessageConsumer extends AbstractMessageListener { @Autowired diff --git a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/YiDunIMTextAntiMessageConsumer.java b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/YiDunIMTextAntiMessageConsumer.java index 2dd4ee79f..6557a1209 100644 --- a/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/YiDunIMTextAntiMessageConsumer.java +++ b/accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/YiDunIMTextAntiMessageConsumer.java @@ -19,7 +19,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component @ConditionalOnProperty(name = "spring.application.name", havingValue = "web") -@RocketMQMessageListener(topic = MqConstant.YI_DUN_TEXT_ANTI_TOPIC, consumerGroup = MqConstant.YI_DUN_TEXT_ANTI_CONSUME_GROUP) +@RocketMQMessageListener(topic = MqConstant.YI_DUN_TEXT_ANTI_TOPIC, consumerGroup = MqConstant.YI_DUN_TEXT_ANTI_CONSUME_GROUP, consumeThreadNumber = 2) public class YiDunIMTextAntiMessageConsumer extends AbstractMessageListener { @Autowired