From 9aafc10be83aaec35e809a10d99b7b90b09c243f Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期四, 12 二月 2026 16:49:40 +0800
Subject: [PATCH] 处理启动失败问题
---
xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java | 93 ++++------------------------------------------
1 files changed, 9 insertions(+), 84 deletions(-)
diff --git a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
index 8eb081a..a1593f8 100644
--- a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
+++ b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
@@ -12,110 +12,35 @@
public class KafkaConsumerService {
/**
- * 消费消息 - 自动驾驶主题
+ * 消费消息 - XPU上报Robotaxi云端的消息topic（高优先级）
*
* @param message 消息内容
*/
- @KafkaListener(topics = "automatic-pilot-topic", groupId = "xp-automaticPilot-group")
+ @KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
public void consumeAutomaticPilotMessage(String message) {
try {
- log.info("收到自动驾驶主题消息: {}", message);
- // 处理消息逻辑
- processMessage(message);
+ log.info("收到XPU上报高优先级主题消息: {}", message);
} catch (Exception e) {
- log.error("处理消息失败: {}", message, e);
+ log.error("处理XPU上报高优先级主题消息失败: {}", message, e);
throw e;
}
}
/**
- * 消费消息 - 车辆状态主题
+ * 消费消息 - XPU上报Robotaxi云端的消息topic（低优先级）
*
* @param message 消息内容
*/
- @KafkaListener(topics = "vehicle-status-topic", groupId = "xp-automaticPilot-group")
+ @KafkaListener(topics = "topic-prod-robotaxi-xpu-normal", groupId = "group-robotaxi-xpu")
public void consumeVehicleStatusMessage(String message) {
try {
- log.info("收到车辆状态主题消息: {}", message);
- // 处理车辆状态消息逻辑
- processVehicleStatus(message);
+ log.info("收到XPU上报低优先级主题消息: {}", message);
+
} catch (Exception e) {
- log.error("处理车辆状态消息失败: {}", message, e);
+ log.error("处理XPU上报低优先级主题消息失败: {}", message, e);
throw e;
}
}
- /**
- * 消费消息 - 导航主题
- *
- * @param message 消息内容
- */
- @KafkaListener(topics = "navigation-topic", groupId = "xp-automaticPilot-group")
- public void consumeNavigationMessage(String message) {
- try {
- log.info("收到导航主题消息: {}", message);
- // 处理导航消息逻辑
- processNavigation(message);
- } catch (Exception e) {
- log.error("处理导航消息失败: {}", message, e);
- throw e;
- }
- }
- /**
- * 消费消息 - 订单主题
- *
- * @param message 消息内容
- */
- @KafkaListener(topics = "order-topic", groupId = "xp-automaticPilot-group")
- public void consumeOrderMessage(String message) {
- try {
- log.info("收到订单主题消息: {}", message);
- // 处理订单消息逻辑
- processOrder(message);
- } catch (Exception e) {
- log.error("处理订单消息失败: {}", message, e);
- throw e;
- }
- }
-
- /**
- * 处理消息逻辑（示例）
- *
- * @param message 消息内容
- */
- private void processMessage(String message) {
- // TODO: 实现具体的消息处理逻辑
- log.info("处理自动驾驶消息: {}", message);
- }
-
- /**
- * 处理车辆状态消息（示例）
- *
- * @param message 消息内容
- */
- private void processVehicleStatus(String message) {
- // TODO: 实现具体的车辆状态处理逻辑
- log.info("处理车辆状态消息: {}", message);
- }
-
- /**
- * 处理导航消息（示例）
- *
- * @param message 消息内容
- */
- private void processNavigation(String message) {
- // TODO: 实现具体的导航处理逻辑
- log.info("处理导航消息: {}", message);
- }
-
- /**
- * 处理订单消息（示例）
- *
- * @param message 消息内容
- */
- private void processOrder(String message) {
- // TODO: 实现具体的订单处理逻辑
- log.info("处理订单消息: {}", message);
- }
}
--
Gitblit v1.7.1