如题,在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
}
}