|
|
@ -55,7 +55,8 @@ public class MqttManager { |
|
|
|
private static final String PRODUCT_KEY = "qr3rximCZnT6ZU0NsAAiTC7O"; // 动态注册用的ProductKey |
|
|
|
|
|
|
|
// MQTT连接配置 |
|
|
|
private static final String BROKER_URL = "ssl://" + PRODUCT_ID + ".iotcloud.tencentdevices.com:8883"; // 腾讯云IoT Hub SSL地址 |
|
|
|
// private static final String BROKER_URL = "ssl://" + PRODUCT_ID + ".iotcloud.tencentdevices.com:8883"; // 腾讯云IoT Hub SSL地址 |
|
|
|
private static final String BROKER_URL = null ; |
|
|
|
private static final int KEEP_ALIVE_INTERVAL = 240; // 增加心跳间隔 |
|
|
|
private static final int CONNECTION_TIMEOUT = 30; // 增加连接超时时间 |
|
|
|
private static final int QOS = 1; |
|
|
@ -578,7 +579,13 @@ public class MqttManager { |
|
|
|
if (status == Status.OK) { |
|
|
|
LogManager.logInfo(TAG, "主题订阅成功: " + subscribeTopic); |
|
|
|
} else { |
|
|
|
LogManager.logError(TAG, "主题订阅失败: " + errMsg); |
|
|
|
String errorMsg = errMsg != null ? errMsg : "未知错误"; |
|
|
|
LogManager.logError(TAG, "主题订阅失败: " + errorMsg); |
|
|
|
|
|
|
|
// 检查是否是由于代理程序不可用导致的错误 |
|
|
|
if (errorMsg.contains("代理程序不可用")) { |
|
|
|
LogManager.logError(TAG, "MQTT代理程序不可用,请检查网络连接和腾讯云IoT设备配置"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|