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 { @@ -40,6 +41,7 @@ public class CorpusDccMqConsumer implements RocketMQListener { 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);