97 lines
3.0 KiB
C#
97 lines
3.0 KiB
C#
using AxibugProtobuf;
|
|
using ClientCore.Enum;
|
|
using ClientCore.Event;
|
|
using HaoYueNet.ClientNetwork;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace ClientCore.Network
|
|
{
|
|
/// <summary>
|
|
/// 继承网络库，以支持网络功能
|
|
/// </summary>
|
|
public class NetworkP2PHelper : NetworkHelperP2PCore
|
|
{
|
|
ServerType mServerType;
|
|
public long mUID { get; private set; } = -1;
|
|
public E_P2P_STATE e_P2P_STATE = E_P2P_STATE.None;
|
|
public NetworkP2PHelper(ServerType serverType,long UID = -1)
|
|
{
|
|
//指定接收服务器数据事件
|
|
OnDataCallBack += GetDataCallBack;
|
|
//断开连接
|
|
OnClose += OnConnectClose;
|
|
//网络库调试信息输出事件，用于打印连接断开，收发事件
|
|
OnLogOut += NetworkDeBugLog;
|
|
OnConnected += NetworkConnected;
|
|
mServerType = serverType;
|
|
e_P2P_STATE = E_P2P_STATE.None;
|
|
mUID = UID;
|
|
}
|
|
|
|
|
|
public void NetworkConnected(bool IsConnect)
|
|
{
|
|
if (IsConnect)
|
|
{
|
|
EventSystem.Instance.PostEvent(EEvent.OnSocketConnect, mServerType, true);
|
|
NetworkDeBugLog("服务器连接成功");
|
|
}
|
|
else
|
|
{
|
|
EventSystem.Instance.PostEvent(EEvent.OnSocketConnect, mServerType, false);
|
|
NetworkDeBugLog("服务器连接失败");
|
|
//to do 重连逻辑
|
|
}
|
|
}
|
|
|
|
public void NetworkDeBugLog(string str)
|
|
{
|
|
//用于Unity内的输出
|
|
//Debug.Log("NetCoreDebug >> "+str);
|
|
|
|
App.log.Info("NetCoreDebug >> " + str);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 接受包回调
|
|
/// </summary>
|
|
/// <param name="CMDID">协议ID</param>
|
|
/// <param name="ERRCODE">错误编号</param>
|
|
/// <param name="data">业务数据</param>
|
|
public void GetDataCallBack(int CMDID, int ERRCODE, byte[] data)
|
|
{
|
|
//NetworkDeBugLog("收到消息 CMDID =>" + CMDID + " ERRCODE =>" + ERRCODE + " 数据长度=>" + data.Length);
|
|
try
|
|
{
|
|
//抛出网络数据
|
|
if (mServerType == ServerType.TcpP2PTarget)
|
|
{
|
|
NetMsg.Instance.PostNetMsgEvent(CMDID, mUID,data);
|
|
}
|
|
else
|
|
{
|
|
NetMsg.Instance.PostNetMsgEvent(CMDID, data);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
NetworkDeBugLog("逻辑处理错误：" + ex.ToString());
|
|
}
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 关闭连接
|
|
/// </summary>
|
|
public void OnConnectClose()
|
|
{
|
|
NetworkDeBugLog("OnConnectClose");
|
|
EventSystem.Instance.PostEvent(EEvent.OnSocketDisconnect, mServerType, mUID);
|
|
}
|
|
}
|
|
}
|