C# client 与java netty 服务端的简单通信，客户端采用Unity。

短命女 2022-08-27 02:28 234阅读 0赞

## C\# client 与java netty 服务端的简单通信，客户端采用Unity。 ##

近日根据官方提供的通信例子自己写了一个关于Unity(C\#)和后台通信的类，拿出来和大家分享一下。

具体请参考：

1.java服务端用的apach.mina框架搭建。java服务端请参考：[http://blog.9tech.cn/?c=site&m=article&id=548][http_blog.9tech.cn_c_site_m_article_id_548]

2.C\#环境：.NET framework 2.0

3.C\#帮组文档，及Socket注解：[http://msdn.microsoft.com/zh-cn/library/system.net.sockets.socket(v=vs.85).aspx][http_msdn.microsoft.com_zh-cn_library_system.net.sockets.socket_v_vs.85_.aspx]

4.官方例子：[http://msdn.microsoft.com/zh-cn/library/bew39x2a(v=VS.85).aspx\#CommunityContent][http_msdn.microsoft.com_zh-cn_library_bew39x2a_v_VS.85_.aspx_CommunityContent]

个人觉得，最难的地方在与以下几个地方：

**1.封装数据，和后台的编解码格式保持一致**

封装数据，其实就是一个前后台约定好一个通信格式。比如：获得所以数据后并写入字节数组后，在吧这个字节数组的长度读出来（4个字节的整形数据），再封装进一个字节数组中。

所以最终的数据字节数组内容是：4个字节的数据长度+实际数据的字节数组。

当然数据的加密加压可以在吧实际数据存入字节数组后就进行，那么发送的长度就是加密加压后的数据长度了。

实现方法：

<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> </td> 
   <td> 
    <div> 
     <div> 
      <code>String&nbsp;message&nbsp;=&nbsp;</code> 
      <code>"shit&nbsp;"</code> 
      <code>;</code> 
      <code>//5个字节</code> 
     </div> 
     <div> 
      <code>byte</code> 
      <code>[]&nbsp;bytes&nbsp;=&nbsp;Encoding.UTF8.GetBytes(message);</code> 
      <code>//未加密加压的实际数据</code> 
     </div> 
     <div> 
      <code>byte</code> 
      <code>[]&nbsp;prefixBytes&nbsp;=BitConverter.GetBytes(bytes.Length);</code> 
      <code>//数据长度</code> 
     </div> 
     <div> 
      <code>Array.Reverse(prefixBytes);</code> 
     </div> 
     <div> 
      <code>byte</code> 
      <code>[]&nbsp;sendBytes&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[bytes.Length&nbsp;+&nbsp;4];</code> 
     </div> 
     <div> 
      <code>//吧字节数组合并到sendBytes&nbsp;</code> 
     </div> 
     <div> 
      <code>System.Buffer.BlockCopy(prefixBytes&nbsp;,0,sendBytes&nbsp;,0,4);</code> 
     </div> 
     <div> 
      <code>System.Buffer.BlockCopy(bytes,0,sendBytes&nbsp;,4,bytes.Length);</code> 
     </div> 
     <div> 
      <code>//合并完毕，就可以使用socket吧sendBytes发送出去了，后台也是有同样的格式解码就可以了。</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

**2.异步通信的线程管理**

异步通信的线程安全一直是一个难点，它不像ActionScript那样，建立通信连接后注册事件用来侦听即可。但是在C\#中就必须让线程等待当前的异步操作完成后才可以继续向下执行。C\#异步通信中可以使用ManualResetEvent类来处理这类问题。当需要暂停执行后续代码以完成异步操作时。使用ManualResetEvent的WaitOne();方法来阻塞这个线程（类似与java的ReentrantLock类），但是必须在异步操作完成后使线程恢复，否则就会出现线程被锁死的情况。使用ManualResetEvent的Set()方法即可。

实现方法：

ManualResetEvent类的帮组文档及例子：[http://msdn.microsoft.com/zh-cn/library/system.threading.manualresetevent\_members(v=vs.85).aspx][http_msdn.microsoft.com_zh-cn_library_system.threading.manualresetevent_members_v_vs.85_.aspx]

**3.关于数据的压缩，和解压.**

对于数据的压缩和解压可以采用ICSharpCode.SharpZipLib这个动态链接库。下载地址：[http://www.icsharpcode.net/opensource/sharpziplib/][http_www.icsharpcode.net_opensource_sharpziplib]

下载后再MonoDevelop里倒入引用就可以了，位置：Project->Edit References..

using ICSharpCode.SharpZipLib.Zip;

然后在代码里就可以倒入类了

参考:[http://blog.sina.com.cn/s/blog\_62fda93c0101d51j.html][http_blog.sina.com.cn_s_blog_62fda93c0101d51j.html]

**4.接收和读取数据的操作**

在接受服务端发送的数据时，也根据同样的格式进行解读；先读取4个字节的数据长度，再跟进这个长度得到实际的数据，最后在解密和解压就可以得到最终的数据了。

但是在这个操作过程中，会出现一些意想不到的麻烦。

大致流程是：

采取分段读取的方式，第一次只读取4个字节的长度信息。

取得长度后，根据设置的每次分段读取数据长度来读取，知道所得的数据和总长度相同；

每次分段读取的数据的长度不一定都是设置的长度，所以将每次读取的数据写入内存流MemoryStream类中。特别重要的每次操作MemoryStream类时注意设置它的Position位置，不然会出现你本来已经成功的存入了数据，但是由于Position的原因没有找准需要取出或者存入数据的准确位置而读取数据失败。

详细代码如下：

<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> </td> 
   <td> 
    <div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>UnityEngine;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System.Collections;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System.Collections.Generic;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System.IO;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System.Threading;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System.Text;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System.Net;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>System.Net.Sockets;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>ICSharpCode.SharpZipLib.Zip;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>ICSharpCode.SharpZipLib.GZip;</code> 
     </div> 
     <div> 
      <code>using</code>&nbsp; 
      <code>LitJson;</code> 
     </div> 
     <div> 
      <code>/**</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>*&nbsp;连接对象</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>*&nbsp;@author&nbsp;duwei</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>*&nbsp;@version&nbsp;1.0.0</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>*&nbsp;build&nbsp;time&nbsp;:2013.11.7</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>*&nbsp;*/</code> 
     </div> 
     <div> 
      <code>public</code>&nbsp; 
      <code>class</code>&nbsp; 
      <code>BufferConnection{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>Socket&nbsp;socket&nbsp;=&nbsp;</code> 
      <code>null</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>const</code>&nbsp; 
      <code>int</code>&nbsp; 
      <code>prefixSize&nbsp;=&nbsp;4;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>String&nbsp;ip&nbsp;=&nbsp;</code> 
      <code>"192.168.1.105"</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>int</code>&nbsp; 
      <code>port&nbsp;=&nbsp;8005;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code>&nbsp; 
      <code>static</code>&nbsp; 
      <code>ManualResetEvent&nbsp;connectDone&nbsp;=&nbsp;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>ManualResetEvent(</code> 
      <code>false</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code>&nbsp; 
      <code>static</code>&nbsp; 
      <code>ManualResetEvent&nbsp;sendDone&nbsp;=&nbsp;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>ManualResetEvent(</code> 
      <code>false</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code>&nbsp; 
      <code>static</code>&nbsp; 
      <code>ManualResetEvent&nbsp;receiveDone&nbsp;=&nbsp;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>ManualResetEvent(</code> 
      <code>false</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>BufferConnection(){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//&nbsp;State&nbsp;object&nbsp;for&nbsp;receiving&nbsp;data&nbsp;from&nbsp;remote&nbsp;device.</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>class</code>&nbsp; 
      <code>StateObject&nbsp;{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//&nbsp;Client&nbsp;socket.</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>Socket&nbsp;workSocket&nbsp;=&nbsp;</code> 
      <code>null</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//&nbsp;Size&nbsp;of&nbsp;receive&nbsp;buffer.</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>const</code>&nbsp; 
      <code>int</code>&nbsp; 
      <code>BufferSize&nbsp;=&nbsp;1024;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//&nbsp;Receive&nbsp;buffer.</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>byte</code> 
      <code>[]&nbsp;buffer&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[BufferSize];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>/**开始建立socket连接*/</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>startConnect(){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Debug.Log(</code> 
      <code>"starting&nbsp;connection..."</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>IPAddress&nbsp;ipd&nbsp;=&nbsp;IPAddress.Parse(ip);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>EndPoint&nbsp;endPoint&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>IPEndPoint(ipd,port);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>socket&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>socket.BeginConnect(endPoint,</code> 
      <code>new</code>&nbsp; 
      <code>AsyncCallback(connectCallback),socket);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>connectDone.WaitOne();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receive(socket);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code> 
      <code>//receiveDone.WaitOne();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
      <code>catch</code> 
      <code>(Exception&nbsp;e){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Console.WriteLine(e.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>connectCallback(IAsyncResult&nbsp;ar){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Socket&nbsp;backSocket&nbsp;=&nbsp;(Socket)ar.AsyncState;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>backSocket.EndConnect(ar);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>connectDone.Set();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Debug.Log(</code> 
      <code>"on&nbsp;connected"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
      <code>catch</code> 
      <code>(Exception&nbsp;e){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Console.WriteLine(e.ToString());&nbsp;&nbsp;&nbsp; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}&nbsp;&nbsp; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>/**发送数据，目前只支持&nbsp;String&nbsp;类型数据*/</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>send(Socket&nbsp;client,String&nbsp;msg){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//封装数据</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code> 
      <code>[]&nbsp;byteData&nbsp;=&nbsp;Encoding.UTF8.GetBytes(msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code> 
      <code>[]&nbsp;sendData&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[byteData.Length&nbsp;+&nbsp;prefixSize];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code> 
      <code>[]&nbsp;sizeData&nbsp;=&nbsp;BitConverter.GetBytes(byteData.Length);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//反转</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code> 
      <code>Array.Reverse(sizeData);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//合并</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>System.Buffer.BlockCopy(sizeData,0,sendData,0,prefixSize);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>System.Buffer.BlockCopy(byteData,0,sendData,prefixSize,byteData.Length);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//socket.Send(sendData);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>client.BeginSend(sendData,0,sendData.Length,0,</code> 
      <code>new</code>&nbsp; 
      <code>AsyncCallback(sendCallback),client);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Debug.Log(</code> 
      <code>"data&nbsp;send&nbsp;finished,&nbsp;data&nbsp;size:"</code> 
      <code>+sendData.Length);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
      <code>catch</code> 
      <code>(Exception&nbsp;e){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Console.WriteLine(e.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>send(String&nbsp;msg){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(socket&nbsp;!=&nbsp;</code> 
      <code>null</code> 
      <code>){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>send(socket,msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>sendDone.WaitOne();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>sendCallback(IAsyncResult&nbsp;ar){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Socket&nbsp;socket&nbsp;=&nbsp;(Socket)ar.AsyncState;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(ar.IsCompleted){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code>&nbsp; 
      <code>endPoint&nbsp;=&nbsp;socket.EndSend(ar);&nbsp;&nbsp; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Debug.Log(</code> 
      <code>"send&nbsp;data&nbsp;finished&nbsp;endpoint:&nbsp;"</code> 
      <code>+endPoint);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>sendDone.Set();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
      <code>catch</code> 
      <code>(Exception&nbsp;e){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Console.WriteLine(e.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>receive(Socket&nbsp;socket){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{&nbsp;&nbsp;&nbsp; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>StateObject&nbsp;so&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>StateObject();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>so.workSocket&nbsp;=&nbsp;socket;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//第一次读取数据的总长度</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>socket.BeginReceive(so.buffer,0,prefixSize,0,</code> 
      <code>new</code>&nbsp; 
      <code>AsyncCallback(receivedCallback),so);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//测试用：数据在1024以内的数据，一次性读取出来</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//socket.BeginReceive(so.buffer,0,StateObject.BufferSize,0,new&nbsp;AsyncCallback(simpleCallback),so);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
      <code>catch</code> 
      <code>(Exception&nbsp;e){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Console.WriteLine(e.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>simpleCallback(IAsyncResult&nbsp;ar){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>StateObject&nbsp;so&nbsp;=&nbsp;(StateObject)ar.AsyncState; &nbsp;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Socket&nbsp;socket&nbsp;=&nbsp;so.workSocket;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code> 
      <code>[]&nbsp;presixBytes&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[prefixSize];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code>&nbsp; 
      <code>presix&nbsp;=&nbsp;0;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Buffer.BlockCopy(so.buffer,0,presixBytes,0,prefixSize);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Array.Reverse(presixBytes);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>presix&nbsp;=&nbsp;BitConverter.ToInt32(presixBytes,0);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(presix&nbsp;&lt;=&nbsp;0){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}&nbsp;&nbsp; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code>&nbsp; 
      <code>[]&nbsp;datas&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[presix];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Buffer.BlockCopy(so.buffer,prefixSize,datas,0,datas.Length);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>String&nbsp;str&nbsp;=&nbsp;Encoding.UTF8.GetString(datas);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Debug.Log(</code> 
      <code>"received&nbsp;message&nbsp;:"</code> 
      <code>+str);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>MemoryStream&nbsp;receiveData&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>MemoryStream();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code>&nbsp; 
      <code>bool</code>&nbsp; 
      <code>isPresix&nbsp;=&nbsp;</code> 
      <code>true</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>int</code>&nbsp; 
      <code>curPrefix&nbsp;=&nbsp;0;</code> 
      <code>//需要读取的数据总长度</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>void</code>&nbsp; 
      <code>receivedCallback(IAsyncResult&nbsp;ar){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>try</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>StateObject&nbsp;so&nbsp;=&nbsp;(StateObject)ar.AsyncState;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Socket&nbsp;client&nbsp;=&nbsp;so.workSocket;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code>&nbsp; 
      <code>readSize&nbsp;=&nbsp;client.EndReceive&nbsp;(ar);</code> 
      <code>//结束读取，返回已读取的缓冲区里的字节数组长度</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//将每次读取的数据，写入内存流里</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveData.Write(so.buffer,0,readSize);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveData.Position&nbsp;=&nbsp;0;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//读取前置长度，只读取一次</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>((</code> 
      <code>int</code> 
      <code>)receiveData.Length&nbsp;&gt;=&nbsp;prefixSize&nbsp;&amp;&amp;&nbsp;isPresix){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code> 
      <code>[]&nbsp;presixBytes&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[prefixSize];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveData.Read(presixBytes,0,prefixSize);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Array.Reverse(presixBytes);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>curPrefix&nbsp;=&nbsp;BitConverter.ToInt32(presixBytes,0);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>isPresix&nbsp;=&nbsp;</code> 
      <code>false</code> 
      <code>;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(receiveData.Length&nbsp;-&nbsp;(</code> 
      <code>long</code> 
      <code>)prefixSize&nbsp;&lt;&nbsp;(</code> 
      <code>long</code> 
      <code>)curPrefix){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//如果数据没有读取完毕，调整Position到最后，接着读取。</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveData.Position&nbsp;=&nbsp;receiveData.Length;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
      <code>else</code> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//如果内存流中的实际数字总长度符合要求，则说明数据已经全部读取完毕。</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//将position位置调整到第4个节点，开始准备读取数据。</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveData.Position&nbsp;=&nbsp;prefixSize;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//读取数据</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code> 
      <code>[]&nbsp;datas&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[curPrefix];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>receiveData.Read(datas,0,datas.Length);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//有压缩的话需要先解压，然后在操作。</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>byte</code> 
      <code>[]&nbsp;finallyBytes&nbsp;=&nbsp;decompress(datas);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>String&nbsp;str&nbsp;=&nbsp;Encoding.UTF8.GetString(finallyBytes);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Debug.Log(</code> 
      <code>"the&nbsp;finally&nbsp;message&nbsp;is&nbsp;:&nbsp;"</code> 
      <code>+str);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//重复读取，每次读取1024个字节数据</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>client.BeginReceive(so.buffer,0,StateObject.BufferSize,0,</code> 
      <code>new</code>&nbsp; 
      <code>AsyncCallback(receivedCallback),&nbsp;so);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
      <code>catch</code> 
      <code>(Exception&nbsp;e){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Console.WriteLine(e.ToString());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code>&nbsp; 
      <code>byte</code>&nbsp; 
      <code>[]&nbsp;temp&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>byte</code> 
      <code>[1024];</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>//解压</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code>&nbsp; 
      <code>byte</code> 
      <code>[]&nbsp;decompress(</code> 
      <code>byte</code> 
      <code>[]&nbsp;bytes){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>MemoryStream&nbsp;memory&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>MemoryStream&nbsp;();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>ICSharpCode.SharpZipLib.Zip.Compression.Inflater&nbsp;inf&nbsp;=&nbsp;</code> 
      <code>new</code>&nbsp; 
      <code>ICSharpCode.SharpZipLib.Zip.Compression.Inflater&nbsp;();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>inf.SetInput&nbsp;(bytes);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>while</code>&nbsp; 
      <code>(!inf.IsFinished)&nbsp;{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>int</code>&nbsp; 
      <code>extracted&nbsp;=&nbsp;inf.Inflate&nbsp;(temp);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>if</code>&nbsp; 
      <code>(extracted&nbsp;&gt;&nbsp;0)&nbsp;{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>memory.Write&nbsp;(temp,&nbsp;0,&nbsp;extracted);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}&nbsp;</code> 
      <code>else</code>&nbsp; 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>break</code> 
      <code>;&nbsp;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code>&nbsp; 
      <code>memory.ToArray&nbsp;();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

[http_blog.9tech.cn_c_site_m_article_id_548]: http://blog.9tech.cn/?c=site&m=article&id=548
[http_msdn.microsoft.com_zh-cn_library_system.net.sockets.socket_v_vs.85_.aspx]: http://msdn.microsoft.com/zh-cn/library/system.net.sockets.socket%28v=vs.85%29.aspx
[http_msdn.microsoft.com_zh-cn_library_bew39x2a_v_VS.85_.aspx_CommunityContent]: http://msdn.microsoft.com/zh-cn/library/bew39x2a%28v=VS.85%29.aspx#CommunityContent
[http_msdn.microsoft.com_zh-cn_library_system.threading.manualresetevent_members_v_vs.85_.aspx]: http://msdn.microsoft.com/zh-cn/library/system.threading.manualresetevent_members%28v=vs.85%29.aspx
[http_www.icsharpcode.net_opensource_sharpziplib]: http://www.icsharpcode.net/opensource/sharpziplib/
[http_blog.sina.com.cn_s_blog_62fda93c0101d51j.html]: http://blog.sina.com.cn/s/blog_62fda93c0101d51j.html