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

feat():修改格式

dev.protocol.parsing
chentaisen 2024-10-07 09:58:50 +08:00
parent 4765f0bb58
commit ff492390b1
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -89,8 +89,15 @@ public class MqttTest {
.value(value) .value(value)
.type("String") .type("String")
.build()); .build());
kafKaDataList.add(KafKaData.builder()
.key("firmCode")
.label("企业编码")
.value("firm01")
.type("String")
.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);
kafkaProducer.send(producerRecord); kafkaProducer.send(producerRecord);
log.info("kafka投产：{}", jsonString); log.info("kafka投产：{}", jsonString);
@ -100,6 +107,8 @@ public class MqttTest {
// System.out.println(jsonString); // System.out.println(jsonString);
} }
// 接收信息 // 接收信息
@Override @Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {