@@ -40,7 +40,10 @@ bool FromMQTT::initMQTT()
/* 连接MQTT */
setIPAndPort(m_mqttIP, m_mqttPort);
addSubcribe(m_topic_WebAPI, 0); // 订阅WebAPI主题
- connectToServer();
+ if(!m_client.isConnectedToHost())
+ {
+ connectToServer();
+ }
/* 设置自动重连 */
setAutoReconnect();