update mqtt

main.c

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

mqtt.c

@@ -296,7 +296,7 @@ int mqtt_create(struct mosquitto *mosq) //创建mqtt客服端
     if (rc != MOSQ_ERR_SUCCESS) {                             
         fprintf(stderr, "Failed to connect to broker: %s\n", mosquitto_strerror(rc));
         mosquitto_destroy(mosq);
-        return EXIT_FAILURE;
+        //return EXIT_FAILURE;
     }
     //mosquitto_subscribe_opt_set(mosq, TOPIC, strlen(TOPIC), 1, MOSQ_OPT_NO_LOCAL);
 

opensh.c

@@ -2,15 +2,16 @@
 #include <stdlib.h>
 #include "opensh.h"
 #include <string.h>
+#include "mqtt.h"
 
 char gwebcam[100];
 
 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=controlcar0002");
+    sprintf(gwebcam,"sudo firefox --new-window https://jywy.yd-ss.com?dev=%s &",TOPIC3);
+    system(gwebcam);
     printf("%s\n",gwebcam);
     printf("close cam\n");