介绍

目标

代码实现

        private void serialPort1_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            if (isRxShow == false) return;
            // 1,需要读取有效的数据 BytesToRead
            byte[] dataTemp = new byte[serialPort1.BytesToRead];
            serialPort1.Read(dataTemp,0,dataTemp.Length);

            reciveBuffer.AddRange(dataTemp);

            reciveCount += dataTemp.Length;

            this.Invoke(new EventHandler(delegate
            {
                // 显示接收数据的长度
                recivecount_tssl.Text = reciveCount.ToString();
                if (startData_chb.Checked == false)
                {
                    if (!recivehex_chb.Checked)
                    {
                        // 2, 编码格式的选择
                        string str = Encoding.GetEncoding("gb2312").GetString(dataTemp);
                        // 3，0x00 -> \0 结束 不会显示
                        str = str.Replace("\0", "\\0");

                        recive_rtb.AppendText(str);

                        // recive_rtb.AppendText(Encoding.GetEncoding("gb2312").GetString(dataTemp).Replace("\0", "\\0"));
                    }
                    else
                    {
                        //  十六进制是选中的状态下
                        recive_rtb.AppendText(Transform.ToHexString(dataTemp, " "));
                    }
                }
                else
                {
                    // 解析数据 queue

                    foreach (byte item in dataTemp)
                    {
                        // 入列
                        bufferQueue.Enqueue(item);
                    }

                    // 解析获取帧头
                    if (isHeadRecive == false)
                    {

                        foreach (byte item in bufferQueue.ToArray())
                        {
                            if (item != 0x7f)
                            {
                                // 出列
                                bufferQueue.Dequeue();
                                Console.WriteLine("not 0x7f, Dequeue !!");
                            }
                            else
                            {
                                // get 0x7f from bufferQueue
                                isHeadRecive = true;
                                Console.WriteLine("0x7f is recived !!");
                                break;
                            }
                        }
                    }

                    if (isHeadRecive == true)
                    {
                        // 判断有数据帧长度
                        if (bufferQueue.Count >= 2)
                        {
                            Console.WriteLine(DateTime.Now.ToLongTimeString());
                            Console.WriteLine($"show the data in bufferQueue{Transform.ToHexString(bufferQueue.ToArray())}");
                            Console.WriteLine($"frame lenth ={String.Format("{0:X2}", bufferQueue.ToArray()[1])}");
                            frameLenth = bufferQueue.ToArray()[1];
                            // 一帧完整的数据长度判断，不代表数据是正确的
                            if(bufferQueue.Count>=1+1+frameLenth+2)
                            {
                                byte[] frameBuffer = new byte[1 + 1 + frameLenth + 2];
                                Array.Copy(bufferQueue.ToArray(), 0, frameBuffer, 0, frameBuffer.Length);
                                if(crc_chech(frameBuffer))
                                {
                                    Console.WriteLine("frame is check ok,pick it");
                                    data_txb.Text = Transform.ToHexString(frameBuffer);
                                    data1_txb.Text = String.Format("{0:X2}", frameBuffer[2]);
                                    data2_txb.Text = String.Format("{0:X2}", frameBuffer[3]);
                                    data3_txb.Text = String.Format("{0:X2}", frameBuffer[4]);
                                    data4_txb.Text = String.Format("{0:X2}", frameBuffer[5]);

                                }
                                else
                                {
                                    // 无效数据
                                    Console.WriteLine("bad frame, drop it");
                                    
                                }


                                for(int i=0; i<1 + 1+frameLenth+2;i++)
                                {
                                    bufferQueue.Dequeue();
                                }

                                isHeadRecive = false;
                            }
                        }
                        //接续接收数据
                    }
                }
            }));
        }

   private bool crc_chech(byte[] frameBuffer)
   {
       /*大端模式: 是指数据的高字节保存在内存的低地址中，
        * 而数据的低字节保存在内存的高地址中，这样的存储
        * 模式有点儿类似于把数据当作字符串顺序处理：地址
        * 由小向大增加，而数据从高位往低位放；这和我们的
        * 阅读习惯一致。
        * 
        * 小端模式: 是指数据的高字节保存在内存的高地址中，
        * 而数据的低字节保存在内存的低地址中，这种存储模
        * 式将地址的高低和数据位权有效地结合起来，高地址
        * 部分权值高，低地址部分权值低。
        */
       bool ret = false;

       byte[] temp = new byte[frameBuffer.Length-2];
       Array.Copy(frameBuffer, 0, temp, 0, temp.Length);
       byte[] crcdata = DataCheck.DataCrc16_Ccitt(temp, DataCheck.BigOrLittle.BigEndian);
       if (crcdata[0] == frameBuffer[frameBuffer.Length - 2] &&
           crcdata[1]== frameBuffer[frameBuffer.Length-1])
       {
           // check ok
           ret = true;
       }

       return ret;

   }

效果展示

待续》》》》》