update mqtt

main.c

@@ -84,14 +84,8 @@ void *Mqtt_onnect(void *arg)
     mqtt_init();//mqtt初始化
     mqtt_create(mosq);//创建mqtt客户端
     //mqtt_wirte();//mqtt心跳首次发送
-      
-        if(mqtt_create(mosq)!=-1)
-        {
+    mqtt_create(mosq) ;     
     mqtt_cycle(mosq);   
-        }
-
-        
-    
     mqtt_clean(mosq);
     return NULL;
 }