123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462 |
- using System;
- using MapServer;
- using System.Net;
- using System.Net.Sockets;
- using pb = global::Google.Protobuf;
- using NetData;
- using Newtonsoft.Json.Linq;
- using Newtonsoft.Json;
- using System.Diagnostics;
- using System.Linq;
- using System.Text;
- internal class MapTcpProxy : MonoSingleton<MapTcpProxy>
- {
- const int Port = 2333;
- static string IP = "192.168.10.86";
- public MapPeer2 Peer { get; set; }
- private bool netFailed = false;
- protected override void OnAwake()
- {
- base.OnAwake();
- ReConnect();
- //if (GlobalConfig.netType != eNetType.LAN)
- //{
- // var uri = "ylsjtt.game7000.com";
- // IPHostEntry entry = Dns.GetHostEntry(uri);
- // if (entry != null && entry.AddressList != null && entry.AddressList.Length > 0)
- // {
- // IPAddress addr = entry.AddressList[0]; //使用时使用AddressList[0]即可
- // IP = addr.ToString();
- // }
- // //IP = "ylsjtt.game7000.com";
- //}
- //this.Peer = new MapPeer2(IP, GlobalConfig.MapServerPort);
- //// todu: 重新登录时怎么处理重新连接的问题? --gwang
- //this.Peer.OnConnectClosed += Peer_OnConnectClosed;
- //this.Peer.OnReconnect += ()=> { Login(); return true; } ;
- }
- private void OnDisable()
- {
- this.Peer.OnConnectClosed -= Peer_OnConnectClosed;
- }
- private void OnEnable()
- {
- this.Peer.OnConnectClosed += Peer_OnConnectClosed;
- }
- private void Peer_OnConnectClosed()
- {
- LogHelper.Log("连接关闭事件:");
- netFailed = true;
- }
- public event Func<bool> OnReconnect;
- public void ReConnect()
- {
- if (GlobalConfig.netType != eNetType.LAN)
- {
- var uri = "ylsjtt.game7000.com";
- IPHostEntry entry = Dns.GetHostEntry(uri);
- if (entry != null && entry.AddressList != null && entry.AddressList.Length > 0)
- {
- IPAddress addr = entry.AddressList[0]; //使用时使用AddressList[0]即可
- IP = addr.ToString();
- }
- //IP = "ylsjtt.game7000.com";
- }
- LogHelper.Log("创建连接");
- this.Peer = new MapPeer2(IP, GlobalConfig.MapServerPort);
- // todu: 重新登录时怎么处理重新连接的问题? --gwang
- this.Peer.OnConnectClosed += Peer_OnConnectClosed;
-
- }
- private void OnApplicationFocus(bool focus)
- {
- LogHelper.Log("OnApplicationFocus" + focus);
- LogHelper.Log(TraceBack());
- }
- private void OnApplicationPause(bool pause)
- {
- //this.Peer.
- LogHelper.Log("OnApplicationPause" + pause);
- LogHelper.Log(TraceBack());
- }
- static string TraceBack() // 打印调用到这里的栈信息
- {
- var sb = new StringBuilder();
- StackTrace st = new StackTrace();
- StackFrame[] sf = st.GetFrames();
- sf.ToList().ForEach(curSf => sb.AppendLine($"{curSf}"));
- return sb.ToString();
- }
- //
- public void Login()
- {
- try
- {
- netFailed = false;
- this.Peer?.Login();
- LogHelper.Log("身份认证!");
- }
- catch(Exception e) {
- LogHelper.Log(e.Message);
- }
- }
- public void LogOut()
- {
- this.Peer.LogOut();
- }
- public void Update()
- {
- Peer?.Update();
- //LogHelper.Log($"tts: {Peer.tts}ms");
- if (netFailed)
- {
- UI_CueDialog.Instance().Open("与服务器的连接断开, 尝试重新建立连接", "网络故障", E_DialogType.OneButton, () => {
- ReConnect();
- Login();
- });
- //UI_CueDialog.Instance().Open("与游戏服务器的连接断开, 请检查网络.", "网络故障", E_DialogType.OneButton, UnityEngine.Application.Quit);
- }
- }
- protected override void DoOnDestroy()
- {
- base.DoOnDestroy();
- this.Peer?.Close();
- }
- }
- /// <summary>
- /// 地图长连服务器3代
- /// </summary>
- internal class MapPeer2 : PeerBase
- {
- /// <summary>
- /// (玩家数据)模块名称
- /// </summary>
- public enum EModName
- {
- Unkowm = 0,
- MapData = 1,
- CmptMgr,
- NpcMgr,
- SpawnerMgr,
- SpawnerMgr_Spawner,
- SpawnerMgr_Spawner_Role,
- Player = 100,
- Player_hero,
- }
- protected readonly Random r = new Random(); // 随机数
- private string ip;
- private int port;
- public MapPeer2(string Ip, int Port) : base(Ip, Port)
- {
- ip = Ip;
- port = Port;
- //OnDisconnect += MapPeer2_OnDisconnect; // 添加重连处理机制
- }
- #region
- //virtual protected bool OnConnectReset()
- //{
- // if (UnityEngine.Application.isPlaying)
- // {
- // Log("断线重连");
- // Login();
- // return true;
- // }
- // else
- // {
- // Log("停止播放断线不重连");
- // return false;
- // }
- //}
-
- #endregion
- public Info_Map? MapData { get; private set; }
- public Info_Map_Player Player { get; private set; }
- /// <summary>
- /// 注册服务端消息处理逻辑
- /// </summary>
- protected override void InitDispatch()
- {
- base.InitDispatch();
- this.callbacks[eProtocalCommand.ScMapLoginRet] = On_LoginOk; // 登录成功
- this.callbacks[eProtocalCommand.ScMapLogOutRet] = On_GameOver; // 登出成功
- this.callbacks[eProtocalCommand.ScMapDataChange] = On_update; // 数据更新
- this.callbacks[eProtocalCommand.ScMapSwitchMapRet] = On_SwitchMapReturn; // 地图切换
- }
- #region 消息处理逻辑
- /// <summary>
- /// 处理服务端登录成功消息
- /// </summary>
- /// <param name="data"></param>
- void On_LoginOk(byte[] data)
- {
- var msg = SC_login_ret.Parser.ParseFrom(data);
- // todo: 这里目前就只有mapdata一个模块, 后面可以考虑拆分多个模块
- var jobj = JObject.Parse(msg.MapJsonData);
- this.MapData = jobj.ToObject<Info_Map>();// Newtonsoft.Json.JsonConvert.DeserializeObject<Info_Map>(msg.MapJsonData);
- this.Player = JObject.Parse(msg.PlayerJsonData).ToObject<Info_Map_Player>(); // 玩家数据
- this.MapData.PropertyChanged += (s, e) => ReportDataChange(this.MapData); // 当数据有变化的时候上报
- // todo: 这里是设置一个状态值, 还是说做个message通知给前端?
- LogHelper.Log("地图登录成功: " + msg.MapJsonData);
- //LogHelper.LogWarning("测试warning文本颜色");
- //LogHelper.LogError("测试Error文本颜色");
- }
- /// <summary>
- /// 处理服务端更新数据消息
- /// </summary>
- void On_update(byte[] data)
- {
- var msg = SC_DataChange.Parser.ParseFrom(data);
- // todo: 这里目前就只有mapdata一个模块, 后面可以考虑拆分多个模块
- foreach (var kv in msg.ChangedMods)
- {
- var mod = Enum.Parse<EModName>(kv.Key);
- switch (mod)
- {
- case EModName.MapData: // 地图数据模块
- // this.MapData = Newtonsoft.Json.JsonConvert.DeserializeObject<Info_Map>(kv.Value);
- var jobj = JObject.Parse(kv.Value);
- this.MapData = jobj.ToObject<Info_Map>();// Newtonsoft.Json.JsonConvert.DeserializeObject<Info_Map>(msg.MapJsonData);
- //this.MapData.CheckJsonRaw(jobj);
- break;
- default:
- LogHelper.Log("未知模块!");
- break;
- }
- }
- LogHelper.Log("地图数据有更新: " + msg.ChangedMods);
- }
- /// <summary>
- /// 处理服务端返回登出成功消息
- /// </summary>
- void On_GameOver(byte[] data)
- {
- var msg = SC_LogOut_ret.Parser.ParseFrom(data);
- LogHelper.Log("地图模块退出成功: " + msg.ToString());
- Close(); // 通知recv协程退出循环
- }
- void On_SwitchMapReturn(byte[] data)
- {
- var msg = SC_SwitchMap_ret.Parser.ParseFrom(data);
- LogHelper.Log("切换到新地图成功:" + msg.ToString());
- var jobj = JObject.Parse(msg.MapJsonData);
- this.MapData = jobj.ToObject<Info_Map>(); // Newtonsoft.Json.JsonConvert.DeserializeObject<Info_Map>(msg.MapJsonData);
- this.MapData.PropertyChanged += (s, e) => ReportDataChange(this.MapData); // 当数据有变化的时候上报
- this.Player = JsonConvert.DeserializeObject<Info_Map_Player>(msg.PlayerJsonData);
- if (OnSwitchedNextMap != null)
- {
- OnSwitchedNextMap.Invoke(MapData);
- OnSwitchedNextMap = null;
- }
- }
- /// <summary>
- /// 暂存回调函数.
- /// </summary>
- private Action<Info_Map> OnSwitchedNextMap;
- #endregion
- #region 客户端访问接口
- public void LogOut()
- {
- SendMsg(eProtocalCommand.CsMapLogOut, new CS_LogOut());
- LogHelper.Log("地图 登出");
- }
- public void Login()
- {
- var p = UserProxy.Instance.player;
- var msg = new CS_login() { Uid = p.uid, Zoneid = p.zoneid, CurMapId = p.newMap.curMapId };
- SendMsg(eProtocalCommand.CsMapLogin, msg);
- LogHelper.Log("地图 登录");
- }
- #region 上报数据接口(多个重载)
- /// <summary>
- /// 上报数据发生变化
- /// </summary>
- public void ReportDataChange(Info_Map mapInfo)
- {
- this.MapData = mapInfo;
- this.MapData.PropertyChanged += (s, e) => ReportDataChange(this.MapData); // 当数据有变化的时候上报
- if (sm_gate.GetMoById(mapInfo.mapId)?.mapType < 4)
- {
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.MapData.ToString(), mapInfo.Json() } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- }
- }
- /// <summary>
- /// 上报数据发生变化
- /// </summary>
- public void ReportDataChange(Info_Map_CmptMgr cpmMgr)
- {
- var p = UserProxy.Instance.player;
- if (sm_gate.GetMoById(p.newMap.curMapId)?.mapType < 4)
- {
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.CmptMgr.ToString(), cpmMgr.Json() } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- MapData.cmptMgr = cpmMgr;
- }
- }
- /// <summary>
- /// 上报数据发生变化
- /// </summary>
- public void ReportDataChange(Info_Map_NpcMgr npcMgr)
- {
- var p = UserProxy.Instance.player;
- if (sm_gate.GetMoById(p.newMap.curMapId)?.mapType < 4)
- {
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.NpcMgr.ToString(), npcMgr.Json() } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- MapData.npcMgr = npcMgr;
- }
- }
- /// <summary>
- /// 上报数据发生变化
- /// </summary>
- public void ReportDataChange(Info_Map_SpawnerMgr spwMgr)
- {
- var p = UserProxy.Instance.player;
- if (sm_gate.GetMoById(p.newMap.curMapId)?.mapType < 4)
- {
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.SpawnerMgr.ToString(), spwMgr.Json() } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- MapData.spnSys = spwMgr;
- }
- }
- /// <summary>
- /// 上报数据发生变化
- /// </summary>
- public void ReportDataChange(Info_Map_Spawner spwnr)
- {
- var p = UserProxy.Instance.player;
- if (sm_gate.GetMoById(p.newMap.curMapId)?.mapType < 4)
- {
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.SpawnerMgr_Spawner.ToString(), spwnr.Json() } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- MapData.spnSys._spawnerDict[spwnr.spawnerId] = spwnr;
- }
- }
- internal class Msg_SwawnerRoleInfo
- {
- public int SpawnerId;
- public int RoleId;
- public Info_Map_RoleData roleData;
- }
- /// <summary>
- /// 上报数据发生变化(roleInfo:hp,pos等)
- /// </summary>
- public void ReportDataChange(int spwnrId, int roleId)
- {
- var data = new Msg_SwawnerRoleInfo();
- data.SpawnerId = spwnrId;
- data.RoleId = roleId;
- if (MapData.spnSys._spawnerDict.ContainsKey(spwnrId) && MapData.spnSys._spawnerDict[spwnrId].roleDict.ContainsKey(roleId)) // 防御对象已被移除
- {
- data.roleData = MapData.spnSys._spawnerDict[spwnrId]?.roleDict[roleId] ?? null;
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.SpawnerMgr_Spawner_Role.ToString(), JsonConvert.SerializeObject(data) } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- MapData.spnSys._spawnerDict[spwnrId].roleDict[roleId] = data.roleData;
- }
- }
- /// <summary>
- /// 上报数据发生变化(玩家信息)
- /// </summary>
- /// <param name="player"></param>
- public void ReportDataChange(Info_Map_Player player)
- {
- var p = UserProxy.Instance.player;
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.Player.ToString(), player.Json() } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- this.Player = player;
- }
- /// <summary>
- ///
- /// </summary>
- /// <param name="hero"></param>
- public void ReportDataChange(Info_Map_Player_Hero hero)
- {
- var p = UserProxy.Instance.player;
- var msg = new CS_DataChange();
- var kv = new pb.Collections.MapField<string, string>() { { EModName.Player_hero.ToString(), hero.Json() } };// 地图模块数据
- msg.ChangedMods.Add(kv);
- LogHelper.Log($"上报地图信息{msg}");
- SendMsg(eProtocalCommand.CsMapDataChange, msg);
- if (hero.hp <= 0)
- {
- hero.hp = hero.hpMax;
- }
- Player.heroDict[hero.uid] = hero;
- }
- #endregion
- /// <summary>
- /// 切换到下一个地图
- /// </summary>
- /// <param name="targetMapId"></param>
- /// <param name="curPoint">唤灵师当前点位(再回这张地图时用)</param>
- /// <param name="callback"></param>
- public void SwitchNextMap(int targetMapId, int curPoint, Action<Info_Map> callback)
- {
- if (callback != null)
- {
- OnSwitchedNextMap = callback;
- }
- var msg = new CS_SwitchMap() { TargetMapId = targetMapId, CurBirthPoint = curPoint };
- LogHelper.Log($"切换到下一地图{targetMapId}");
- SendMsg(eProtocalCommand.CsMapSwitchMap, msg);
- }
- #endregion
- }
|