248 lines
14 KiB
C#
248 lines
14 KiB
C#
//////////////////////////////////////////////////////////////////////////
|
||
//
|
||
// 文件：Assets/Code/Scripts/Gameplay/Net/Client/NetManager.cs
|
||
// 作者：Xoen Xie
|
||
// 时间：2023/07/18
|
||
// 描述：网络管理
|
||
// 说明：
|
||
//
|
||
//////////////////////////////////////////////////////////////////////////
|
||
|
||
using System;
|
||
using Framework;
|
||
using PhxhSDK;
|
||
using UnityEngine;
|
||
|
||
namespace Gameplay.Net
|
||
{
|
||
public sealed class NetManager : Singlenton<NetManager>, IUpdatable, IInitable
|
||
{
|
||
public NetClient mClient { get; private set; }
|
||
|
||
private uint m_nClientID;
|
||
|
||
private IMessage []m_MessagePool;
|
||
|
||
public RC4Cipher Rc4Cipher { get; private set; }
|
||
|
||
public void Init()
|
||
{
|
||
DebugUtil.Log("NetManager Init start");
|
||
InitPools();
|
||
|
||
m_nClientID = 1;
|
||
}
|
||
|
||
public void Release()
|
||
{
|
||
DebugUtil.Log("NetManager Release start");
|
||
CloseClient();
|
||
}
|
||
|
||
public void CloseClient()
|
||
{
|
||
if (mClient != null)
|
||
{
|
||
mClient.Release();
|
||
mClient = null;
|
||
}
|
||
}
|
||
|
||
public NetClient CreateNetClient(string sIP, int nPort)
|
||
{
|
||
if (mClient != null)
|
||
{
|
||
DebugUtil.Log("CreateNetClient mClient.Release");
|
||
mClient.Release();
|
||
}
|
||
|
||
mClient = new NetClient();
|
||
mClient.mID = m_nClientID++;
|
||
if (!mClient.Create(sIP, nPort))
|
||
{
|
||
mClient.Release();
|
||
mClient = null;
|
||
}
|
||
|
||
mClient.Connect();
|
||
DebugUtil.Log("IP: " + sIP + " Port: " + nPort);
|
||
return mClient;
|
||
}
|
||
|
||
public void SendMessage(IMessage message)
|
||
{
|
||
if (mClient == null)
|
||
{
|
||
DebugUtil.LogWarning("NetManager.SendMessage mClient == null, message={0}", message.ID);
|
||
return;
|
||
}
|
||
|
||
|
||
mClient.SendMessage(message);
|
||
}
|
||
|
||
public void Update(float deltaTime)
|
||
{
|
||
if (mClient != null)
|
||
mClient.Update();
|
||
}
|
||
|
||
private void InitPools()
|
||
{
|
||
m_MessagePool = new IMessage[(int)NLDMID.MSGID.Max];
|
||
// MESSAGE_START
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGtHandshake] = new MSG_Clt_Gt_Handshake();
|
||
m_MessagePool[(int)NLDMID.MSGID.GtCltHandshake] = new MSG_Gt_Clt_Handshake();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGtHeartbeat] = new MSG_Clt_Gt_Heartbeat();
|
||
m_MessagePool[(int)NLDMID.MSGID.GtCltHeartbeat] = new MSG_Gt_Clt_Heartbeat();
|
||
m_MessagePool[(int)NLDMID.MSGID.GtCltDisconnect] = new MSG_Gt_Clt_Disconnect();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLLogin] = new MSG_Clt_L_Login();
|
||
m_MessagePool[(int)NLDMID.MSGID.LCltLoginResult] = new MSG_L_Clt_LoginResult();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltLoginResult] = new MSG_G_Clt_LoginResult();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltOpResult] = new MSG_G_Clt_OpResult();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorBase] = new MSG_G_Clt_ActorBase();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorItem] = new MSG_G_Clt_ActorItem();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorCharacter] = new MSG_G_Clt_ActorCharacter();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGCharacterUpgrade] = new MSG_Clt_G_CharacterUpgrade();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorLogic] = new MSG_G_Clt_ActorLogic();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorTask] = new MSG_G_Clt_ActorTask();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGSetNickname] = new MSG_Clt_G_SetNickname();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorLevel] = new MSG_G_Clt_ActorLevel();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGEnterLevel] = new MSG_Clt_G_EnterLevel();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGExitLevel] = new MSG_Clt_G_ExitLevel();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorRaffle] = new MSG_G_Clt_ActorRaffle();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGRaffle] = new MSG_Clt_G_Raffle();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltItemList] = new MSG_G_Clt_ItemList();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGGroupReward] = new MSG_Clt_G_GroupReward();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGVehicleUpgrade] = new MSG_Clt_G_VehicleUpgrade();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorTeam] = new MSG_G_Clt_ActorTeam();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGCreateTeam] = new MSG_Clt_G_CreateTeam();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGUseItem] = new MSG_Clt_G_UseItem();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGTestInit] = new MSG_Clt_G_TestInit();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGGiftCode] = new MSG_Clt_G_GiftCode();
|
||
m_MessagePool[(int)NLDMID.MSGID.MlCltMailInfo] = new MSG_Ml_Clt_MailInfo();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltMlMailRequest] = new MSG_Clt_Ml_MailRequest();
|
||
m_MessagePool[(int)NLDMID.MSGID.MlCltMailData] = new MSG_Ml_Clt_MailData();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltMlOpenMail] = new MSG_Clt_Ml_OpenMail();
|
||
m_MessagePool[(int)NLDMID.MSGID.MlCltNewGlobalMail] = new MSG_Ml_Clt_NewGlobalMail();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltLoginKey] = new MSG_G_Clt_LoginKey();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGRelogin] = new MSG_Clt_G_Relogin();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltMlClaimMailItems] = new MSG_Clt_Ml_ClaimMailItems();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltMlDeleteMail] = new MSG_Clt_Ml_DeleteMail();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGTaskClaim] = new MSG_Clt_G_TaskClaim();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGGetShopContent] = new MSG_Clt_G_GetShopContent();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltShopDatas] = new MSG_G_Clt_ShopDatas();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGShopPurchase] = new MSG_Clt_G_ShopPurchase();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorPlayerSkill] = new MSG_G_Clt_ActorPlayerSkill();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGPlayerSkillUpgrade] = new MSG_Clt_G_PlayerSkillUpgrade();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGSetDefenceTeamForPvp] = new MSG_Clt_G_SetDefenceTeamForPvp();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltMgPvpInformation] = new MSG_Clt_Mg_PvpInformation();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltPvpInformation] = new MSG_G_Clt_PvpInformation();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGPvpStart] = new MSG_Clt_G_PvpStart();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGPvpResult] = new MSG_Clt_G_PvpResult();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorPvp] = new MSG_G_Clt_ActorPvp();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltPvpDefenceData] = new MSG_G_Clt_PvpDefenceData();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltMgPvpOrderList] = new MSG_Clt_Mg_PvpOrderList();
|
||
m_MessagePool[(int)NLDMID.MSGID.MgCltPvpOrderListData] = new MSG_Mg_Clt_PvpOrderListData();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGPatioExchange] = new MSG_Clt_G_PatioExchange();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGInAppPurchase] = new MSG_Clt_G_InAppPurchase();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorPurchase] = new MSG_G_Clt_ActorPurchase();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGExchangeItem] = new MSG_Clt_G_ExchangeItem();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGNewGuideProgress] = new MSG_Clt_G_NewGuideProgress();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGSetHeadicon] = new MSG_Clt_G_SetHeadicon();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGBuyAlbum] = new MSG_Clt_G_BuyAlbum();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGAdultAuth] = new MSG_Clt_G_AdultAuth();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGLevelSweep] = new MSG_Clt_G_LevelSweep();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltHorseLight] = new MSG_G_Clt_HorseLight();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGSetActorBase] = new MSG_Clt_G_SetActorBase();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGStringCheck] = new MSG_Clt_G_StringCheck();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGInAppPurchaseTest] = new MSG_Clt_G_InAppPurchaseTest();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGVehicleDevelopment] = new MSG_Clt_G_VehicleDevelopment();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGVehicleBuyPaint] = new MSG_Clt_G_VehicleBuyPaint();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGVehicleSetPaint] = new MSG_Clt_G_VehicleSetPaint();
|
||
m_MessagePool[(int)NLDMID.MSGID.LCltNldToken] = new MSG_L_Clt_NldToken();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionList] = new MSG_Clt_Lg_LegionList();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLegionListData] = new MSG_Lg_Clt_LegionListData();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgCreateLegion] = new MSG_Clt_Lg_CreateLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgUpdateLegion] = new MSG_Clt_Lg_UpdateLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgJoinLegion] = new MSG_Clt_Lg_JoinLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgExamineJoinLegion] = new MSG_Clt_Lg_ExamineJoinLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgQuitLegion] = new MSG_Clt_Lg_QuitLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgUpdateMember] = new MSG_Clt_Lg_UpdateMember();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgDismissMember] = new MSG_Clt_Lg_DismissMember();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgGetMyLegionInfo] = new MSG_Clt_Lg_GetMyLegionInfo();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLegionBase] = new MSG_Lg_Clt_LegionBase();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLegionMember] = new MSG_Lg_Clt_LegionMember();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLegionLog] = new MSG_Lg_Clt_LegionLog();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLegionApply] = new MSG_Lg_Clt_LegionApply();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionPart] = new MSG_Clt_Lg_LegionPart();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGCheckCharacter] = new MSG_Clt_G_CheckCharacter();
|
||
m_MessagePool[(int)NLDMID.MSGID.GCltActorLegion] = new MSG_G_Clt_ActorLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionBattleSignUp] = new MSG_Clt_Lg_LegionBattleSignUp();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGBattlePassReward] = new MSG_Clt_G_BattlePassReward();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltBEnterLegionBattlefield] = new MSG_Clt_B_EnterLegionBattlefield();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltGBuyBattlePassLevel] = new MSG_Clt_G_BuyBattlePassLevel();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldInfo] = new MSG_B_Clt_LegionBattlefieldInfo();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefield] = new MSG_B_Clt_LegionBattlefield();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltJoinedLegion] = new MSG_Lg_Clt_JoinedLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLoseLegion] = new MSG_Lg_Clt_LoseLegion();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltBEnterLegionBattlefieldOk] = new MSG_Clt_B_EnterLegionBattlefieldOk();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltBLegionBattleCommand] = new MSG_Clt_B_LegionBattleCommand();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldBuilding] = new MSG_B_Clt_LegionBattlefieldBuilding();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldActor] = new MSG_B_Clt_LegionBattlefieldActor();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldActorUpdate] = new MSG_B_Clt_LegionBattlefieldActorUpdate();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldActorCommand] = new MSG_B_Clt_LegionBattlefieldActorCommand();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldAttack] = new MSG_B_Clt_LegionBattlefieldAttack();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldOccupy] = new MSG_B_Clt_LegionBattlefieldOccupy();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltBLegionBattleCaptainOrder] = new MSG_Clt_B_LegionBattleCaptainOrder();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattleCaptainOrder] = new MSG_B_Clt_LegionBattleCaptainOrder();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattlefieldBuildingUpdate] = new MSG_B_Clt_LegionBattlefieldBuildingUpdate();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltBLegionBattleLog] = new MSG_Clt_B_LegionBattleLog();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattleLog] = new MSG_B_Clt_LegionBattleLog();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionPostHiring] = new MSG_Clt_Lg_LegionPostHiring();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgMercenarySignUp] = new MSG_Clt_Lg_MercenarySignUp();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionMercenaryApply] = new MSG_Clt_Lg_LegionMercenaryApply();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionMercenaryApprove] = new MSG_Clt_Lg_LegionMercenaryApprove();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionMercenaryHire] = new MSG_Clt_Lg_LegionMercenaryHire();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionMercenaryHireDatas] = new MSG_Clt_Lg_LegionMercenaryHireDatas();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLegionMercenaryHireDatas] = new MSG_Lg_Clt_LegionMercenaryHireDatas();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltLgLegionMercenarySignUpDatas] = new MSG_Clt_Lg_LegionMercenarySignUpDatas();
|
||
m_MessagePool[(int)NLDMID.MSGID.LgCltLegionMercenarySignUpDatas] = new MSG_Lg_Clt_LegionMercenarySignUpDatas();
|
||
m_MessagePool[(int)NLDMID.MSGID.BCltLegionBattleStatus] = new MSG_B_Clt_LegionBattleStatus();
|
||
m_MessagePool[(int)NLDMID.MSGID.CltBExitLegionBattlefield] = new MSG_Clt_B_ExitLegionBattlefield();
|
||
// MESSAGE_END
|
||
}
|
||
|
||
public IMessage GetMessage(NLDMID.MSGID id)
|
||
{
|
||
return m_MessagePool[(int)id];
|
||
}
|
||
|
||
// 服务器当前时间戳：毫秒
|
||
public ulong ServerTimeMS { get { return m_ServerTimeStart + (PhxhSDK.Utils.GetTimeStampMilliseconds() - m_ClientTimeStart); } }
|
||
|
||
// 服务器当前时间戳：秒
|
||
public uint ServerTime { get { return (uint)(ServerTimeMS / 1000); } }
|
||
|
||
// 服务器发送心跳的时间
|
||
private ulong m_ServerTimeStart;
|
||
|
||
// 服务器发送心跳时，客户端的时间
|
||
private ulong m_ClientTimeStart;
|
||
|
||
// 消息从客户端 ——> 服务器 -->客户端的总时间的一半
|
||
public uint RTT { get; private set; }
|
||
|
||
public void SetTime(ulong clientTime, ulong serverTime)
|
||
{
|
||
m_ServerTimeStart = serverTime; // 服务器回复心跳的时间
|
||
|
||
ulong current = PhxhSDK.Utils.GetTimeStampMilliseconds();
|
||
ulong timePass = current - clientTime;
|
||
RTT = (uint)(timePass / 2);
|
||
|
||
m_ClientTimeStart = current - RTT;
|
||
}
|
||
}
|
||
}
|