one-YI
/
cloud-server
5
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat():二次优化格式，增加firmCode

dev.protocol.parsing
chentaisen 2024-10-07 10:22:59 +08:00
parent ff492390b1
commit b12076b5d5
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
View File

@ -87,15 +87,15 @@ public class MqttTest {
.key(carMessage.getMessageTypeCode()) .key(carMessage.getMessageTypeCode())
.label(carMessage.getMessageTypeCode()) .label(carMessage.getMessageTypeCode())
.value(value) .value(value)
.type("String") .type(carMessage.getMessageType())
.build()); .build());
}
kafKaDataList.add(KafKaData.builder() kafKaDataList.add(KafKaData.builder()
.key("firmCode") .key("firmCode")
.label("企业编码") .label("企业编码")
.value("firm01") .value("firm01")
.type("String") .type("String")
.build()); .build());
}
String jsonString = JSONObject.toJSONString(kafKaDataList); String jsonString = JSONObject.toJSONString(kafKaDataList);
ProducerRecord<String, String> producerRecord = new ProducerRecord<>(KafkaConstants.KafkaTopic, jsonString); ProducerRecord<String, String> producerRecord = new ProducerRecord<>(KafkaConstants.KafkaTopic, jsonString);
@ -108,7 +108,6 @@ public class MqttTest {
} }
// 接收信息 // 接收信息
@Override @Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {