using System; using System.Collections.Generic; using System.Linq; using System.Net.Sockets; using System.Net; using System.Text; using System.Threading.Tasks; using FunGame.Desktop.Models.Component; using System.ComponentModel.DataAnnotations; using System.Net.NetworkInformation; using FunGame.Core.Api.Model.Entity; using FunGame.Core.Api.Model.Enum; using FunGame.Desktop.Models.Config; using FunGame.Desktop.UI; namespace FunGame.Desktop.Utils { public class WebHelper { private Socket? client; private EndPoint? server; Main Main; Action? WebHelper_Action = null; Task? WaitHeartBeat = null; public WebHelper(Main main) { Main = main; } /// /// 选择WebHelp分支方法 /// /// 分支方法ID public void WebHelpMethod(int i) { switch (i) { case (int)CommonEnums.WebHelperMethod.CreateSocket: CreateSocket(); break; case (int)CommonEnums.WebHelperMethod.CloseSocket: Close(); break; case (int)CommonEnums.WebHelperMethod.StartWebHelper: StartWebHelper(); break; } } /// /// 创建客户端专属Socket /// private void CreateSocket() { try { client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); server = new IPEndPoint(IPAddress.Parse(Config.SERVER_IPADRESS), Config.SERVER_PORT); while (true) { if (!IsConnected()) { client.Connect(server); if (IsConnected()) { Main.GetMessage(this, Config.WebHelper_SetYellow); break; } } } WebHelper_Action = (main, socket) => { object? obj = main.GetMessage(this, Config.WebHelper_GetUser); object[] objs; if (obj != null) objs = new object[] { main, socket, obj }; else objs = new object[] { main, socket }; if (Send((int)CommonEnums.SocketType.GetNotice, objs)) // 接触服务器并获取公告 main.GetMessage(this, " >> 连接服务器成功，请登录账号以体验FunGame。", true); }; Task t = Task.Factory.StartNew(() => { if (Main.InvokeRequired) { Main.Invoke(WebHelper_Action, Main, client); } else { WebHelper_Action(Main, client); } }); } catch (Exception e) { Main.GetMessage(this, Config.WebHelper_Disconnected); Main.GetMessage(this, e.StackTrace); Close(); } } /// /// 判断是否连接成功 /// /// 连接状态 public bool IsConnected() { if (client != null) return client.Connected; return false; } private bool Read(object[]? objs = null) { Main main = Main; Socket? socket = null; try { if (objs != null) { if (objs.Length > 0) main = (Main)objs[0]; if (objs.Length > 1) socket = (Socket)objs[1]; } else { main = Main; socket = client; } if (socket != null) { // 从服务器接收消息 byte[] buffer = new byte[2048]; int length = socket.Receive(buffer); if (length > 0) { string msg = Config.DEFAULT_ENCODING.GetString(buffer, 0, length); int type = GetType(msg); string typestring = CommonEnums.GetSocketTypeName(type); string read = GetMessage(msg); switch (type) { case (int)CommonEnums.SocketType.GetNotice: main.GetMessage(this, read, true); return true; case (int)CommonEnums.SocketType.Login: break; case (int)CommonEnums.SocketType.CheckLogin: StartWebHelper(); // 开始创建TCP流 return true; case (int)CommonEnums.SocketType.Logout: break; case (int)CommonEnums.SocketType.HeartBeat: if (WaitHeartBeat != null && !WaitHeartBeat.IsCompleted) WaitHeartBeat.Wait(1); Config.WebHelper_HeartBeatFaileds = 0; main.GetMessage(this, Config.WebHelper_SetGreenAndPing); return true; } main.GetMessage(this, read); return true; } else throw new Exception("ERROR：未收到任何来自服务器的信息，与服务器连接可能丢失。"); } else { main.GetMessage(this, Config.WebHelper_Disconnected); throw new Exception("ERROR：服务器连接失败。"); } } catch (Exception e) { main.GetMessage(this, Config.WebHelper_Disconnected); main.GetMessage(this, e.Message != null ? e.Message + "\n" + e.StackTrace : "" + e.StackTrace); Close(); } return false; } private bool Send(int i, object[]? objs = null) { Main main = Main; Socket? socket = null; try { if (objs != null) { if (objs.Length > 0) main = (Main)objs[0]; if (objs.Length > 1) socket = (Socket)objs[1]; } else { main = Main; socket = client; } if (socket != null) { string msg = ""; byte[] buffer; int length; // 发送消息给服务器端 switch (i) { case (int)CommonEnums.SocketType.GetNotice: msg = "获取公告"; buffer = new byte[2048]; buffer = Config.DEFAULT_ENCODING.GetBytes(MakeMessage((int)CommonEnums.SocketType.GetNotice, msg)); length = socket.Send(buffer); if (length > 0) { return Read(objs); } break; case (int)CommonEnums.SocketType.Login: break; case (int)CommonEnums.SocketType.CheckLogin: User user; if (objs != null && objs.Length > 2) { user = (User)objs[2]; msg = user.Userame; } else { Usercfg.FunGame_isAutoRetry = false; throw new Exception("ERROR: 请登录账号。"); } buffer = new byte[2048]; buffer = Config.DEFAULT_ENCODING.GetBytes(MakeMessage((int)CommonEnums.SocketType.CheckLogin, msg)); length = socket.Send(buffer); if (length > 0) { return Read(objs); } else throw new Exception("ERROR：消息未送达服务器，与服务器连接可能丢失。"); case (int)CommonEnums.SocketType.Logout: break; case (int)CommonEnums.SocketType.HeartBeat: buffer = new byte[2048]; buffer = Config.DEFAULT_ENCODING.GetBytes(Convert.ToString(MakeMessage((int)CommonEnums.SocketType.HeartBeat, "心跳检测"))); if (socket.Send(buffer) > 0) { WaitHeartBeat = Task.Run(() => { Thread.Sleep(4000); AddHeartBeatFaileds(main); }); return true; } AddHeartBeatFaileds(main); break; } } else { main.GetMessage(this, Config.WebHelper_Disconnected); throw new Exception("ERROR：服务器连接失败。"); } } catch (Exception e) { CatchException(main, e, false); } return false; } private void CatchException(Main main, Exception e, bool isDisconnected) { if (isDisconnected) main.GetMessage(this, Config.WebHelper_Disconnected); else main.GetMessage(this, Config.WebHelper_SetRed); main.GetMessage(this, e.Message != null ? e.Message + "\n" + e.StackTrace : "" + e.StackTrace); Close(); } private void AddHeartBeatFaileds(Main main) { // 超过三次没回应心跳，服务器连接失败。 try { Config.WebHelper_HeartBeatFaileds++; if (Config.WebHelper_HeartBeatFaileds >= 3) throw new Exception("ERROR：服务器连接失败。"); } catch (Exception e) { CatchException(main, e, true); } } private int GetType(string msg) { int index = msg.IndexOf(';') - 1; if (index > 0) return Convert.ToInt32(msg[..index]); else return Convert.ToInt32(msg[..1]); } private string GetMessage(string msg) { int index = msg.IndexOf(';') + 1; return msg[index..]; } private string MakeMessage(int type, string msg) { return type + ";" + msg; } private void Close() { if (client != null) { client.Close(); client = null; } if (server != null) { server = null; } } private void StartWebHelper() { Task HeartBeatStream = Task.Factory.StartNew(() => { CreateSendHeartBeatStream(); }); Task StreamReader = Task.Factory.StartNew(() => { CreateStreamReader(); }); } private void CreateSendHeartBeatStream() { Thread.Sleep(1000); Main.GetMessage(this, "Creating: SendHeartBeatStream...OK"); while (IsConnected()) { Send((int)CommonEnums.SocketType.HeartBeat); // 发送心跳包 Thread.Sleep(20000); } } private void CreateStreamReader() { Thread.Sleep(1000); Main.GetMessage(this, "Creating: StreamReader...OK"); while (IsConnected()) { Read(); } } } }