MQTT Java,如何获取MQTT broker上面指定topic的信息内容。

如题,在Java编程中,如何获取MQTT broker上指定topic的消息,不是print模式,是要用get方法得到这个信息内容。并且能够用构造器获得topic这个string。用哪一个Java代码来实现?最好是举个例子。 我知道有个命令就是callback, 但是不会用。因为如果调用public void messageArrived, 我需要输入String s还有mqttMessage。我的目标就是获取指定topic的mqttMessage,所以感觉这个代码不对,请大神指点一下。

public class SimpleMqttCallBack implements MqttCallback {

  public void connectionLost(Throwable throwable) {
    System.out.println("Connection to MQTT broker lost!");
  }

  public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
    System.out.println("Message received:\n\t"+ new String(mqttMessage.getPayload()) );
  }

  public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
    // not used in this example
  }
}

 

https://www.cnblogs.com/rain1024/p/12358023.html

你看下这个对你有没有帮助,java整合MQTT,服务端客户端简易案例都有