zoukankan      html  css  js  c++  java
  • c# 串口编程

    http://news.ccidnet.com/art/32859/20100524/2067861_4.html

    字节缓冲器处理类:

     /// <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了
                    }
    
                }
    
            }
  • 相关阅读:
    Socket开发框架之消息的回调处理
    Socket开发框架之数据加密及完整性检查
    Socket开发框架之数据传输协议
    Socket开发框架之框架设计及分析
    C#进行Visio二次开发之文件导出及另存Web页面
    Winform混合式开发框架的特点总结
    代码生成工具Database2Sharp中增加视图的代码生成以及主从表界面生成功能
    基于Metronic的Bootstrap开发框架经验总结(9)--实现Web页面内容的打印预览和保存操作
    基于C#的MongoDB数据库开发应用(4)--Redis的安装及使用
    基于C#的MongoDB数据库开发应用(3)--MongoDB数据库的C#开发之异步接口
  • 原文地址:https://www.cnblogs.com/jenney-qiu/p/4186357.html
Copyright © 2011-2022 走看看