调整心跳超时检查断线逻辑

Class/AsyncHttpServer.cs

@@ -145,13 +145,5 @@ namespace ForwardingServerUI.Class
              
 
 
-
-
-
-       
-
-
-
-
     }
 }

Class/AsyncTcpServer.cs

@@ -33,23 +33,22 @@ namespace ForwardingServerUI.Class
             service.Connecting = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在连接
             service.Connected = (client, e) => { return EasyTask.CompletedTask;};//有客户端成功连接
             service.Closing = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在断开连接，只有当主动断开时才有效。
-            service.Closed =  (client, e) => {
+            service.Closed =  (client, e) =>
+            {
                 //离线记录
-
                 Console.WriteLine("[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "] NOT ID " +
                     client.Id + " IP " + client.IP);
 
-                DataRow[] dat = MainWindowViewModel._machineTable.Select("ID='"+client.Id+"'");
-                foreach (DataRow row in dat)
-                {
-                    Application.Current.Dispatcher.Invoke(() => {
-                        MainWindowViewModel._machineTable.Rows.Remove(row);
-                    });
+                DataRow row = MainWindowViewModel._machineTable.Select("ID='" + client.Id + "'").First();
 
-                    Console.WriteLine("[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "] NOT LINK ID = " +
-                          row["ID"] + " IP = " + row["IP"] + " Enterprise = " + row["Enterprise"] +
-                          " MachineName = " + row["MachineName"]);
-                }               
+                Console.WriteLine("[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "] BREAK LINK ID = " +
+                      row["ID"] + " IP = " + row["IP"] + " Enterprise = " + row["Enterprise"] +
+                      " MachineName = " + row["MachineName"]);
+
+                Application.Current.Dispatcher.Invoke(() =>
+                {
+                    MainWindowViewModel._machineTable.Rows.Remove(row);
+                });
                 return EasyTask.CompletedTask;
             };//有客户端断开连接
             service.Received = (client, e) =>{                
@@ -156,7 +155,7 @@ namespace ForwardingServerUI.Class
             Console.WriteLine("TcpServer:Run");
 
             //启动检查循环定时器
-            _timer = new Timer(TimerCallback, null, TimeSpan.FromSeconds(90), TimeSpan.FromSeconds(30));
+            _timer = new Timer(TimerCallback, null, TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(30));
         }
 
         private static async void TimerCallback(object? state)
@@ -168,12 +167,24 @@ namespace ForwardingServerUI.Class
                 {
                     DataRow dataRow = MainWindowViewModel._machineTable.Rows[i-1];
                     DateTime dateTime = DateTime.Parse(dataRow["HeartbeatTime"].ToString()!);
-                    if (DateTime.Now > dateTime.AddSeconds(180))
+
+                    if (DateTime.Now > dateTime.AddSeconds(30) && (int)dataRow["Start"] == 30)
                     {
+                        Application.Current.Dispatcher.Invoke(() =>
+                        {
+                            dataRow.BeginEdit();
+                            dataRow["Start"] = 999;
+                            dataRow.EndEdit();
+                            dataRow.AcceptChanges();
+                        });
+
                         Console.WriteLine("[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "] NOT LINK ID = " +
                             dataRow["ID"] + " IP = " + dataRow["IP"] + " Enterprise = " + dataRow["Enterprise"] +
-                            " MachineName = " + dataRow["MachineName"] );
+                            " MachineName = " + dataRow["MachineName"]);
+                    }
 
+                    if (DateTime.Now > dateTime.AddSeconds(180))
+                    {
                         //关闭无回应连接
                         foreach (var item in service.Clients)
                         {
@@ -186,6 +197,7 @@ namespace ForwardingServerUI.Class
                             }
                         }
                     }
+                 
                 }
             }
             catch (Exception ex)