diff --git a/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java b/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java index bab3af9..248944e 100644 --- a/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java +++ b/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java @@ -248,6 +248,18 @@ public class MqttManager { } /** + * 异步连接MQTT - 对外公开接口 + */ + public void connectAsync() { + LogManager.logInfo(TAG, "手动触发MQTT连接"); + if (!isConnected && !isConnecting) { + simulateConnection(); + } else { + LogManager.logInfo(TAG, "MQTT已连接或正在连接中"); + } + } + + /** * 获取连接状态 */ public boolean isConnected() {