前言:本篇文章主题Tcp连贯Socket套接字相干内容,对根底局部、优化补充局部做了阐明,最终目标是让阅读者看完本篇文章后能写一个功能完善的网络框架。
首先明确一下网络连接的根底模块有哪些
[根底局部2]数据接管
客户端Socket连贯后开始接收数据,客户端接收数据的形式个别有两种
[数据接管第一种]
开线程,为何开线程:数据接管不须要和Mono交互,仅仅是对byte[]数据的操作,开线程提高效率,上面是代码示例
这个没什么好说的,四个重载接口区别不大
//数据初始化uint ReceiveMaxByteCount;byte[] bufferTemp = new byte[ReceiveMaxByteCount]; pubvoid void Connect(string _ip,int _port){ SocketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPAddress ip = IPAddress.Parse(_ip); IPEndPoint point = new IPEndPoint(ip, _port); SocketClient.NoDelay = true; SocketClient.Connect(point); }
[根底局部2]数据接管
客户端Socket连贯后开始接收数据,客户端接收数据的形式个别有两种
[数据接管第一种]
开线程,为何开线程:数据接管不须要和Mono交互,仅仅是对byte[]数据的操作,开线程提高效率,上面是代码示例
pubvoid void Connect(string _ip,int _port){ SocketClient = new Socket() //........... //这是第一种形式,开线程接管 Thread c_thread = new Thread(Received); c_thread.IsBackground = true; c_thread.Start();}
void Received(){ while (true) { try { int len = _SocketClient.Receive(bufferTemp); //len 理论接管到的无效字节数 if (len <= 0) { //异样解决 break; } //把收到的字节解析或者塞入接管缓存池中 } catch { } }}
[数据接管第二种]
简略粗犷的写在Update里,如果是框架则应该有tick 接管和发送缓存池的机制,这里是根底局部,只介绍外围代码
void Update(){ ProcessReceive()} void ProcessReceive(){ uint recLen = 0; if( client.Connected) //maxLen代表最大接管长度,如果有缓存池,接管长度不能超过缓存池残余量的长度 recLen = (uint)client.Receive(bufferTemp,maxLen, SocketFlags.None); //有池则入池,没池间接解析bufferTemp,数据长度为recLen}
[根底局部3]数据发送
void Send (Socket client, Byte[] buff, uint nLen, SocketFlags flags = SocketFlags.None){ try { //提醒:sendLen代表向tcp底层缓冲区塞了多少个字节,并不是向服务器发送胜利了多少个字节 uint sendLen = client.Send(buff, (int)nLen, flags); } catch (SocketException e) { } }
[根底局部4]:断开连接
void Close (Socket ClientSocket){ try { ClientSocket.Shutdown(SocketShutdown.Both); ClientSocket.Close(); } catch (SocketException e) { //LogSystem.Error(e.ToString()); }}
Socket根底局部外的优化
[补充优化1]发送、接管缓存池
咱们能够把发送缓存池和接管缓存池都封装成一个class,未来数据发送和接管的重任就落到了它俩身上,输入叫SocketOutputPool,输出叫SocketInputPool
[补充优化1-发送缓存池]
发送缓存池是干嘛的?基本原理就是保护一个Byte数组。
当下层业务有数据向服务器发送时,会调用NetMgr的send函数,send函数再调用SocketOutputPool的Write函数向Byte数组中写入该数据。
缓存池的数据适合发送,发送多少?当Write函数写入数据后,该当记录一下以后数据长度,int变量m_PoolTail记录尾部长度,上文有过对发送机会的形容,一般来说会在Update中调用发送函数
public const uint DEFAULT_SOCKET_OUTPUT_BUFFER_SIZE = 1024 * 80;//缓存最大长度int m_Tail = 0; //缓存池以后长度byte[] m_Buffer = new Byte[DEFAULT_SOCKET_OUTPUT_BUFFER_SIZE]; void TickSend(){ //再次提醒:SendLen不是向服务器发送的长度,而是往Tcp发送缓冲区塞了多少数据 int SendLen = Socket.Send(m_Buffer,m_PoolTail, flag); //发送完结后,须要从池中把发送过得数据剔除}
3、数据发送和数据接管能够写两个缓存池
注意事项:
1、Tcp是否须要缓存池,可设置bool变量Nodelay
2:socket.Send()办法的返回变量int值示意该send向tcp发送缓冲区塞了多少个字节,并不是向服务器发送胜利了多少个字节,
3:如果呈现发包失败,tcp底层会主动重发,tcp的底层有发送胜利回复机制,另一端收到音讯包后会回复一个确认包
图片起源:http://www.pizei.com/ 页游