mirror of
https://github.com/project-redbud/FunGame-Core.git
synced 2025-04-22 20:19:34 +08:00
ce0c933b35
* 添加安全类型转换，适配 SQLite * 更新版权声明 * 上一层已经有 try-catch 时，底层需要抛出异常 不应该再在底层添加 try-catch，或者添加了一定要抛出新的异常。
347 lines
13 KiB
C#
347 lines
13 KiB
C#
using System.Net;
|
||
using System.Net.Sockets;
|
||
using Milimoe.FunGame.Core.Api.Utility;
|
||
using Milimoe.FunGame.Core.Library.Constant;
|
||
using Milimoe.FunGame.Core.Library.Exception;
|
||
|
||
namespace Milimoe.FunGame.Core.Service
|
||
{
|
||
internal class SocketManager
|
||
{
|
||
#region 属性
|
||
|
||
/// <summary>
|
||
/// 客户端专用Socket
|
||
/// </summary>
|
||
internal static Socket? Socket => _Socket;
|
||
|
||
/// <summary>
|
||
/// 服务器端专用Socket
|
||
/// </summary>
|
||
internal static Socket? ServerSocket => _ServerSocket;
|
||
|
||
private static Socket? _Socket = null;
|
||
private static Socket? _ServerSocket = null;
|
||
|
||
#endregion
|
||
|
||
#region 实现
|
||
|
||
/// <summary>
|
||
/// 创建服务器监听Socket
|
||
/// </summary>
|
||
/// <param name="port">监听端口号</param>
|
||
/// <param name="maxConnection">最大连接数量</param>
|
||
/// <returns>服务器端专用Socket</returns>
|
||
internal static Socket? StartListening(int port = 22222, int maxConnection = 0)
|
||
{
|
||
if (maxConnection <= 0) maxConnection = SocketSet.MaxConnection_2C2G;
|
||
try
|
||
{
|
||
_ServerSocket = new(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||
IPEndPoint ServerEndPoint = new(IPAddress.Any, port);
|
||
_ServerSocket.Bind(ServerEndPoint);
|
||
_ServerSocket.Listen(maxConnection);
|
||
_ServerSocket.NoDelay = true;
|
||
return _ServerSocket;
|
||
}
|
||
catch
|
||
{
|
||
ServerSocket?.Close();
|
||
}
|
||
return null;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 创建一个监听到客户端Socket
|
||
/// </summary>
|
||
/// <returns>客户端IP地址[0]和客户端Socket[1]</returns>
|
||
internal static object[] Accept()
|
||
{
|
||
if (ServerSocket is null) return [];
|
||
Socket Client;
|
||
string ClientIP;
|
||
try
|
||
{
|
||
Client = ServerSocket.Accept();
|
||
Client.NoDelay = true;
|
||
ClientIP = Client.RemoteEndPoint?.ToString() ?? "Unknown";
|
||
return [ClientIP, Client];
|
||
}
|
||
catch
|
||
{
|
||
ServerSocket?.Close();
|
||
}
|
||
return [];
|
||
}
|
||
|
||
/// <summary>
|
||
/// 创建客户端Socket
|
||
/// </summary>
|
||
/// <param name="address">服务器IP地址</param>
|
||
/// <param name="port">服务器监听端口</param>
|
||
/// <returns>客户端专用Socket</returns>
|
||
internal static Socket? Connect(string address, int port = 22222)
|
||
{
|
||
Socket? ClientSocket;
|
||
EndPoint ServerEndPoint;
|
||
try
|
||
{
|
||
string IP = NetworkUtility.GetIPAddress(address);
|
||
ServerEndPoint = new IPEndPoint(IPAddress.Parse(IP), port);
|
||
if (ServerEndPoint != null)
|
||
{
|
||
ClientSocket = new(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||
bool Connecting = true;
|
||
Task t = Task.Run(() =>
|
||
{
|
||
while (Connecting)
|
||
{
|
||
if (!ClientSocket.Connected && Connecting)
|
||
{
|
||
ClientSocket.Connect(ServerEndPoint);
|
||
if (ClientSocket.Connected)
|
||
{
|
||
ClientSocket.NoDelay = true;
|
||
_Socket = ClientSocket;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
});
|
||
if (t.Wait(10 * 1000) && (_Socket?.Connected ?? false))
|
||
{
|
||
return _Socket;
|
||
}
|
||
else
|
||
{
|
||
Connecting = false;
|
||
throw new ConnectFailedException();
|
||
}
|
||
}
|
||
}
|
||
catch
|
||
{
|
||
_Socket?.Close();
|
||
}
|
||
return null;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 用于服务器端向客户端Socket发送信息
|
||
/// </summary>
|
||
/// <param name="clientSocket">客户端Socket</param>
|
||
/// <param name="obj">Socket信息容器</param>
|
||
/// <returns>通信结果</returns>
|
||
internal static SocketResult Send(Socket clientSocket, Library.Common.Network.SocketObject obj)
|
||
{
|
||
if (clientSocket != null)
|
||
{
|
||
if (clientSocket.Send(General.DefaultEncoding.GetBytes(JsonManager.GetString(obj))) > 0)
|
||
{
|
||
return SocketResult.Success;
|
||
}
|
||
else return SocketResult.Fail;
|
||
}
|
||
return SocketResult.NotSent;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 用于服务器端向客户端Socket发送信息 [ 异步版 ]
|
||
/// </summary>
|
||
/// <param name="clientSocket">客户端Socket</param>
|
||
/// <param name="obj">Socket信息容器</param>
|
||
/// <returns>通信结果</returns>
|
||
internal static async Task<SocketResult> SendAsync(Socket clientSocket, Library.Common.Network.SocketObject obj)
|
||
{
|
||
if (clientSocket != null)
|
||
{
|
||
if (await clientSocket.SendAsync(General.DefaultEncoding.GetBytes(JsonManager.GetString(obj))) > 0)
|
||
{
|
||
return SocketResult.Success;
|
||
}
|
||
else return SocketResult.Fail;
|
||
}
|
||
return SocketResult.NotSent;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 用于客户端向服务器Socket发送信息
|
||
/// </summary>
|
||
/// <param name="obj">Socket信息容器</param>
|
||
/// <returns>通信结果</returns>
|
||
internal static SocketResult Send(Library.Common.Network.SocketObject obj)
|
||
{
|
||
if (Socket != null)
|
||
{
|
||
if (Socket.Send(General.DefaultEncoding.GetBytes(JsonManager.GetString(obj))) > 0)
|
||
{
|
||
return SocketResult.Success;
|
||
}
|
||
else return SocketResult.Fail;
|
||
}
|
||
return SocketResult.NotSent;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 用于客户端向服务器Socket发送信息 [ 异步版 ]
|
||
/// </summary>
|
||
/// <param name="obj">Socket信息容器</param>
|
||
/// <returns>通信结果</returns>
|
||
internal static async Task<SocketResult> SendAsync(Library.Common.Network.SocketObject obj)
|
||
{
|
||
if (Socket != null)
|
||
{
|
||
if (await Socket.SendAsync(General.DefaultEncoding.GetBytes(JsonManager.GetString(obj))) > 0)
|
||
{
|
||
return SocketResult.Success;
|
||
}
|
||
else return SocketResult.Fail;
|
||
}
|
||
return SocketResult.NotSent;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 接收数据流中的信息
|
||
/// <para/>如果是服务器接收信息需要传入客户端Socket <paramref name="clientSocket"/>
|
||
/// </summary>
|
||
/// <param name="clientSocket">如果是服务器接收信息需要传入客户端Socket</param>
|
||
/// <returns>SocketObjects</returns>
|
||
internal static Library.Common.Network.SocketObject[] Receive(Socket? clientSocket = null)
|
||
{
|
||
List<Library.Common.Network.SocketObject> result = [];
|
||
Socket? tempSocket = clientSocket is null ? Socket : clientSocket;
|
||
if (tempSocket != null)
|
||
{
|
||
// 从服务器接收消息
|
||
byte[] buffer = new byte[General.SocketByteSize];
|
||
int length = tempSocket.Receive(buffer, buffer.Length, SocketFlags.None);
|
||
string msg = "";
|
||
if (length > 0)
|
||
{
|
||
msg = General.DefaultEncoding.GetString(buffer, 0, length);
|
||
if (JsonManager.IsCompleteJson<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
foreach (Library.Common.Network.SocketObject obj in JsonManager.GetObjects<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
result.Add(obj);
|
||
// 客户端接收消息，广播ScoketObject到每个UIModel
|
||
if (clientSocket is null) OnSocketReceive(obj);
|
||
}
|
||
return [.. result];
|
||
}
|
||
else
|
||
{
|
||
Thread.Sleep(20);
|
||
while (true)
|
||
{
|
||
if (tempSocket.Available > 0)
|
||
{
|
||
length = tempSocket.Receive(buffer, buffer.Length, SocketFlags.None);
|
||
msg += General.DefaultEncoding.GetString(buffer, 0, length);
|
||
if (JsonManager.IsCompleteJson<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
break;
|
||
}
|
||
Thread.Sleep(20);
|
||
}
|
||
else break;
|
||
}
|
||
}
|
||
}
|
||
foreach (Library.Common.Network.SocketObject obj in JsonManager.GetObjects<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
result.Add(obj);
|
||
// 客户端接收消息，广播ScoketObject到每个UIModel
|
||
if (clientSocket is null) OnSocketReceive(obj);
|
||
}
|
||
}
|
||
return [.. result];
|
||
}
|
||
|
||
/// <summary>
|
||
/// 接收数据流中的信息 [ 异步版 ]
|
||
/// <para/>如果是服务器接收信息需要传入客户端Socket <paramref name="clientSocket"/>
|
||
/// </summary>
|
||
/// <param name="clientSocket">如果是服务器接收信息需要传入客户端Socket</param>
|
||
/// <returns>SocketObjects</returns>
|
||
internal static async Task<Library.Common.Network.SocketObject[]> ReceiveAsync(Socket? clientSocket = null)
|
||
{
|
||
List<Library.Common.Network.SocketObject> result = [];
|
||
Socket? tempSocket = clientSocket is null ? Socket : clientSocket;
|
||
if (tempSocket != null)
|
||
{
|
||
// 从服务器接收消息
|
||
byte[] buffer = new byte[General.SocketByteSize];
|
||
int length = await tempSocket.ReceiveAsync(new ArraySegment<byte>(buffer), SocketFlags.None);
|
||
string msg = "";
|
||
if (length > 0)
|
||
{
|
||
msg = General.DefaultEncoding.GetString(buffer, 0, length);
|
||
if (JsonManager.IsCompleteJson<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
foreach (Library.Common.Network.SocketObject obj in JsonManager.GetObjects<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
result.Add(obj);
|
||
// 客户端接收消息，广播ScoketObject到每个UIModel
|
||
if (clientSocket is null) OnSocketReceive(obj);
|
||
}
|
||
return [.. result];
|
||
}
|
||
else
|
||
{
|
||
Thread.Sleep(20);
|
||
while (true)
|
||
{
|
||
if (tempSocket.Available > 0)
|
||
{
|
||
length = tempSocket.Receive(buffer, buffer.Length, SocketFlags.None);
|
||
msg += General.DefaultEncoding.GetString(buffer, 0, length);
|
||
if (JsonManager.IsCompleteJson<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
break;
|
||
}
|
||
Thread.Sleep(20);
|
||
}
|
||
else break;
|
||
}
|
||
}
|
||
}
|
||
foreach (Library.Common.Network.SocketObject obj in JsonManager.GetObjects<Library.Common.Network.SocketObject>(msg))
|
||
{
|
||
result.Add(obj);
|
||
// 客户端接收消息，广播ScoketObject到每个UIModel
|
||
if (clientSocket is null) OnSocketReceive(obj);
|
||
}
|
||
}
|
||
return [.. result];
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 事件
|
||
|
||
/// <summary>
|
||
/// 监听事件的委托
|
||
/// </summary>
|
||
/// <param name="obj">SocketObject</param>
|
||
internal delegate void SocketReceiveHandler(Library.Common.Network.SocketObject obj);
|
||
|
||
/// <summary>
|
||
/// 监听事件
|
||
/// </summary>
|
||
internal static event SocketReceiveHandler? SocketReceive;
|
||
|
||
/// <summary>
|
||
/// 触发异步监听事件
|
||
/// </summary>
|
||
/// <param name="obj">SocketObject</param>
|
||
internal static void OnSocketReceive(Library.Common.Network.SocketObject obj)
|
||
{
|
||
SocketReceive?.Invoke(obj);
|
||
}
|
||
|
||
#endregion
|
||
}
|
||
}
|