feat():修改ktlv

cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/controller/SysCarMessageController.java

@@ -78,11 +78,11 @@ public class SysCarMessageController extends BaseController {
             }
             String value = new String(result);
             kafKaDataList.add(KafKaData.builder()
-                            .key(carMessage.getMessageTypeCode())
+                    .key(carMessage.getMessageTypeCode())
-                            .label(carMessage.getMessageTypeCode())
+                    .label(carMessage.getMessageTypeCode())
-                            .value(value)
+                    .value(value)
-                            .type("String")
+                    .type("String")
-                            .build());
+                    .build());
         }
 
 //        String jsonString = """
@@ -179,48 +179,4 @@ public class SysCarMessageController extends BaseController {
         return success();
     }
 
-//    public String message() {
-//        String topic = "vehicle";
-//        String content = "Message from MqttPublishSample";
-//        int qos = 2;
-//        String broker = "tcp://106.15.136.7:1883";
-//        String clientId = "JavaSample";
-//        try {
-//            // 第三个参数为空，默认持久化策略
-//            MqttClient sampleClient = new MqttClient(broker, clientId);
-//            MqttConnectOptions connOpts = new MqttConnectOptions();
-//            connOpts.setCleanSession(true);
-//            System.out.println("Connecting to broker: " + broker);
-//            sampleClient.connect(connOpts);
-//            sampleClient.subscribe(topic, 0);
-//            sampleClient.setCallback(new MqttCallback() {
-//                // 连接丢失
-//                @Override
-//                public void connectionLost(Throwable throwable) {
-//
-//                }
-//
-//                // 连接成功
-//                @Override
-//                public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
-//                    System.out.println(new String(mqttMessage.getPayload()));
-//                }
-//
-//                // 接收信息
-//                @Override
-//                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
-//
-//                }
-//            });
-//        } catch (MqttException me) {
-//            System.out.println("reason " + me.getReasonCode());
-//            System.out.println("msg " + me.getMessage());
-//            System.out.println("loc " + me.getLocalizedMessage());
-//            System.out.println("cause " + me.getCause());
-//            System.out.println("excep " + me);
-//            me.printStackTrace();
-//        }
-//        return this.messageArrived();
-//    }
-
 }

cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/remote/CarMessageRemote.java

@@ -1,19 +0,0 @@
-package com.muyu.parsing.remote;
-
-import com.muyu.common.core.domain.Result;
-import com.muyu.parsing.domain.SysCarMessage;
-import org.springframework.web.bind.annotation.GetMapping;
-
-import java.util.List;
-
-/**
- * @ClassName CarMessageRemote
- * @Description 描述
- * @Author Chen
- * @Date 2024/9/28 23:45
- */
-
-//public interface CarMessageRemote {
-//    @GetMapping("/list")
-//    public Result<List<SysCarMessage>> list(SysCarMessage sysCarMessage);
-//}