From f002ac1c5b98f800f7f30238990ed24f3b4f34f6 Mon Sep 17 00:00:00 2001 From: zren25 Date: Mon, 31 Mar 2025 23:36:26 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89mock?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../center/controller/TestController.java | 26 ------------------- 1 file changed, 26 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java index b678140..c558670 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java @@ -1,19 +1,13 @@ package com.volvo.ai.analytic.center.controller; -import com.alibaba.fastjson.JSONObject; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.volvo.ai.analytic.center.dto.corpus.AicorpusTelephoneDTO; import com.volvo.common.core.util.ResultMsg; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.context.config.annotation.RefreshScope; -import org.springframework.kafka.core.KafkaTemplate; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; @@ -30,10 +24,6 @@ public class TestController { @Autowired private RocketMQTemplate rocketMQTemplate; - @Autowired - private KafkaTemplate kafkaTemplate; // 注入 KafkaTemplate - - private final ObjectMapper objectMapper = new ObjectMapper(); @PostMapping("/mockMq") @@ -43,21 +33,5 @@ public class TestController { return ResultMsg.ok("ok"); } - @PostMapping("/mockKafka") - @ApiOperation(value = "生成 Kafka 数据") - public ResultMsg mockKafka(@RequestBody String message) { - try { - AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class); - log.info("mockKafka：{}",message); - for (int i = 0; i < 20; i++){ - aicorpusTelephone.setSourceId(aicorpusTelephone.getSourceId().concat("_"+i)); - kafkaTemplate.send("topic_voc_covert_text_log", JSONObject.toJSONString(aicorpusTelephone)); // 发送 Kafka 消息 - } - log.info("Kafka 消息已发送: {}", message); - } catch (JsonProcessingException e) { - throw new RuntimeException(e); - } - return ResultMsg.ok("Kafka 消息已发送"); - } }