diff --git a/Class/AsyncTcpServer.cs b/Class/AsyncTcpServer.cs index 28e4587..087d865 100644 --- a/Class/AsyncTcpServer.cs +++ b/Class/AsyncTcpServer.cs @@ -35,15 +35,21 @@ namespace ForwardingServerUI.Class service.Closing = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在断开连接,只有当主动断开时才有效。 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); }); - } - Console.WriteLine("[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "] NOT ID " + client.Id + " IP " + client.IP); + 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"]); + } return EasyTask.CompletedTask; };//有客户端断开连接 service.Received = (client, e) =>{ @@ -117,7 +123,7 @@ namespace ForwardingServerUI.Class deserializedPerson.SERVERMachineName, DateTime.Now.ToString(), deserializedPerson.MachineVer); } }); - Console.WriteLine("[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " [LINK ID " + client.Id + " IP " + client.IP + "]\nDATA =" + DAT); + Console.WriteLine("[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " LINK ID " + client.Id + " IP " + client.IP + "]\nDATA =" + DAT); } } @@ -164,15 +170,10 @@ namespace ForwardingServerUI.Class DateTime dateTime = DateTime.Parse(dataRow["HeartbeatTime"].ToString()!); if (DateTime.Now > dateTime.AddSeconds(180)) { - //标记无回应连接 - await Application.Current.Dispatcher.Invoke(async () => - { - 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"] ); + //关闭无回应连接 foreach (var item in service.Clients) {