377 lines
12 KiB
C#
377 lines
12 KiB
C#
using AxibugEmuOnline.Server.Common;
|
|
using AxibugEmuOnline.Server.Event;
|
|
using AxibugEmuOnline.Server.NetWork;
|
|
using AxibugProtobuf;
|
|
using MySql.Data.MySqlClient;
|
|
using MySqlX.XDevAPI;
|
|
using System.Collections.Generic;
|
|
using System.Net.Sockets;
|
|
using System.Timers;
|
|
|
|
namespace AxibugEmuOnline.Server.Manager
|
|
{
|
|
public class ClientInfo
|
|
{
|
|
public long UID { get; set; }
|
|
public string NickName { get; set; } = string.Empty;
|
|
public string Account { get; set; } = string.Empty;
|
|
public Socket _socket { get; set; }
|
|
public bool IsOffline { get; set; } = false;
|
|
public DateTime RegisterDT { get; set; }
|
|
public DateTime LogOutDT { get; set; }
|
|
public DateTime LogInDT { get; set; }
|
|
public DateTime LastLogInDT { get; set; }
|
|
public UserRoomState RoomState { get; set; } = new UserRoomState();
|
|
public TimeSpan LastStartPingTime { get; set; }
|
|
public int LastPingSeed { get; set; }
|
|
public double AveNetDelay { get; set; }
|
|
public double MinNetDelay { get; set; }
|
|
public double MaxNetDelay { get; set; }
|
|
public List<double> NetDelays { get; set; } = new List<double>();
|
|
public const int NetAveDelayCount = 3;
|
|
}
|
|
|
|
public class UserRoomState
|
|
{
|
|
public int RoomID { get; private set; }
|
|
public int PlayerIdx { get; private set; }
|
|
public UserRoomState()
|
|
{
|
|
ClearRoomData();
|
|
}
|
|
public void SetRoomData(int roomID, int playerIdx)
|
|
{
|
|
RoomID = roomID;
|
|
PlayerIdx = playerIdx;
|
|
}
|
|
public void ClearRoomData()
|
|
{
|
|
RoomID = -1;
|
|
PlayerIdx = -1;
|
|
}
|
|
}
|
|
|
|
public class ClientManager
|
|
{
|
|
private List<ClientInfo> ClientList = new List<ClientInfo>();
|
|
private Dictionary<Socket, ClientInfo> _DictSocketClient = new Dictionary<Socket, ClientInfo>();
|
|
private Dictionary<long?, ClientInfo> _DictUIDClient = new Dictionary<long?, ClientInfo>();
|
|
private long TestUIDSeed = 0;
|
|
|
|
private System.Timers.Timer clientCheckTimer;
|
|
private AutoResetEvent pingTickARE;
|
|
private long _RemoveOfflineCacheMin;
|
|
private Thread threadPingTick;
|
|
/// <summary>
|
|
/// 初始化并指定检查时间
|
|
/// </summary>
|
|
/// <param name="ticktime">tick检查毫秒数</param>
|
|
/// <param name="RemoveOfflineCache">清理掉线分钟数</param>
|
|
public void Init(long ticktime, long RemoveOfflineCacheMin)
|
|
{
|
|
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdPing, OnCmdPing);
|
|
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdPong, OnCmdPong);
|
|
|
|
pingTickARE = AppSrv.g_Tick.AddNewARE(TickManager.TickType.Interval_2000MS);
|
|
|
|
//换算成毫秒
|
|
_RemoveOfflineCacheMin = RemoveOfflineCacheMin;
|
|
clientCheckTimer = new System.Timers.Timer();
|
|
clientCheckTimer.Interval = ticktime;
|
|
clientCheckTimer.AutoReset = true;
|
|
clientCheckTimer.Elapsed += new ElapsedEventHandler(ClientCheckClearOffline_Elapsed);
|
|
clientCheckTimer.Enabled = true;
|
|
|
|
pingTickARE = AppSrv.g_Tick.AddNewARE(TickManager.TickType.Interval_2000MS);
|
|
threadPingTick = new Thread(PingAllLoop);
|
|
threadPingTick.Start();
|
|
}
|
|
|
|
|
|
public long GetNextUID()
|
|
{
|
|
return ++TestUIDSeed;
|
|
}
|
|
|
|
private void ClientCheckClearOffline_Elapsed(object sender, ElapsedEventArgs e)
|
|
{
|
|
DateTime CheckDT = DateTime.Now.AddMinutes(-1 * _RemoveOfflineCacheMin);
|
|
ClientInfo[] OfflineClientlist = ClientList.Where(w => w.IsOffline == true && w.LogOutDT < CheckDT).ToArray();
|
|
|
|
for (int i = 0; i < OfflineClientlist.Length; i++)
|
|
{
|
|
Console.WriteLine($"清理离线过久玩家 UID->{OfflineClientlist[i].UID} Name->{OfflineClientlist[i].NickName}");
|
|
//掉线处理
|
|
RemoveClient(OfflineClientlist[i]);
|
|
}
|
|
GC.Collect();
|
|
}
|
|
|
|
|
|
//通用处理
|
|
#region clientlist 处理
|
|
|
|
public ClientInfo JoinNewClient(long _uid, Socket _socket)
|
|
{
|
|
//也许这个函数需加lock
|
|
ClientInfo cinfo = GetClientForSocket(_socket);
|
|
//如果连接还在
|
|
if (cinfo != null)
|
|
{
|
|
cinfo.IsOffline = false;
|
|
}
|
|
else
|
|
{
|
|
cinfo = new ClientInfo()
|
|
{
|
|
UID = _uid,
|
|
_socket = _socket,
|
|
IsOffline = false,
|
|
};
|
|
AddClient(cinfo);
|
|
}
|
|
return cinfo;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 增加用户
|
|
/// </summary>
|
|
/// <param name="client"></param>
|
|
void AddClient(ClientInfo clientInfo)
|
|
{
|
|
try
|
|
{
|
|
Console.WriteLine("追加连接玩家 UID=>" + clientInfo.UID + " | " + clientInfo.Account);
|
|
lock (ClientList)
|
|
{
|
|
_DictUIDClient.Add(clientInfo.UID, clientInfo);
|
|
_DictSocketClient.Add(clientInfo._socket, clientInfo);
|
|
ClientList.Add(clientInfo);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
ex.ToString();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 清理连接
|
|
/// </summary>
|
|
/// <param name="client"></param>
|
|
public void RemoveClient(ClientInfo client)
|
|
{
|
|
lock (ClientList)
|
|
{
|
|
if (_DictUIDClient.ContainsKey(client.UID))
|
|
_DictUIDClient.Remove(client.UID);
|
|
|
|
if (_DictSocketClient.ContainsKey(client._socket))
|
|
_DictSocketClient.Remove(client._socket);
|
|
|
|
ClientList.Remove(client);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 清理连接
|
|
/// </summary>
|
|
/// <param name="client"></param>
|
|
public bool GetClientByUID(long uid, out ClientInfo client, bool bNeedOnline = false)
|
|
{
|
|
lock (ClientList)
|
|
{
|
|
if (!_DictUIDClient.ContainsKey(uid))
|
|
{
|
|
client = null;
|
|
return false;
|
|
}
|
|
|
|
client = _DictUIDClient[uid];
|
|
|
|
|
|
if (bNeedOnline && client.IsOffline)
|
|
return false;
|
|
return true;
|
|
}
|
|
}
|
|
|
|
public ClientInfo GetClientForUID(long UID)
|
|
{
|
|
return _DictUIDClient.ContainsKey(UID) ? _DictUIDClient[UID] : null;
|
|
}
|
|
|
|
public ClientInfo GetClientForSocket(Socket sk)
|
|
{
|
|
return _DictSocketClient.ContainsKey(sk) ? _DictSocketClient[sk] : null;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取在线玩家
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public List<ClientInfo> GetOnlineClientList()
|
|
{
|
|
return ClientList.Where(w => w.IsOffline == false).ToList();
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 设置玩家离线
|
|
/// </summary>
|
|
/// <param name="sk"></param>
|
|
public void SetClientOfflineForSocket(Socket sk)
|
|
{
|
|
if (!_DictSocketClient.ContainsKey(sk))
|
|
return;
|
|
|
|
ClientInfo cinfo = _DictSocketClient[sk];
|
|
Console.WriteLine("标记玩家UID" + cinfo.UID + "为离线");
|
|
cinfo.IsOffline = true;
|
|
cinfo.LogOutDT = DateTime.Now;
|
|
AppSrv.g_Room.LeaveRoom(cinfo, cinfo.RoomState.RoomID);
|
|
EventSystem.Instance.PostEvent(EEvent.OnUserOffline, cinfo.UID);
|
|
}
|
|
|
|
public void RemoveClientForSocket(Socket sk)
|
|
{
|
|
if (!_DictSocketClient.ContainsKey(sk))
|
|
return;
|
|
|
|
RemoveClient(_DictSocketClient[sk]);
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region Ping
|
|
void PingAllLoop()
|
|
{
|
|
while (true)
|
|
{
|
|
pingTickARE.WaitOne();
|
|
//AppSrv.g_Log.Info("PingAll");
|
|
PingAll();
|
|
}
|
|
}
|
|
void PingAll()
|
|
{
|
|
List<ClientInfo> clientlist = GetOnlineClientList();
|
|
int randSeed = new Random().Next(0, int.MaxValue);
|
|
foreach (var _c in clientlist)
|
|
{
|
|
_c.LastPingSeed = randSeed;
|
|
_c.LastStartPingTime = AppSrv.g_Tick.sw.Elapsed;
|
|
|
|
Protobuf_Ping resp = new Protobuf_Ping()
|
|
{
|
|
Seed = randSeed,
|
|
};
|
|
AppSrv.g_ClientMgr.ClientSend(_c._socket, (int)CommandID.CmdPing, (int)ErrorCode.ErrorOk, ProtoBufHelper.Serizlize(resp));
|
|
}
|
|
}
|
|
public void OnCmdPing(Socket sk, byte[] reqData)
|
|
{
|
|
//AppSrv.g_Log.Debug($"OnCmdPing");
|
|
Protobuf_Ping msg = ProtoBufHelper.DeSerizlize<Protobuf_Ping>(reqData);
|
|
|
|
//创建成功下行
|
|
Protobuf_Pong resp = new Protobuf_Pong()
|
|
{
|
|
Seed = msg.Seed,
|
|
};
|
|
AppSrv.g_ClientMgr.ClientSend(sk, (int)CommandID.CmdPong, (int)ErrorCode.ErrorOk, ProtoBufHelper.Serizlize(resp));
|
|
}
|
|
public void OnCmdPong(Socket sk, byte[] reqData)
|
|
{
|
|
//AppSrv.g_Log.Debug($"OnCmdPong");
|
|
ClientInfo _c = AppSrv.g_ClientMgr.GetClientForSocket(sk);
|
|
Protobuf_Pong msg = ProtoBufHelper.DeSerizlize<Protobuf_Pong>(reqData);
|
|
|
|
if (_c.LastPingSeed == msg.Seed)
|
|
{
|
|
TimeSpan current = AppSrv.g_Tick.sw.Elapsed;
|
|
TimeSpan delta = current - _c.LastStartPingTime;
|
|
_c.NetDelays.Add(delta.TotalSeconds);
|
|
|
|
while (_c.NetDelays.Count > ClientInfo.NetAveDelayCount)
|
|
_c.NetDelays.RemoveAt(0);
|
|
|
|
double tempMin = double.MaxValue;
|
|
double tempMax = double.MinValue;
|
|
for (int i = 0; i < _c.NetDelays.Count; i++)
|
|
{
|
|
tempMin = Math.Min(_c.NetDelays[i], tempMin);
|
|
tempMax = Math.Max(_c.NetDelays[i], tempMax);
|
|
}
|
|
_c.MinNetDelay = tempMin;
|
|
_c.MaxNetDelay = tempMax;
|
|
_c.AveNetDelay = _c.NetDelays.Average(w => w);
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
|
|
public void ClientSendALL(int CMDID, int ERRCODE, byte[] data, long SkipUID = -1)
|
|
{
|
|
ClientSend(ClientList, CMDID, ERRCODE, data, SkipUID);
|
|
}
|
|
|
|
public void ClientSend(List<long> UIDs, int CMDID, int ERRCODE, byte[] data, long SkipUID = -1)
|
|
{
|
|
for (int i = 0; i < UIDs.Count(); i++)
|
|
{
|
|
if (!GetClientByUID(UIDs[i], out ClientInfo _c, true))
|
|
continue;
|
|
AppSrv.g_SocketMgr.SendToSocket(_c._socket, CMDID, ERRCODE, data);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 给一组用户发送数据
|
|
/// </summary>
|
|
/// <param name="_toclientlist"></param>
|
|
/// <param name="CMDID"></param>
|
|
/// <param name="ERRCODE"></param>
|
|
/// <param name="data"></param>
|
|
public void ClientSend(List<ClientInfo> _toclientlist, int CMDID, int ERRCODE, byte[] data, long SkipUID = -1)
|
|
{
|
|
for (int i = 0; i < _toclientlist.Count(); i++)
|
|
{
|
|
if (_toclientlist[i] == null || _toclientlist[i].IsOffline)
|
|
continue;
|
|
|
|
if (SkipUID > -1 && _toclientlist[i].UID == SkipUID)
|
|
continue;
|
|
|
|
AppSrv.g_SocketMgr.SendToSocket(_toclientlist[i]._socket, CMDID, ERRCODE, data);
|
|
}
|
|
}
|
|
|
|
public void ClientSend(Socket _socket, int CMDID, int ERRCODE, byte[] data)
|
|
{
|
|
//Console.WriteLine("发送数据 CMDID->"+ CMDID);
|
|
AppSrv.g_SocketMgr.SendToSocket(_socket, CMDID, ERRCODE, data);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 给一个连接发送数据
|
|
/// </summary>
|
|
/// <param name="_c"></param>
|
|
/// <param name="CMDID"></param>
|
|
/// <param name="ERRCODE"></param>
|
|
/// <param name="data"></param>
|
|
public void ClientSend(ClientInfo _c, int CMDID, int ERRCODE, byte[] data)
|
|
{
|
|
if (_c == null || _c.IsOffline)
|
|
return;
|
|
AppSrv.g_SocketMgr.SendToSocket(_c._socket, CMDID, ERRCODE, data);
|
|
}
|
|
|
|
public int GetOnlineClient()
|
|
{
|
|
return ClientList.Where(w => !w.IsOffline).Count();
|
|
}
|
|
}
|
|
}
|