Как получить объект из MQTT полезной нагрузки сообщения

Получив 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)

источник

2016-08-28 manish

Как вы пишете объект в этом сообщении? Он не похож на сериализованный объект Java. – eckes

javascript отправляет сообщение JSON, которое я получаю в java – manish

Скорее всего, это не объект Java. – eckes

Вам нужен JSON parser не библиотека Serialization Apache.

Что-то вроде JSON.org парсер

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

источник

2016-08-28 18:29:00 hardillb

Как получить объект из MQTT полезной нагрузки сообщения

ответ

Смежные вопросы