`
3. 實現回調接口：添加回調接口 `MqttCallback`:
“`java
public class MQTTManager implements MqttCallback {
//…MQTTManager的其他代碼
public void setCallback() {
mqttAndroidClient.setCallback(this);
}
@Override
public void connectionLost(Throwable cause) {
// 連接丟失，可以在這里處理相關邏輯
}
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
// 收到消息，APP可以在這里處理相關邏輯
}
@Override
public void deliveryComplete(IMqttDeliveryToken token) {
// 消息發送成功，可以在這里處理相關邏輯
}
}
“`
4. 連接、訂閱、發布：
“`java
public class MQTTManager {
// 實現連接
public void connect(final IMqttActionListener listener) {
try {
IMqttToken token = mqttAndroidClient.connect();
token.setActionCallback(listener);
} catch (MqttException e) {
e.printStackTrace();
}
}
// 訂閱主題
public void subscribe(String topic) {
try {
mqttAndroidClient.subscribe(topic, 0);
} catch (MqttException e) {
e.printStackTrace();
}
}
// 發布消息
public void publish(String topic, String message) {
try {
MqttMessage mqttMessage = new MqttMessage();
mqttMessage.setPayload(message.getBytes());
mqttAndroidClient.publish(topic, mqttMessage);
} catch (Exception e) {
e.printStackTrace();
}
}
}
“`
五、總結
MQTT協議為App開發提供了高效、穩定、實時的通信解決方案。通過在App中引入MQTT協議的實現庫，可以輕松實現物聯網設備間的即時通信。以上詳細講解了MQTT協議的基本知識和原理，以及如何在Android App中實現MQTT協議，能夠幫助開發者快速入門MQTT協議。
