修改bug

@@ -102,4 +102,9 @@ public class MqttService {
         }
         }
         return SysConfig.mqttConfig.subTopic;
         return SysConfig.mqttConfig.subTopic;
     }
     }
+
+    public boolean isConnect()
+    {
+        return mqttclient != null && mqttclient.isConnected();
+    }
 }
 }

@@ -29,7 +29,13 @@ public class Task {
                 data.put("playurl", playurl);
                 data.put("playurl", playurl);
                 data.put("online", oline);
                 data.put("online", oline);
                 jsonObject.put("1_1",data);
                 jsonObject.put("1_1",data);
-                MqttService.getInstance().publish("ADD_POST", jsonObject.toJSONString());
+                MqttService mqttService = MqttService.getInstance();
+                if(mqttService.isConnect())
+                {
+                    mqttService.publish("ADD_POST", jsonObject.toJSONString());
+                }else{
+                    mqttService.sart();
+                }
             } catch (Exception e) {
             } catch (Exception e) {
                 logger.error("定时任务执行异常", e);
                 logger.error("定时任务执行异常", e);
             }
             }

@@ -101,7 +101,12 @@ public class WebRtcService {
             try (DatagramSocket socket = new DatagramSocket()) {
             try (DatagramSocket socket = new DatagramSocket()) {
                 socket.connect(InetAddress.getByName("8.8.8.8"), 10002);
                 socket.connect(InetAddress.getByName("8.8.8.8"), 10002);
                 InetAddress localAddress = socket.getLocalAddress();
                 InetAddress localAddress = socket.getLocalAddress();
-                return SysConfig.webrtc_host=localIp=localAddress.getHostAddress();
+                String ip = localAddress.getHostAddress();
+                if("0.0.0.0".equals(ip))
+                {
+                    return null;
+                }
+                return localIp=ip;
             }
             }
         } catch (Exception e) {
         } catch (Exception e) {
             e.printStackTrace();
             e.printStackTrace();