12312

DataVAPI.Tools/IOT/IOTDevServer.cs

@@ -46,6 +46,10 @@ namespace DataVAPI.Tool.IOT
         /// 客户端
         /// </summary>
         public static MqttClient client { get; set; }
+        /// <summary>
+        /// 连接事件
+        /// </summary>
+        public static Action<string> ConnectMqtt { get; set; }
         #endregion
 
         #region 发布或订阅主题或URL地址
@@ -360,6 +364,7 @@ namespace DataVAPI.Tool.IOT
                                 client.Subscribe(new string[] { par }, new byte[] { 0 });
                             });
                             UNConnectMqtt?.Invoke("重新连接阿里云MQTT成功！");
+                            
                         }
                     }
                     catch (Exception ce)

DataVAPI/UpAndDown/ProcessServer.cs

@@ -60,17 +60,15 @@ namespace DataVAPI.UpAndDown
             ConsoleHelper.WriteInfoLine("尝试连接阿里云.");
             if (IOTDevServer.GetInstance().CreateLinks("grgpECHSL7q", "Transit", "562dcc779b918a54c2d6589ec30ee230"))
             {
+                
                 ConsoleHelper.WriteSuccessLine($"阿里云【Transit】连接成功");
             }
             else
             {
                 ConsoleHelper.WriteSuccessLine($"阿里云【Transit】连接失败");
-                return;
             }
-
-            IOTDevServer.UNConnectMqtt += new Action<string>((o) => { ConsoleHelper.WriteSuccessLine(o); });
-
             Subscribe(IOTDevServer.HeartbeatSubTopic);
+            IOTDevServer.UNConnectMqtt += new Action<string>((o) => { ConsoleHelper.WriteSuccessLine(o); });
 
             IOTDevServer.DevIOTAction += DevIOTActionHandler;