java到节点。js代码转换

Question

我正在使用以下java代码来展开数据。但我不知道如何为Node编写相同的代码。js？Java代码如下所示：

public void receiveEvent(String forTopic, MqttMessage event)
        throws MqttException {
    Object obj = null;
    java.io.ByteArrayInputStream bstream = new   java.io.ByteArrayInputStream(
            event.getPayload());
    try {
        java.io.ObjectInputStream st = new java.io.ObjectInputStream(
                bstream);
        obj = st.readObject();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } catch (ClassNotFoundException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    DataWrapper dt = (DataWrapper) obj;
 s.notifyReceived(forTopic, dt.getObject(), dt.getDevice());

数据包装器的代码如下所示：

public class DataWrapper implements Serializable {
private static final long serialVersionUID = 1L;
Device device;
Object object;
public void setDevice(Device deviceInfo) {
    this.device = deviceInfo;
}
public void setObject(Object object) {
    this.object = object;
}
public Device getDevice() {
    return device;
}
public Object getObject() {
    return object;
}

}

Answer 1

您可能需要研究MQTT。js。可以在NPM上找到：https://www.npmjs.com/package/mqtt

作为一个完整的例子，我们需要更多地了解您的设置和您正在尝试做的事情。。。但这里是从MQTT，js复制过来的示例

var mqtt    = require('mqtt');
var client  = mqtt.connect('mqtt://test.mosquitto.org');

client.on('connect', function () {
  client.subscribe('presence');
  client.publish('presence', 'Hello mqtt');
});

client.on('message', function (topic, message) {
  // message is Buffer 
  console.log(message.toString());
  client.end();
});

这可能非常接近你想要的开始