【轉】Socket接收字節緩衝區

原創本拉燈

2014年04月16日 10:06:55

• 標籤：
• socket /
• 數據包

• 4448

        咱們接收Socket字節流數據通常都會定義一個數據包協議( 協議號,長度,內容),因爲Socket接收數據是連續的，對方發兩個包過來，Socket的 Recive事件有可能只觸發一次或觸發三次，也就是你們聽到的粘包，爲解決這個粘包，因此咱們必要建一個字節緩衝區，將全部的接收到的字節流全放到這個緩衝區內 由這個緩衝區來分隔每一個數據包的內容。

        這份代碼也是爲論壇某我的解決串口接收數據包時而寫的。很少說了上代碼：

/// <summary>
   /// 字節緩衝器
   /// </summary>
   public class ByteQueue
   {
       private List<byte> m_buffer = new List<byte>();
       public bool Find()
       {
           if (m_buffer.Count == 0)
               return false;
           int HeadIndex = m_buffer.FindIndex(o => o == 0xAA);

           if (HeadIndex == -1)
           {
               m_buffer.Clear();
               return false; //沒找到AA
           }

           else if (HeadIndex != 0) //不爲開頭移掉以前的字節
           {
               if (HeadIndex > 1)
                   m_buffer.RemoveRange(0, HeadIndex);
           }

           int length= GetLength();

           if (m_buffer.Count <length)
           {
               return false;
           }

           int TailIndex = m_buffer.FindIndex(o => o == 0x55); //查找55的位置

           if (TailIndex == -1)
           {
               //這一步爲防止連發一個AA開頭的包後，沒發55，而又發了一個AA
               int head = m_buffer.FindLastIndex(o => o == 0xAA);
               if (head > -1)
               {
                   m_buffer.RemoveRange(0, head);
               }
               return false;
           }
           else if (TailIndex + 1 != length) //計算包尾是否與包長度相等
           {
               m_buffer.RemoveRange(0, TailIndex);
               return false;
           }

           return true;
       }

       /// <summary>
       /// 命令類型
       /// </summary>
       /// <returns></returns>
       public byte Cmd()
       {
           if (m_buffer.Count >= 2)
           {
               return m_buffer[1];
           }
           return 0;
       }

       /// <summary>
       /// 序號
       /// </summary>
       /// <returns></returns>
       public byte Number()
       {
           if (m_buffer.Count >= 3)
           {
               return m_buffer[2];
           }
           return 0;
       }

       /// <summary>
       /// 包長度
       /// </summary>
       /// <returns></returns>
       public int GetLength()
       {
           int len = 5;//AA 命令類型 序號 校驗和 55
           if (m_buffer.Count >= 3)
           {
               switch (m_buffer[2]) //第三字節爲序號
               {
                   case 0x00: //序號
                       return len + 16;
                   case 0x01: //序號
                       return len + 10;
                   case 0x02: //序號
                       return len + 12;
               }
           }
           return 0;
       }
       /// <summary>
       /// 提取數據
       /// </summary>
       public void Dequeue(byte[] buffer, int offset,int size)
       {
           m_buffer.CopyTo(0,buffer,offset,size);
           m_buffer.RemoveRange(0, size);
       }

       /// <summary>
       /// 隊列數據
       /// </summary>
       /// <param name="buffer"></param>
       public void Enqueue(byte[] buffer)
       {
           m_buffer.AddRange(buffer);
       }
   }

 調用列子：

private ByteQueue queue = new ByteQueue();
private void serialPort1_DataReceived(object sender, SerialDataReceivedEventArgs e)
       {
           int len = serialPort1.BytesToRead;
           if (len > 0)
           {
               byte[] temp = new byte[len];
               serialPort1.Read(temp, 0, len);
               queue.Enqueue(temp);
               while (queue.Find()) //while可處理同時接收到多個AA ... 55 ,AA...55的包
               {
                   int length = queue.GetLength();
                   byte[] readBuffer = new byte[len];
                   queue.Dequeue(readBuffer, 0, length);
                   OnReceiveData(readBuffer); //<這裏本身寫一個委託吧就OK了
               }

           }

       }

上面的字節接收容器是用List來處理爲方便進出字節後移除整個數據包的字節數據，固然更高效的應用byte[] 數組做成環形緩衝會好不少相對應的寫法也會難一些，