mqtt update

main.c

@@ -81,20 +81,21 @@ void *serial_usart2(void *arg)
 void *Mqtt_onnect(void *arg)
 {
     Delay_Ms(5,0);
-  
+    mqtt_init();//mqtt初始化
+    mqtt_create(mosq);//创建mqtt客户端
+    mqtt_create(mosq);
     //mqtt_wirte();//mqtt心跳首次发送
     while(1)
     {    
-        mqtt_init();//mqtt初始化
-        mqtt_create(mosq);//创建mqtt客户端
-        mqtt_create(mosq);
+      
         if(mqtt_create(mosq)!=-1)
         {
             mqtt_cycle(mosq);   
         }
 
-        mqtt_clean(mosq);
+        
     }
+    mqtt_clean(mosq);
     return NULL;
 }