java - 如何从MQTT消息有效负载获取对象

收到mqtt消息后，我正在尝试从有效负载（字节[]）中获取对象

Object ob = SerializationUtils.deserialize(message.getPayload());

我正进入（状态：

org.apache.commons.lang.SerializationException: java.io.StreamCorruptedException: invalid stream header: 7B22736E
    at org.apache.commons.lang.SerializationUtils.deserialize(SerializationUtils.java:168)
    at org.apache.commons.lang.SerializationUtils.deserialize(SerializationUtils.java:193)

最佳答案

您需要一个JSON解析器，而不是Apache Commons Serialization库。

类似于JSON.org解析器

JSONObject obj = new JSONObject(msg.toString());