C#使用Protocol Buffer(ProtoBuf)进行Unity中的Socket通信

- 日理万妓 2022-07-15 12:05 595阅读 0赞

From: [http://www.jb51.net/article/82795.htm][http_www.jb51.net_article_82795.htm]

这篇文章主要介绍了C\#使用Protocol Buffer(ProtoBuf)进行Unity的Socket通信的实例,Protocol Buffer是Google开发的数据格式,也是除了XML和JSON之外人气第三高的^^需要的朋友可以参考下

首先来说一下本文中例子所要实现的功能：

*  基于ProtoBuf序列化对象
 *  使用Socket实现时时通信
 *  数据包的编码和解码

下面来看具体的步骤：

**一、Unity中使用ProtoBuf**

导入DLL到Unity中，  
创建网络传输的模型类：

[?][Link 1]

在Unity中添加测试脚本，介绍ProtoBuf工具的使用。

[?][Link 1]

**二、Unity中使用Socket实现时时通信**

通信应该实现的功能：

*  服务器可以时时监听多个客户端
 *  服务器可以时时监听某一个客户端消息
 *  服务器可以时时给某一个客户端发消息
 *  首先我们需要定义一个客户端对象

[?][Link 1]

然后实现我们的服务器代码

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> 
    <div>
      15 
    </div> 
    <div>
      16 
    </div> 
    <div>
      17 
    </div> 
    <div>
      18 
    </div> 
    <div>
      19 
    </div> 
    <div>
      20 
    </div> 
    <div>
      21 
    </div> 
    <div>
      22 
    </div> 
    <div>
      23 
    </div> 
    <div>
      24 
    </div> 
    <div>
      25 
    </div> 
    <div>
      26 
    </div> 
    <div>
      27 
    </div> 
    <div>
      28 
    </div> 
    <div>
      29 
    </div> 
    <div>
      30 
    </div> 
    <div>
      31 
    </div> 
    <div>
      32 
    </div> 
    <div>
      33 
    </div> 
    <div>
      34 
    </div> 
    <div>
      35 
    </div> 
    <div>
      36 
    </div> 
    <div>
      37 
    </div> 
    <div>
      38 
    </div> 
    <div>
      39 
    </div> 
    <div>
      40 
    </div> 
    <div>
      41 
    </div> 
    <div>
      42 
    </div> 
    <div>
      43 
    </div> 
    <div>
      44 
    </div> 
    <div>
      45 
    </div> 
    <div>
      46 
    </div> 
    <div>
      47 
    </div> 
    <div>
      48 
    </div> 
    <div>
      49 
    </div> 
    <div>
      50 
    </div> 
    <div>
      51 
    </div> 
    <div>
      52 
    </div> 
    <div>
      53 
    </div> 
    <div>
      54 
    </div> 
    <div>
      55 
    </div> 
    <div>
      56 
    </div> 
    <div>
      57 
    </div> 
    <div>
      58 
    </div> 
    <div>
      59 
    </div> 
    <div>
      60 
    </div> 
    <div>
      61 
    </div> 
    <div>
      62 
    </div> 
    <div>
      63 
    </div> 
    <div>
      64 
    </div> 
    <div>
      65 
    </div> 
    <div>
      66 
    </div> 
    <div>
      67 
    </div> 
    <div>
      68 
    </div> 
    <div>
      69 
    </div> 
    <div>
      70 
    </div> 
    <div>
      71 
    </div> 
    <div>
      72 
    </div> 
    <div>
      73 
    </div> 
    <div>
      74 
    </div> 
    <div>
      75 
    </div> 
    <div>
      76 
    </div> 
    <div>
      77 
    </div> 
    <div>
      78 
    </div> 
    <div>
      79 
    </div> 
    <div>
      80 
    </div> 
    <div>
      81 
    </div> 
    <div>
      82 
    </div> 
    <div>
      83 
    </div> 
    <div>
      84 
    </div> 
    <div>
      85 
    </div> 
    <div>
      86 
    </div> 
    <div>
      87 
    </div> 
    <div>
      88 
    </div> 
    <div>
      89 
    </div> 
    <div>
      90 
    </div> 
    <div>
      91 
    </div> 
    <div>
      92 
    </div> 
    <div>
      93 
    </div> 
    <div>
      94 
    </div> 
    <div>
      95 
    </div> 
    <div>
      96 
    </div> 
    <div>
      97 
    </div> 
    <div>
      98 
    </div> 
    <div>
      99 
    </div> 
    <div>
      100 
    </div> 
    <div>
      101 
    </div> 
    <div>
      102 
    </div> 
    <div>
      103 
    </div> 
    <div>
      104 
    </div> 
    <div>
      105 
    </div> 
    <div>
      106 
    </div> 
    <div>
      107 
    </div> 
    <div>
      108 
    </div> 
    <div>
      109 
    </div> 
    <div>
      110 
    </div> 
    <div>
      111 
    </div> 
    <div>
      112 
    </div> 
    <div>
      113 
    </div> 
    <div>
      114 
    </div> 
    <div>
      115 
    </div> 
    <div>
      116 
    </div> 
    <div>
      117 
    </div> 
    <div>
      118 
    </div> 
    <div>
      119 
    </div> 
    <div>
      120 
    </div> 
    <div>
      121 
    </div> 
    <div>
      122 
    </div> 
    <div>
      123 
    </div> 
    <div>
      124 
    </div> 
    <div>
      125 
    </div> 
    <div>
      126 
    </div> 
    <div>
      127 
    </div> 
    <div>
      128 
    </div> 
    <div>
      129 
    </div> 
    <div>
      130 
    </div> 
    <div>
      131 
    </div> 
    <div>
      132 
    </div> 
    <div>
      133 
    </div> 
    <div>
      134 
    </div> 
    <div>
      135 
    </div> 
    <div>
      136 
    </div> 
    <div>
      137 
    </div> 
    <div>
      138 
    </div> 
    <div>
      139 
    </div> 
    <div>
      140 
    </div> 
    <div>
      141 
    </div> 
    <div>
      142 
    </div> 
    <div>
      143 
    </div> 
    <div>
      144 
    </div> 
    <div>
      145 
    </div> 
    <div>
      146 
    </div> 
    <div>
      147 
    </div> 
    <div>
      148 
    </div> 
    <div>
      149 
    </div> 
    <div>
      150 
    </div> 
    <div>
      151 
    </div> 
    <div>
      152 
    </div> 
    <div>
      153 
    </div> 
    <div>
      154 
    </div> 
    <div>
      155 
    </div> 
    <div>
      156 
    </div> 
    <div>
      157 
    </div> 
    <div>
      158 
    </div> 
    <div>
      159 
    </div> 
    <div>
      160 
    </div> 
    <div>
      161 
    </div> 
    <div>
      162 
    </div> 
    <div>
      163 
    </div> 
    <div>
      164 
    </div> 
    <div>
      165 
    </div> 
    <div>
      166 
    </div> 
    <div>
      167 
    </div> 
    <div>
      168 
    </div> 
    <div>
      169 
    </div> 
    <div>
      170 
    </div> 
    <div>
      171 
    </div> 
    <div>
      172 
    </div> 
    <div>
      173 
    </div> 
    <div>
      174 
    </div> 
    <div>
      175 
    </div> 
    <div>
      176 
    </div> 
    <div>
      177 
    </div> 
    <div>
      178 
    </div> 
    <div>
      179 
    </div> 
    <div>
      180 
    </div> 
    <div>
      181 
    </div> 
    <div>
      182 
    </div> 
    <div>
      183 
    </div> 
    <div>
      184 
    </div> 
    <div>
      185 
    </div> 
    <div>
      186 
    </div> 
    <div>
      187 
    </div> 
    <div>
      188 
    </div> 
    <div>
      189 
    </div> 
    <div>
      190 
    </div> 
    <div>
      191 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>using</code> 
      <code>System.Collections;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Collections.Generic;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Net;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Net.Sockets;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>NetServer{ </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//单例脚本</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>static</code> 
      <code>readonly NetServer Instance = </code> 
      <code>new</code> 
      <code>NetServer();</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//定义tcp服务器</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>Socket server;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>int</code> 
      <code>maxClient = 10;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//定义端口</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>int</code> 
      <code>port = 35353;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//用户池</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>Stack&lt;NetUserToken&gt; pools;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>NetServer()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//初始化socket</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server = </code> 
      <code>new</code> 
      <code>Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server.Bind(</code> 
      <code>new</code> 
      <code>IPEndPoint(IPAddress.Any, port));</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//开启服务器</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>Start()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server.Listen(maxClient);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"Server OK!"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//实例化客户端的用户池</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>pools = </code> 
      <code>new</code> 
      <code>Stack&lt;NetUserToken&gt;(maxClient);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>for</code> 
      <code>(</code> 
      <code>int</code> 
      <code>i = 0; i &lt; maxClient; i++)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetUserToken usertoken = </code> 
      <code>new</code> 
      <code>NetUserToken();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>pools.Push(usertoken);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//可以异步接受客户端, BeginAccept函数的第一个参数是回调函数，当有客户端连接的时候自动调用</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server.BeginAccept (AsyncAccept, null);</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//回调函数， 有客户端连接的时候会自动调用此方法</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>AsyncAccept(IAsyncResult result)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//结束监听，同时获取到客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>Socket client = server.EndAccept(result);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"有客户端连接"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//来了一个客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetUserToken userToken = pools.Pop();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>userToken.socket = client;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//客户端连接之后，可以接受客户端消息</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>BeginReceive(userToken);</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//尾递归，再次监听是否还有其他客户端连入</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>server.BeginAccept(AsyncAccept, null);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//异步监听消息</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>BeginReceive(NetUserToken userToken)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//异步方法</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>userToken.socket.BeginReceive(userToken.buffer, 0, userToken.buffer.Length, SocketFlags.None,</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>EndReceive, userToken);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//监听到消息之后调用的函数</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>EndReceive(IAsyncResult result)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//取出客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetUserToken userToken = result.AsyncState as NetUserToken;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//获取消息的长度</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code> 
      <code>len = userToken.socket.EndReceive(result);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(len &gt; 0)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte[] data = </code> 
      <code>new</code> 
      <code>byte[len];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Buffer.BlockCopy(userToken.buffer, 0, data, 0, len);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//用户接受消息</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>userToken.Receive(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//尾递归，再次监听客户端消息</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>BeginReceive(userToken);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Collections;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Collections.Generic;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Net;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Net.Sockets;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>NetServer{ </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//单例脚本</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>static</code> 
      <code>readonly NetServer Instance = </code> 
      <code>new</code> 
      <code>NetServer();</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//定义tcp服务器</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>Socket server;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>int</code> 
      <code>maxClient = 10;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//定义端口</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>int</code> 
      <code>port = 35353;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//用户池</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>Stack&lt;NetUserToken&gt; pools;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>NetServer()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//初始化socket</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server = </code> 
      <code>new</code> 
      <code>Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server.Bind(</code> 
      <code>new</code> 
      <code>IPEndPoint(IPAddress.Any, port));</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//开启服务器</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>Start()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server.Listen(maxClient);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"Server OK!"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//实例化客户端的用户池</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>pools = </code> 
      <code>new</code> 
      <code>Stack&lt;NetUserToken&gt;(maxClient);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>for</code> 
      <code>(</code> 
      <code>int</code> 
      <code>i = 0; i &lt; maxClient; i++)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetUserToken usertoken = </code> 
      <code>new</code> 
      <code>NetUserToken();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>pools.Push(usertoken);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//可以异步接受客户端, BeginAccept函数的第一个参数是回调函数，当有客户端连接的时候自动调用</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>server.BeginAccept (AsyncAccept, null);</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//回调函数， 有客户端连接的时候会自动调用此方法</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>AsyncAccept(IAsyncResult result)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//结束监听，同时获取到客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>Socket client = server.EndAccept(result);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"有客户端连接"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//来了一个客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetUserToken userToken = pools.Pop();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>userToken.socket = client;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//客户端连接之后，可以接受客户端消息</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>BeginReceive(userToken);</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//尾递归，再次监听是否还有其他客户端连入</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>server.BeginAccept(AsyncAccept, null);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//异步监听消息</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>BeginReceive(NetUserToken userToken)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//异步方法</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>userToken.socket.BeginReceive(userToken.buffer, 0, userToken.buffer.Length, SocketFlags.None,</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>EndReceive, userToken);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//监听到消息之后调用的函数</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>EndReceive(IAsyncResult result)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//取出客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetUserToken userToken = result.AsyncState as NetUserToken;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//获取消息的长度</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code> 
      <code>len = userToken.socket.EndReceive(result);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(len &gt; 0)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte[] data = </code> 
      <code>new</code> 
      <code>byte[len];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Buffer.BlockCopy(userToken.buffer, 0, data, 0, len);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//用户接受消息</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>userToken.Receive(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//尾递归，再次监听客户端消息</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>BeginReceive(userToken);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

在Unity中开启服务器，并使用C\#控制台模拟客户端连接、发送消息操作。测试OK了，Unity中可以时时监听到消息。

[?][Link 1]

**三、数据包的编码和解码**

首先，举个例子，这个月信用卡被媳妇刷爆了，面对房贷车贷的压力，我只能选择分期付款。。。

那么OK了，现在我想问一下，当服务器向客户端发送的数据过大时怎么办呢？

当服务器需要向客户端发送一条很长的数据，也会“分期付款！”，服务器会把一条很长的数据分成若干条小数据，多次发送给客户端。

可是，这样就又有另外一个问题，客户端接受到多条数据之后如何解析？

这里其实就是客户端的解码。server发数据一般采用“长度+内容”的格式，Client接收到数据之后，先提取出长度来，然后根据长度判断内容是否发送完毕。

再次重申，用户在发送序列化好的消息的前，需要先编码后再发送消息；用户在接受消息后，需要解码之后再解析数据（反序列化）。

[?][Link 1]

用户接受数据代码如下：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> 
    <div>
      15 
    </div> 
    <div>
      16 
    </div> 
    <div>
      17 
    </div> 
    <div>
      18 
    </div> 
    <div>
      19 
    </div> 
    <div>
      20 
    </div> 
    <div>
      21 
    </div> 
    <div>
      22 
    </div> 
    <div>
      23 
    </div> 
    <div>
      24 
    </div> 
    <div>
      25 
    </div> 
    <div>
      26 
    </div> 
    <div>
      27 
    </div> 
    <div>
      28 
    </div> 
    <div>
      29 
    </div> 
    <div>
      30 
    </div> 
    <div>
      31 
    </div> 
    <div>
      32 
    </div> 
    <div>
      33 
    </div> 
    <div>
      34 
    </div> 
    <div>
      35 
    </div> 
    <div>
      36 
    </div> 
    <div>
      37 
    </div> 
    <div>
      38 
    </div> 
    <div>
      39 
    </div> 
    <div>
      40 
    </div> 
    <div>
      41 
    </div> 
    <div>
      42 
    </div> 
    <div>
      43 
    </div> 
    <div>
      44 
    </div> 
    <div>
      45 
    </div> 
    <div>
      46 
    </div> 
    <div>
      47 
    </div> 
    <div>
      48 
    </div> 
    <div>
      49 
    </div> 
    <div>
      50 
    </div> 
    <div>
      51 
    </div> 
    <div>
      52 
    </div> 
    <div>
      53 
    </div> 
    <div>
      54 
    </div> 
    <div>
      55 
    </div> 
    <div>
      56 
    </div> 
    <div>
      57 
    </div> 
    <div>
      58 
    </div> 
    <div>
      59 
    </div> 
    <div>
      60 
    </div> 
    <div>
      61 
    </div> 
    <div>
      62 
    </div> 
    <div>
      63 
    </div> 
    <div>
      64 
    </div> 
    <div>
      65 
    </div> 
    <div>
      66 
    </div> 
    <div>
      67 
    </div> 
    <div>
      68 
    </div> 
    <div>
      69 
    </div> 
    <div>
      70 
    </div> 
    <div>
      71 
    </div> 
    <div>
      72 
    </div> 
    <div>
      73 
    </div> 
    <div>
      74 
    </div> 
    <div>
      75 
    </div> 
    <div>
      76 
    </div> 
    <div>
      77 
    </div> 
    <div>
      78 
    </div> 
    <div>
      79 
    </div> 
    <div>
      80 
    </div> 
    <div>
      81 
    </div> 
    <div>
      82 
    </div> 
    <div>
      83 
    </div> 
    <div>
      84 
    </div> 
    <div>
      85 
    </div> 
    <div>
      86 
    </div> 
    <div>
      87 
    </div> 
    <div>
      88 
    </div> 
    <div>
      89 
    </div> 
    <div>
      90 
    </div> 
    <div>
      91 
    </div> 
    <div>
      92 
    </div> 
    <div>
      93 
    </div> 
    <div>
      94 
    </div> 
    <div>
      95 
    </div> 
    <div>
      96 
    </div> 
    <div>
      97 
    </div> 
    <div>
      98 
    </div> 
    <div>
      99 
    </div> 
    <div>
      100 
    </div> 
    <div>
      101 
    </div> 
    <div>
      102 
    </div> 
    <div>
      103 
    </div> 
    <div>
      104 
    </div> 
    <div>
      105 
    </div> 
    <div>
      106 
    </div> 
    <div>
      107 
    </div> 
    <div>
      108 
    </div> 
    <div>
      109 
    </div> 
    <div>
      110 
    </div> 
    <div>
      111 
    </div> 
    <div>
      112 
    </div> 
    <div>
      113 
    </div> 
    <div>
      114 
    </div> 
    <div>
      115 
    </div> 
    <div>
      116 
    </div> 
    <div>
      117 
    </div> 
    <div>
      118 
    </div> 
    <div>
      119 
    </div> 
    <div>
      120 
    </div> 
    <div>
      121 
    </div> 
    <div>
      122 
    </div> 
    <div>
      123 
    </div> 
    <div>
      124 
    </div> 
    <div>
      125 
    </div> 
    <div>
      126 
    </div> 
    <div>
      127 
    </div> 
    <div>
      128 
    </div> 
    <div>
      129 
    </div> 
    <div>
      130 
    </div> 
    <div>
      131 
    </div> 
    <div>
      132 
    </div> 
    <div>
      133 
    </div> 
    <div>
      134 
    </div> 
    <div>
      135 
    </div> 
    <div>
      136 
    </div> 
    <div>
      137 
    </div> 
    <div>
      138 
    </div> 
    <div>
      139 
    </div> 
    <div>
      140 
    </div> 
    <div>
      141 
    </div> 
    <div>
      142 
    </div> 
    <div>
      143 
    </div> 
    <div>
      144 
    </div> 
    <div>
      145 
    </div> 
    <div>
      146 
    </div> 
    <div>
      147 
    </div> 
    <div>
      148 
    </div> 
    <div>
      149 
    </div> 
    <div>
      150 
    </div> 
    <div>
      151 
    </div> 
    <div>
      152 
    </div> 
    <div>
      153 
    </div> 
    <div>
      154 
    </div> 
    <div>
      155 
    </div> 
    <div>
      156 
    </div> 
    <div>
      157 
    </div> 
    <div>
      158 
    </div> 
    <div>
      159 
    </div> 
    <div>
      160 
    </div> 
    <div>
      161 
    </div> 
    <div>
      162 
    </div> 
    <div>
      163 
    </div> 
    <div>
      164 
    </div> 
    <div>
      165 
    </div> 
    <div>
      166 
    </div> 
    <div>
      167 
    </div> 
    <div>
      168 
    </div> 
    <div>
      169 
    </div> 
    <div>
      170 
    </div> 
    <div>
      171 
    </div> 
    <div>
      172 
    </div> 
    <div>
      173 
    </div> 
    <div>
      174 
    </div> 
    <div>
      175 
    </div> 
    <div>
      176 
    </div> 
    <div>
      177 
    </div> 
    <div>
      178 
    </div> 
    <div>
      179 
    </div> 
    <div>
      180 
    </div> 
    <div>
      181 
    </div> 
    <div>
      182 
    </div> 
    <div>
      183 
    </div> 
    <div>
      184 
    </div> 
    <div>
      185 
    </div> 
    <div>
      186 
    </div> 
    <div>
      187 
    </div> 
    <div>
      188 
    </div> 
    <div>
      189 
    </div> 
    <div>
      190 
    </div> 
    <div>
      191 
    </div> 
    <div>
      192 
    </div> 
    <div>
      193 
    </div> 
    <div>
      194 
    </div> 
    <div>
      195 
    </div> 
    <div>
      196 
    </div> 
    <div>
      197 
    </div> 
    <div>
      198 
    </div> 
    <div>
      199 
    </div> 
    <div>
      200 
    </div> 
    <div>
      201 
    </div> 
    <div>
      202 
    </div> 
    <div>
      203 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>using</code> 
      <code>System;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Collections.Generic;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Net.Sockets;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>// 表示一个客户端</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>NetUserToken { </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//连接客户端的Socket</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>Socket socket;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//用于存放接收数据</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>byte[] buffer;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//每次接受和发送数据的大小</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>const</code> 
      <code>int</code> 
      <code>size = 1024;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//接收数据池</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>List&lt;byte&gt; receiveCache;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>bool</code> 
      <code>isReceiving;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//发送数据池</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>Queue&lt;byte[]&gt; sendCache;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>bool</code> 
      <code>isSending;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//接收到消息之后的回调</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>Action&lt;NetModel&gt; receiveCallBack;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>NetUserToken()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>buffer = </code> 
      <code>new</code> 
      <code>byte[size];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>receiveCache = </code> 
      <code>new</code> 
      <code>List&lt;byte&gt;();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>sendCache = </code> 
      <code>new</code> 
      <code>Queue&lt;byte[]&gt;();</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// 服务器接受客户端发送的消息</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// &lt; param name="data"&gt;Data.&lt; /param&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>Receive(byte[] data)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"接收到数据"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//将接收到的数据放入数据池中</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>receiveCache.AddRange(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//如果没在读数据</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(!isReceiving)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>isReceiving = </code> 
      <code>true</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>ReadData();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// 读取数据</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>ReadData()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>byte[] data = NetEncode.Decode(ref receiveCache);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//说明数据保存成功</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(data != null)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetModel item = NetSerilizer.DeSerialize(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(item.Message);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(receiveCallBack != null)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveCallBack(item);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//尾递归，继续读取数据</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>ReadData();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>else</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>isReceiving = </code> 
      <code>false</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// 服务器发送消息给客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>Send()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(sendCache.Count == 0) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>isSending = </code> 
      <code>false</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
      <code>; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>byte[] data = sendCache.Dequeue ();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code> 
      <code>count = data.Length / size;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code> 
      <code>len = size;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>for</code> 
      <code>(</code> 
      <code>int</code> 
      <code> i = 0; i &lt; count + 1; i++) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(i == count) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>len = data.Length - i * size;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>socket.Send (data, i * size, len, SocketFlags.None);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"发送成功!"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>Send ();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>WriteSendDate(byte[] data){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>sendCache.Enqueue(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(!isSending)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>isSending = </code> 
      <code>true</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>Send();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>using</code> 
      <code>System;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Collections.Generic;</code> 
     </div> 
     <div> 
      <code>using</code> 
      <code>System.Net.Sockets;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>// 表示一个客户端</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>NetUserToken { </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//连接客户端的Socket</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>Socket socket;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//用于存放接收数据</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>byte[] buffer;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//每次接受和发送数据的大小</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>const</code> 
      <code>int</code> 
      <code>size = 1024;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//接收数据池</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>List&lt;byte&gt; receiveCache;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>bool</code> 
      <code>isReceiving;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//发送数据池</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>Queue&lt;byte[]&gt; sendCache;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>bool</code> 
      <code>isSending;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>//接收到消息之后的回调</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>Action&lt;NetModel&gt; receiveCallBack;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>NetUserToken()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>buffer = </code> 
      <code>new</code> 
      <code>byte[size];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>receiveCache = </code> 
      <code>new</code> 
      <code>List&lt;byte&gt;();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>sendCache = </code> 
      <code>new</code> 
      <code>Queue&lt;byte[]&gt;();</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// 服务器接受客户端发送的消息</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// &lt; param name="data"&gt;Data.&lt; /param&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>Receive(byte[] data)</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"接收到数据"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//将接收到的数据放入数据池中</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>receiveCache.AddRange(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//如果没在读数据</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(!isReceiving)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>isReceiving = </code> 
      <code>true</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>ReadData();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// 读取数据</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>private</code> 
      <code>void</code> 
      <code>ReadData()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>byte[] data = NetEncode.Decode(ref receiveCache);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>//说明数据保存成功</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(data != null)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>NetModel item = NetSerilizer.DeSerialize(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(item.Message);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(receiveCallBack != null)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveCallBack(item);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>//尾递归，继续读取数据</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>ReadData();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>else</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>isReceiving = </code> 
      <code>false</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>// 服务器发送消息给客户端</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>Send()</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(sendCache.Count == 0) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>isSending = </code> 
      <code>false</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
      <code>; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>byte[] data = sendCache.Dequeue ();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code> 
      <code>count = data.Length / size;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code> 
      <code>len = size;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>for</code> 
      <code>(</code> 
      <code>int</code> 
      <code> i = 0; i &lt; count + 1; i++) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(i == count) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>len = data.Length - i * size;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>socket.Send (data, i * size, len, SocketFlags.None);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(</code> 
      <code>"发送成功!"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>Send ();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>} </code> 
      <code>catch</code> 
      <code>(Exception ex) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>UnityEngine.Debug.Log(ex.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>WriteSendDate(byte[] data){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>sendCache.Enqueue(data);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(!isSending)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>isSending = </code> 
      <code>true</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>Send();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

ProtoBuf网络传输到这里就全部完成了。

#### 您可能感兴趣的文章: ####

*  [python如何通过protobuf实现rpc][python_protobuf_rpc]
 *  [基于Protobuf C++ serialize到char\*的实现方法分析][Protobuf C_ serialize_char]
 *  [通过Java来测试JSON和Protocol Buffer的传输文件大小][Java_JSON_Protocol Buffer]
 *  [使用Protocol Buffers的C语言拓展提速Python程序的示例][Protocol Buffers_C_Python]
 *  [Protocol Buffer技术深入理解(C++实例)][Protocol Buffer_C]

**Tags：** [ProtoBuf][] [ ProtocolBuffer][ProtocolBuffer]

[http_www.jb51.net_article_82795.htm]: http://www.jb51.net/article/82795.htm
[Link 1]: http://www.jb51.net/article/82795.htm#
[python_protobuf_rpc]: http://www.jb51.net/article/80500.htm
[Protobuf C_ serialize_char]: http://www.jb51.net/article/36661.htm
[Java_JSON_Protocol Buffer]: http://www.jb51.net/article/77123.htm
[Protocol Buffers_C_Python]: http://www.jb51.net/article/64268.htm
[Protocol Buffer_C]: http://www.jb51.net/article/33030.htm
[ProtoBuf]: http://common.jb51.net/tag/ProtoBuf/1.htm
[ProtocolBuffer]: http://common.jb51.net/tag/ProtocolBuffer/1.htm