小編典典

最好的方法是構(gòu)造連接邏輯，使其獨(dú)立存在于一個(gè)方法中，以便可以從實(shí)例的connectionLost回調(diào)中再次調(diào)用它MqttCallback。

該connectionLost方法通過Throwable傳遞，該異常將觸發(fā)斷開連接，因此您可以決定根本原因以及重新連接的時(shí)間/方式的影響。

連接方法應(yīng)連接并訂閱您所需的主題。

像這樣：

public class PubSub {

MqttClient client;

String topics[] = ["foo/#", "bar"];

MqttCallback callback = new MqttCallback() {

public void connectionLost(Throwable t) {

this.connect();

}

public void messageArrived(String topic, MqttMessage message) throws Exception {

System.out.println("topic - " + topic + ": " + new String(message.getPayload()));

}

public void deliveryComplete(IMqttDeliveryToken token) {

}

};

public static void main(String args[]) {

PubSub foo = new PubSub();

}

public PubSub(){

this.connect();

}

public void connect(){

client = new MqttClient("mqtt://localhost", "pubsub-1");

client.setCallback(callback);

client.connect();

client.subscribe(topics);

}

}

2020-11-16

總結(jié)

以上是生活随笔為你收集整理的java paho_Java Eclipse Paho实现-自动重新连接的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。