Unity3d网络游戏Socket通讯
?
下面是Unity3d游戏通讯Socket实现： BaseGameSocket.cs
@原创：dongfu.luo
using System;
using System.Collections.Generic;
using System.Net.Sockets;
{
??? //用来接收服务端发过来的缓冲Buff
??? private byte[] _data_buffer;
? //缓冲二进制数组从哪里开始读
??? private int _data_offset;
//缓冲二进制数组读多少个byte
??? private int _data_size;
//游戏服务器IP地址
??? private string _ip;
??? private bool _is_read_head;
//游戏服务器端口
??? private int _port;
//要服务端发送的数据命令列表
??? private List<PacketOut> _send_list = new List<PacketOut>();
??? private Socket _sock;
??? private const int MAX_SEND_QUEUE = 0x3e8;
//清空数据，一般是在断开重联时候调用???? private void Clear()
??? {
??????? this._ip = null;
??????? this._port = 0;
??????? this._sock = null;
??????? List<PacketOut> list = this._send_list;
??????? lock (list)
??????? {
??????????? this._send_list.Clear();
??????? }
??????? this._is_read_head = false;
??????? this._data_buffer = null;
??????? this._data_offset = 0;
??????? this._data_size = 0;
??? }
//关闭客户端的Socket???? public void Close()
??? {
?try
??????? {
??????????? Socket socket = this._sock;
??????????? this.Clear();
??????????? if ((socket != null) && socket.Connected)
??????????? {
??????????????? socket.Shutdown(SocketShutdown.Both);
??????????????? socket.Close();
??????????? }
??????? }
??????? catch (Exception exception)
??????? {
??????????? UEDebug.LogError("Connect: " + exception.ToString());
??????????? this.Error(Lang.GetString("k3432"));
??????? }
??? }
?//连接游戏服务端public void Connect(string ip, int port)
??? {
??????? try
??????? {
??????????? this.Close();
??????????? this._ip = ip;
??????????? this._port = port;
??????????? this._sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
??????????? this._sock.NoDelay = true;
??????????? this._sock.BeginConnect(this._ip, this._port, new AsyncCallback(this.OnConnect), this._sock);
??????? }
??????? catch (Exception exception)
??????? {
??????????? UEDebug.LogError("Connect: " + exception.ToString());
??????????? this.Error(Lang.GetString("k3432"));
??????? }
??? }
//如果Socket没有关闭继续等服务器信息，如果有信息则开始读???? private void ContinueRead()
??? {
??????? try
??????? {
??????????? if (this.IsConnected)
??????????? {
this._sock.BeginReceive(this._data_buffer, this._data_offset, this._data_size - this._data_offset, SocketFlags.None, new AsyncCallback(this.OnRead), null);
??????????? }
??????? }
??????? catch (Exception exception)
??????? {
??????????? UEDebug.LogError(exception.ToString());
??????????? this.Error(Lang.GetString("k3432"));
??????? }
??? }
//从发送队列从不断向游戏服务器发送命令???? private void ContinueSend()
??? {
??????? PacketOut state = null;
??????? List<PacketOut> list = this._send_list;
?lock (list)
??????? {
??????????? if (this._send_list.Count == 0)
??????????? {
??????????????? return;
??????????? }
??????????? state = this._send_list[0];
??????????? if (state.start)
??????????? {
??????????????? return;
??????????? }
??????????? state.start = true;
??????? }
??????? Socket sock = state.sock;
??????? if (sock.Connected)
??????? {
??????????? sock.BeginSend(state.buff, 0, state.buff.Length, SocketFlags.None, new AsyncCallback(this.OnSend), state);
??????? }
??? }
//发送失败或错误，则关闭Socket一般是网络断了服务器关闭了???? protected void Error(string msg)
??? {
??????? this.Close();
??????? this.OnError(msg);
??? }
//程序猿都知道这是析构函数???? ~PackedSocket()
??? {
??????? this.Close();
??? }??? public int GetSendQueueSize()
??? {
??????? List<PacketOut> list = this._send_list;
??????? lock (list)
??????? {
??????????? return this._send_list.Count;
??????? }
??? }
//此函数由子类去处理???? protected abstract void OnConnect();
//如果是第一次连接上了，解析消息头
??? private void OnConnect(IAsyncResult ret)
??? {
??????? if (ret.AsyncState == this._sock)
??????? {
??????????? try
??????????? {
??????????????? this._sock.EndConnect(ret);
??????????????? this.ReadHead();
??????????????? this.OnConnect();
??????????? }
??????????? catch (Exception exception)
??????????? {????????????????? Debug.log(exception);
???????????? }
??????? }
??? }??? protected abstract void OnError(string msg);
??? protected abstract void OnPack(byte[] data);
//有服务端信息来，开始解析，现解析信息头再解析消息体
??? private void OnRead(IAsyncResult ar)
??? {
??????? try
??????? {
??????????? if (this.IsConnected)
??????????? {
??????????????? int num = this._sock.EndReceive(ar);
??????????????? this._data_offset += num;
??????????????? if (num <= 0)
??????????????? {
????????????????????
??????????????? }
??????????????? else if (this._data_offset != this._data_size)
??????????????? {
??????????????????? this.ContinueRead();
??????????????? }
??????????????? else if (this._is_read_head)
??????????????? {
?int num2 = BitConverter.ToInt32(this._data_buffer, 0);
??????????????????? this.ReadData(num2);
??????????????? }
??????????????? else
??????????????? {
??????????????????? this.OnPack(this._data_buffer);
??????????????????? this.ReadHead();
??????????????? }
??????????? }
??????? }
??????? catch (Exception exception)
??????? {????? Debug.log(exception);
???????}
??? }
//如果命令发送成功，检查发送队列是否还有需要发送的命令。如果有则继续发送???? private void OnSend(IAsyncResult ar)
??? {
??????? PacketOut asyncState = ar.AsyncState as PacketOut;
??????? Socket sock = asyncState.sock;
??????? if (sock.Connected)
??????? {
??????????? sock.EndSend(ar);
??????????? List<PacketOut> list = this._send_list;
??????????? lock (list)
??????????? {
??????????????? if (this._send_list.Contains(asyncState))
??????????????? {
??????????????????? this._send_list.Remove(asyncState);
??????????????? }
??????????? }
??????????? this.ContinueSend();
??????? }
??? }
//读取消息体???? private void ReadData(int pack_len)
??? {
??????? this._is_read_head = false;
??????? this._data_size = pack_len;
??????? this._data_offset = 4;
??????? this._data_buffer = new byte[this._data_size];
??????? this.ContinueRead();
??? }
//读取消息头???? private void ReadHead()
??? {
??????? this._is_read_head = true;
??????? this._data_size = 4;
??????? this._data_offset = 0;
??????? this._data_buffer = new byte[this._data_size];
??????? this.ContinueRead();
??? }
//具体的发送信息，先把数据发到发送队列???? public void Send(byte[] buff)
{
??????? if (this.IsConnected)
??????? {
??????????? PacketOut item = new PacketOut {
??????????????? start = false,
??????????????? buff = buff,
??????????????? sock = this._sock
??????????? };
??????????? int count = 0;
??????????? List<PacketOut> list = this._send_list;
??????????? lock (list)
??????????? {
??????????????? this._send_list.Add(item);
??????????????? count = this._send_list.Count;
??????????? }
??????????? if (count > 0x3e8)
??????????? {
??????????????????????????? }
?else
??????????? {
??????????????? this.ContinueSend();
??????????? }
??????? }
??? }??? public bool IsClosed
??? {
??????? get
??????? {
??????????? return (this._sock == null);
??????? }
??? }??? public bool IsConnected
??? {
??????? get
??????? {
??????????? return ((this._sock != null) && this._sock.Connected);
??????? }
??? }private class PacketOut
??? {
??????? public byte[] buff;
??????? public Socket sock;
??????? public bool start;
??? }
}