更新

root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java

@@ -166,11 +166,11 @@ public class RootCloudIotDataReceiptedEvent implements Serializable {
 
     private Online __online__;
 
-    @JsonIgnoreProperties(ignoreUnknown = true)
-    private String __thingName__;
+    @JsonProperty("__thingName__")
+    private Object thingName;
 
     @Data
-    public static class Online{
+    public static class Online {
         private boolean connected;
 
         private boolean directlyLinked;

root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java

@@ -1,6 +1,9 @@
 package com.qniao.iot.rc.event;
 
+import cn.hutool.core.text.CharSequenceUtil;
 import cn.hutool.core.util.ByteUtil;
+import cn.hutool.core.util.CharsetUtil;
+import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.qniao.iot.rc.RootCloudIotDataReceiptedEvent;
@@ -23,6 +26,7 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese
     @Override
     public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException {
 
+        log.info("接受的信息：{}", StrUtil.str(message, CharsetUtil.UTF_8));
         return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class);
     }