服务器异步客户端-Toy模板网

这篇具有很好参考价值的文章主要介绍了服务器异步客户端。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

服务器

//泛型单例

internal class Singleton<T>where T:class,new() { private static T ins; public static T Ins { get { if(ins == null) { ins = new T(); } return ins; } } }

//消息中心

internal class MessageManager<T>:Singleton<MessageManager<T>>
{
Dictionary<int, Action<T>> MsgDic = new Dictionary<int, Action<T>>();
public void OnAddListen(int id,Action<T> action)
{
if(MsgDic.ContainsKey(id))
{
MsgDic[id] += action;
}
else
{
MsgDic.Add(id, action);
}
}
public void OnBroadCast(int id,T t)
{
if(MsgDic.ContainsKey(id))
{
MsgDic[id](t);
}
}
}

internal class Client
{
public Socket socket;
public byte[] data=new byte[1024];
}

internal class MsgData
{
public Client cli;
public byte[] data;
}

//服务器框架

internal class NetManager:Singleton<NetManager>
{
Socket socket;
//public List<Client> allcli=new List<Client>();
public void InitServer()
{
socket=new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Bind(new IPEndPoint(IPAddress.Any,2201));
socket.Listen(10);
Console.WriteLine("2201 服务器开启");
socket.BeginAccept(OnAccept, null);
}

private void OnAccept(IAsyncResult ar)
{
try
{
Socket socket_cli=socket.EndAccept(ar);
IPEndPoint iPEnd=socket_cli.RemoteEndPoint as IPEndPoint;
Console.WriteLine("IP"+iPEnd.Address+"port"+iPEnd.Port+"连接上了");
socket.BeginAccept(OnAccept, null);
Client client=new Client();
client.socket= socket_cli;
//allcli.Add(client);
client.socket.BeginReceive(client.data, 0, client.data.Length, SocketFlags.None, Receive, client);

}
catch (Exception ex)
{
Console.WriteLine(ex);
}
}

private void Receive(IAsyncResult ar)
{
try
{
Client client=ar.AsyncState as Client;
int len=client.socket.EndReceive(ar);
if(len>0)
{

byte[] rdata=new byte[len];
Buffer.BlockCopy(client.data,0,rdata,0,len);
while(rdata.Length>4)
{
int bodylen=BitConverter.ToInt32(rdata, 0);
byte[] bodydata=new byte[bodylen];
Buffer.BlockCopy(rdata, 4, bodydata, 0, bodylen);

int msgid=BitConverter.ToInt32(bodydata, 0);
byte[] info=new byte[bodylen-4];
Buffer.BlockCopy(bodydata,4,info, 0, info.Length);

MsgData msgData = new MsgData();
msgData.cli = client;
msgData.data = info;
MessageManager<MsgData>.Ins.OnBroadCast(msgid, msgData);

int sylen = rdata.Length - 4 - bodylen;
byte[] sydata=new byte[sylen];
Buffer.BlockCopy(rdata,4+bodylen, sydata, 0, sylen);
rdata = sydata;
}

}
client.socket.BeginReceive(client.data, 0, client.data.Length, SocketFlags.None, Receive, client);
}
catch (Exception ex)
{
Console.WriteLine(ex);
}
}
public void OnSendServer(int id, byte[] data,Client client)
{
int head = 4 + data.Length;
byte[] enddata=new byte[0];
enddata = enddata.Concat(BitConverter.GetBytes(head)).Concat(BitConverter.GetBytes(id)).Concat(data).ToArray();
client.socket.BeginSend(enddata, 0, enddata.Length, SocketFlags.None, Send, client);
}

private void Send(IAsyncResult ar)
{
Client client=ar.AsyncState as Client;
int len = client.socket.EndSend(ar);
Console.WriteLine("发给客户端消息"+len);
}
}

客户端

public class NetManager : Singleton<NetManager>
{
Socket socket;
byte[] data=new byte[1024];

Queue<byte[]> queue=new Queue<byte[]>();
public void InitClient()
{
socket=new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.BeginConnect("127.0.0.1", 2201, OnConnect, null);
}

private void OnConnect(IAsyncResult ar)
{
try
{
socket.EndConnect(ar);
Debug.Log("连接成功");
socket.BeginReceive(data, 0, data.Length, SocketFlags.None, OnReceive, null);
}
catch (Exception ex)
{
Debug.Log(ex);
}
}

private void OnReceive(IAsyncResult ar)
{
try
{
int len =socket.EndReceive(ar);
if (len > 0)
{
byte[] rdata = new byte[len];
Buffer.BlockCopy(data, 0, rdata, 0, len);
while (rdata.Length > 4)
{
int bodylen = BitConverter.ToInt32(rdata, 0);
byte[] bodydata = new byte[bodylen];
Buffer.BlockCopy(rdata, 4, bodydata, 0, bodylen);

queue.Enqueue(bodydata);

int sylen = rdata.Length - 4 - bodylen;
byte[] sydata = new byte[sylen];
Buffer.BlockCopy(rdata, 4 + bodylen, sydata, 0, sylen);
rdata = sydata;
}

}
socket.BeginReceive(data, 0, data.Length, SocketFlags.None, OnReceive, null);
}
catch (Exception ex)
{
Debug.Log(ex);
}
}
public void NetUpdata()
{
if(queue.Count > 0)
{
byte[] bodydata=queue.Dequeue();
int msgid=BitConverter.ToInt32(bodydata, 0);
byte[] info=new byte[bodydata.Length-4];
Buffer.BlockCopy(bodydata, 4, info, 0, info.Length);
MessageManager<byte[]>.Ins.OnBroadCast(msgid, info);

}
}

public void OnSendClient(int id, byte[] data)
{
int head = 4 + data.Length;
byte[] enddata=new byte[0];
enddata = enddata.Concat(BitConverter.GetBytes(head)).Concat(BitConverter.GetBytes(id)).Concat(data).ToArray();
socket.BeginSend(enddata, 0, enddata.Length, SocketFlags.None, OnSend, null);
}

private void OnSend(IAsyncResult ar)
{
int len = socket.EndSend(ar);
Debug.Log("发给服务器消息"+len);
}
}文章来源地址https://www.toymoban.com/news/detail-845522.html

到了这里，关于服务器异步客户端的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！