From ed185efc671142afdd01ce7c1c32a24b96159b48 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Mon, 31 Mar 2025 18:21:19 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9dcc=E6=B6=88=E8=B4=B9?=
 =?UTF-8?q?=E8=80=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
index 9a8059a..a3d4373 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
@@ -28,6 +28,7 @@ import org.springframework.web.bind.annotation.RestController;
 @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}",
 		topic = "${rocketmq.consumer.corpus.dcctopic}",
 		instanceName = "CorpusDccMqConsumer1",
+		consumeThreadNumber = 5,  // 设置5个消费线程
 		enableMsgTrace = true)
 public class CorpusDccMqConsumer implements RocketMQListener<MessageExt>  {
 
@@ -40,6 +41,7 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt>  {
 	public void onMessage(MessageExt messageExt) {
 		long startTime = System.currentTimeMillis();
 		try {
+			log.info("corpusDccMqConsumer1 当前线程: {}, 线程ID: {}", Thread.currentThread().getName(), Thread.currentThread().getId());
 			String message = new String(messageExt.getBody());
 			log.info("dcc_mq message: " + message);
 			AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);