|
@ -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() { |
|
|
public boolean isConnected() { |
|
|