參考：http://wenku.baidu.com/view/cc833787bceb19e8b8f6ba53.html

將接收到得多個數據包

2011-1-26 10:45:24tmp------->F0 F1 00 00 47 57 00 01 F2 F3 00 00

2011-1-26 10:45:24tmp------->00 00 00 00 00 00 00 00 00 00 00 00 00 03 25 00 00 00 10 00

2011-1-26 10:45:24tmp------->00 00 00 00 00 00 00 00 00 00 00 00 02 73 00 00 00 00 00 00

2011-1-26 10:45:24tmp------->00 00 00 00 31 FE FF

數據組裝成一個包

2011-1-26 10:45:24tmpAsync-->F0 F1 00 00 47 57 00 01 F2 F3 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 03 25 00 00 00 10 00 00 00 00 00 00 00 00 00 00 00 00 00 02 73 00 00 00 00 00 00 00 00 00 00 31 FE FF

1、創建緩存接收數據的類

using System; using System.Collections.Generic; /// <summary> /// 創建數據接收隊列 /// CRecvBuf是一個用於緩存接收數據的類，利用List類來實現。 /// 在創建該類的實例時，要制定參數maxLength,表示隊列的總容量。 /// 每當接收到一段數據，就調用Add方法將收到的數據添加到隊列中， /// Add方法中判斷添加數據后字節數是否超過maxLength，並將超過部分從隊首刪除。 /// </summary> class CRecvBuf { public List<byte> li; public int maxLength; public CRecvBuf(int maxLength) { li = new List<byte>(); this.maxLength = maxLength; } public void Add(byte[] b) { if (b.Length > maxLength) throw new Exception("接收到得數據量超出緩沖區長度"); li.AddRange(b); if (li.Count > maxLength) li.RemoveRange(0, li.Count - maxLength); } //在判斷數據包頭包尾正確后，移除數據幀，防止數據包被多次解析，造成重復插入數據庫引起的錯誤 public void RemoveBuf(int p) { if (li.Count >= 59) { li.RemoveRange(p, 59); } } }

2、

在Form_Load中添加事件注冊

recvbuf = new CRecvBuf(120);//隊列長度為數據幀長度的兩倍 //添加事件注冊 comm.DataReceived += comm_DataReceived;

3、為接收事件處理

void comm_DataReceived(object sender, SerialDataReceivedEventArgs e) { if (ComClosing) { return; } //如果正在關閉，忽略操作，直接返回，盡快的完成串口監聽線程的一次循環 try { Listening = true; //設置標記，說明我已經開始處理數據， 一會兒要使用系統UI的。 /************************************* * 以下為按字節讀取第一個字節數據 * 再讀取剩余字節數據 * 將讀取數據添加到隊列隊尾 * 提取完整的數據幀 * （備注：當無數據返回時,會出現“索引index要求非負數。”的錯誤） * *********************************/ byte firstbyte; byte[] tmp; comm.ReadTimeout = 5000;//5秒內沒收到數據將捕獲異常 //received_count += comm.BytesToRead;//增加接收計數 firstbyte = (byte)comm.ReadByte();//讀取第一個字節，程序在這里堵塞 tmp = new byte[comm.BytesToRead + 1]; tmp[0] = firstbyte; comm.Read(tmp, 1, tmp.Length - 1);//讀取剩余字節到tmp數組中 this.Invoke((EventHandler)(delegate { txGet.AppendText("/r/n" + System.DateTime.Now.ToString() + "tmp------->" + CCheck.BinaryToHexString(tmp)); })); recvbuf.Add(tmp);//添加接收數據到隊列 //提取一個完整的數據幀 tmp = getBlock(recvbuf.li); //判斷數據幀是否為空。獲取到一個數據包數據時，開始解析 this.Invoke((EventHandler)(delegate { if (tmp != null) { txGet.AppendText("/r/n" + System.DateTime.Now.ToString() + "tmp!=null->" + CCheck.BinaryToHexString(tmp)); //不為空,且為一個數據幀時，開始解析數據幀 if (tmp.Length >= 59) { txGet.AppendText("/r/n" + System.DateTime.Now.ToString() + "tmpAsync-->" + CCheck.BinaryToHexString(tmp)); //數據解析 // AsyncPacket(tmp); } } else txGet.AppendText("/r/n" + System.DateTime.Now.ToString() + "tmp==null->" + "<--"); })); } catch (Exception ex) { this.Invoke((EventHandler)(delegate { txGet.AppendText("/r/n" + System.DateTime.Now.ToString() + "接收錯誤-->" + ex.Message); })); //log.ConnError("數據接收出錯，詳細為：" + ex.Message); } finally { Listening = false;//我用完了，ui可以關閉串口了。 } }

4、進行數據幀提取：（本程序數據包長度為59字節）

#region /// <summary> /// 從數據接收隊列中獲取完整數據幀 /// </summary> /// <param name="li"></param> /// <returns></returns> private byte[] getBlock(List<byte> li) { byte[] b = null; if (li.Count < 59) return b;//總長度不足59字節 int p = li.Count; //從右向左查找起始標志F0F1,獲取下標 while ((p = li.LastIndexOf(0xF0, p - 1)) != -1) if (li.Count >= p + 59) if (li[p + 1] == 0xF1 && li[p + 57] == 0xFE && li[p + 58] == 0xFF) break;//已經找到，結束循環 if (p != -1)//p為數據塊的起始位置 { b = new byte[59]; li.CopyTo(p, b, 0, 59);//拷貝數據塊到b數組 //移除數據接收隊列中的數據幀 recvbuf.RemoveBuf(p); } return b; } public class CCheck { //字節數組轉換為十六進制字符串 public static string BinaryToHexString(byte[] buff) { StringBuilder tmp = new StringBuilder(); for (int i = 0; i < buff.Length; i++) tmp.Append(buff[i].ToString("X2") + " "); return tmp.ToString().Trim(); } } #endregion