70 lines
1.7 KiB
C#
70 lines
1.7 KiB
C#
using HaoYueNet.ClientNetwork.IOCPMode;
|
|
using System.Net.Sockets;
|
|
|
|
namespace ClientSaeaTest
|
|
{
|
|
internal class SaeaClient : TcpSaeaClient
|
|
{
|
|
public SaeaClient(int numConnections, int receiveBufferSize)
|
|
: base(numConnections, receiveBufferSize)
|
|
{
|
|
OnClientNumberChange += ClientNumberChange;
|
|
OnReceive += ReceiveData;
|
|
OnDisconnected += OnDisconnect;
|
|
OnNetLog += OnShowNetLog;
|
|
}
|
|
|
|
|
|
private void ClientNumberChange(int num, AsyncUserToken token)
|
|
{
|
|
Console.WriteLine("Client数发生变化");
|
|
}
|
|
|
|
public void Connect(string ip, int port)
|
|
{
|
|
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
|
base.StartConnect(ip, port, socket);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 接受包回调
|
|
/// </summary>
|
|
/// <param name="CMDID">协议ID</param>
|
|
/// <param name="ERRCODE">错误编号</param>
|
|
/// <param name="data">业务数据</param>
|
|
private void ReceiveData(AsyncUserToken token, int CMDID,int Error, byte[] data)
|
|
{
|
|
DataCallBack(token.Socket, CMDID, Error,data);
|
|
}
|
|
|
|
public void DataCallBack(Socket sk, int CMDID, int Error, byte[] data)
|
|
{
|
|
Console.WriteLine("收到消息 CMDID =>" + CMDID + " 数据长度=>" + data.Length);
|
|
try
|
|
{
|
|
//抛出网络数据
|
|
//NetMsg.Instance.PostNetMsgEvent(CMDID, sk, data);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Console.WriteLine("逻辑处理错误：" + ex.ToString());
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 断开连接
|
|
/// </summary>
|
|
/// <param name="sk"></param>
|
|
public void OnDisconnect(AsyncUserToken token)
|
|
{
|
|
Console.WriteLine("断开连接");
|
|
//ServerManager.g_ClientMgr.SetClientOfflineForSocket(token.Socket);
|
|
}
|
|
|
|
public void OnShowNetLog(string msg)
|
|
{
|
|
//ServerManager.g_Log.Debug(msg);
|
|
}
|
|
}
|
|
}
|