update mqtt

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;
 }
 

mqtt.c

@@ -16,6 +16,18 @@ unsigned char gpinTemp=0;
 unsigned char gvalTemp=0;
 unsigned char gvalt[4];
 
+int mqtt_init()
+{
+ // 初始化 mosquitto 库
+    mosquitto_lib_init();  
+    mosq = mosquitto_new(NULL, true, NULL);
+    if (!mosq) {
+        fprintf(stderr, "Failed to create Mosquitto client\n");
+        return -1;
+    }
+    mosquitto_int_option(mosq, MOSQ_OPT_PROTOCOL_VERSION, MQTT_PROTOCOL_V5);
+    
+}
 
 void on_connect(struct mosquitto *mosq, void *obj, int rc) //回调函数
 {
@@ -33,19 +45,6 @@ void on_connect(struct mosquitto *mosq, void *obj, int rc) //回调函数
 }
 
 
-int mqtt_init()
-{
- // 初始化 mosquitto 库
-    mosquitto_lib_init();  
-    mosq = mosquitto_new(NULL, true, NULL);
-    if (!mosq) {
-        fprintf(stderr, "Failed to create Mosquitto client\n");
-        return -1;
-    }
-    mosquitto_int_option(mosq, MOSQ_OPT_PROTOCOL_VERSION, MQTT_PROTOCOL_V5);
-    
-}
-
 //int init_mqtt(struct mosquitto *mosq)
 /*
 void mqtt_MAC_wirte()

opensh.c

@@ -10,7 +10,7 @@ int opencamsh()
 
     setenv("DISPLAY", ":0", 1);//设置环境变量https://jywy.yd-ss.com?dev=controcar0004 --new-window sudo 
     //sprintf(gwebcam,"sudo firefox --new-window https://jywy.yd-ss.com?dev=%s &",gsite);
-    system("sudo firefox https://jywy.yd-ss.com?dev=controlcar0001");
+    system("sudo firefox https://jywy.yd-ss.com?dev=controlcar0002");
     printf("%s\n",gwebcam);
     printf("close cam\n");