int headSize = 4;//包頭長度 固定4
  byte[] surplusBuffer = null;//不完整的數據包，即用戶自定義緩沖區(qū)
  /// <summary>
  /// 接收客戶端發(fā)來的數據
  /// </summary>
  /// <param name="connId">每個客戶的會話ID</param>
  /// <param name="bytes">緩沖區(qū)數據</param>
  /// <returns></returns>
  private HandleResult OnReceive(IntPtr connId, byte[] bytes) 
  {
   //bytes 為系統(tǒng)緩沖區(qū)數據
   //bytesRead為系統(tǒng)緩沖區(qū)長度
   int bytesRead = bytes.Length;
   if (bytesRead > 0)
   {
    if (surplusBuffer == null)//判斷是不是第一次接收，為空說是第一次
     surplusBuffer = bytes;//把系統(tǒng)緩沖區(qū)數據放在自定義緩沖區(qū)里面
    else
     surplusBuffer = surplusBuffer.Concat(bytes).ToArray();//拼接上一次剩余的包
    //已經完成讀取每個數據包長度
    int haveRead = 0;
    //這里totalLen的長度有可能大于緩沖區(qū)大小的(因為 這里的surplusBuffer 是系統(tǒng)緩沖區(qū)+不完整的數據包)
    int totalLen = surplusBuffer.Length;
    while (haveRead <= totalLen)
    {
     //如果在N此拆解后剩余的數據包連一個包頭的長度都不夠
     //說明是上次讀取N個完整數據包后，剩下的最后一個非完整的數據包
     if (totalLen - haveRead < headSize)
     {
      byte[] byteSub = new byte[totalLen - haveRead];
      //把剩下不夠一個完整的數據包存起來
      Buffer.BlockCopy(surplusBuffer, haveRead, byteSub, 0, totalLen - haveRead);
      surplusBuffer = byteSub;
      totalLen = 0;
      break;
     }
     //如果夠了一個完整包，則讀取包頭的數據
     byte[] headByte = new byte[headSize];
     Buffer.BlockCopy(surplusBuffer, haveRead, headByte, 0, headSize);//從緩沖區(qū)里讀取包頭的字節(jié)
     int bodySize = BitConverter.ToInt32(headByte, 0);//從包頭里面分析出包體的長度

     //這里的 haveRead=等于N個數據包的長度 從0開始；0,1,2,3....N
     //如果自定義緩沖區(qū)拆解N個包后的長度 大于 總長度，說最后一段數據不夠一個完整的包了，拆出來保存
     if (haveRead + headSize + bodySize > totalLen)
     {
      byte[] byteSub = new byte[totalLen - haveRead];
      Buffer.BlockCopy(surplusBuffer, haveRead, byteSub, 0, totalLen - haveRead);
      surplusBuffer = byteSub;
      break;
     }
     else
     {
      //挨個分解每個包，解析成實際文字
      String strc = Encoding.UTF8.GetString(surplusBuffer, haveRead + headSize, bodySize);
      //AddMsg(string.Format(" > [OnReceive] -> {0}", strc));
      //依次累加當前的數據包的長度
      haveRead = haveRead + headSize + bodySize;
      if (headSize + bodySize == bytesRead)//如果當前接收的數據包長度正好等于緩沖區(qū)長度，則待拼接的不規(guī)則數據長度歸0
      {
       surplusBuffer = null;//設置空 回到原始狀態(tài)
       totalLen = 0;//清0
      }
     }
    }
   }
   return HandleResult.Ok;
  }

//線程安全的字典
  ConcurrentDictionary<IntPtr, byte[]> dic = new ConcurrentDictionary<IntPtr, byte[]>();
  int headSize = 4;//包頭長度 固定4
  /// <summary>
  /// 接收客戶端發(fā)來的數據
  /// </summary>
  /// <param name="connId">每個客戶的會話ID</param>
  /// <param name="bytes">緩沖區(qū)數據</param>
  /// <returns></returns>
  private HandleResult OnReceive(IntPtr connId, byte[] bytes) 
  {
   //bytes 為系統(tǒng)緩沖區(qū)數據
   //bytesRead為系統(tǒng)緩沖區(qū)長度
   int bytesRead = bytes.Length;
   if (bytesRead > 0)
   {
    byte[] surplusBuffer = null;
    if (dic.TryGetValue(connId, out surplusBuffer))
    {
     byte[] curBuffer = surplusBuffer.Concat(bytes).ToArray();//拼接上一次剩余的包
     //更新會話ID 的最新字節(jié)
     dic.TryUpdate(connId, curBuffer, surplusBuffer);
     surplusBuffer = curBuffer;//同步
    }
    else
    {
     //添加會話ID的bytes
     dic.TryAdd(connId, bytes);
     surplusBuffer = bytes;//同步
    }

    //已經完成讀取每個數據包長度
    int haveRead = 0;
    //這里totalLen的長度有可能大于緩沖區(qū)大小的(因為 這里的surplusBuffer 是系統(tǒng)緩沖區(qū)+不完整的數據包)
    int totalLen = surplusBuffer.Length;
    while (haveRead <= totalLen)
    {
     //如果在N此拆解后剩余的數據包連一個包頭的長度都不夠
     //說明是上次讀取N個完整數據包后，剩下的最后一個非完整的數據包
     if (totalLen - haveRead < headSize)
     {
      byte[] byteSub = new byte[totalLen - haveRead];
      //把剩下不夠一個完整的數據包存起來
      Buffer.BlockCopy(surplusBuffer, haveRead, byteSub, 0, totalLen - haveRead);
      dic.TryUpdate(connId, byteSub, surplusBuffer);
      surplusBuffer = byteSub;
      totalLen = 0;
      break;
     }
     //如果夠了一個完整包，則讀取包頭的數據
     byte[] headByte = new byte[headSize];
     Buffer.BlockCopy(surplusBuffer, haveRead, headByte, 0, headSize);//從緩沖區(qū)里讀取包頭的字節(jié)
     int bodySize = BitConverter.ToInt32(headByte, 0);//從包頭里面分析出包體的長度

     //這里的 haveRead=等于N個數據包的長度 從0開始；0,1,2,3....N
     //如果自定義緩沖區(qū)拆解N個包后的長度 大于 總長度，說最后一段數據不夠一個完整的包了，拆出來保存
     if (haveRead + headSize + bodySize > totalLen)
     {
      byte[] byteSub = new byte[totalLen - haveRead];
      Buffer.BlockCopy(surplusBuffer, haveRead, byteSub, 0, totalLen - haveRead);
      dic.TryUpdate(connId, byteSub, surplusBuffer);
      surplusBuffer = byteSub;
      break;
     }
     else
     {
      //挨個分解每個包，解析成實際文字
      String strc = Encoding.UTF8.GetString(surplusBuffer, haveRead + headSize, bodySize);
      AddMsg(string.Format(" > {0}[OnReceive] -> {1}", connId, strc));
      //依次累加當前的數據包的長度
      haveRead = haveRead + headSize + bodySize;
      if (headSize + bodySize == bytesRead)//如果當前接收的數據包長度正好等于緩沖區(qū)長度，則待拼接的不規(guī)則數據長度歸0
      {
       byte[] xbtye=null;
       dic.TryRemove(connId, out xbtye);
       surplusBuffer = null;//設置空 回到原始狀態(tài)
       totalLen = 0;//清0
      }
     }
    }
   }
   return HandleResult.Ok;
  }