C# 串口操做系列(3) -- 协议篇，二进制协议数据解析

时间 2019-11-10

标签 c# 串口系列协议二进制数据解析栏目 C# 繁體版

原文原文链接

C# 串口操做系列(3) -- 协议篇，二进制协议数据解析

标签： c#buffer object 通信 byte 硬件驱动

2010-05-27 09:54 51565人阅读评论(215) 收藏举报

分类：

通信类库设计（4）

咱们的串口程序，除了通用的，进行串口监听收发的简单工具，大多都和下位机有关，这就须要关心咱们的通信协议如何缓存，分析，以及通知界面。算法

咱们先说一下通信协议。通信协议就是通信双方共同遵循的一套规则，定义协议的原则是尽量的简单以提升传输率，尽量的具备安全性保证数据传输完整正确。基于这2点规则，咱们一个通信协议应该是这样的：头+数据长度+数据正文+校验c#

例如：AA 44 05 01 02 03 04 05 EAapi

这里我假设的一条数据，协议以下：数组

数据头： AA 44缓存

数据长度： 05安全

数据正文： 01 02 03 04 05网络

校验： EA异步

通常数据的校验，都会采用经常使用的方式，CRC16,CRC32,Xor。工具

有的数据安全要求高的，不容许丢包的，可能还要加入重发机制或是加入数据恢复算法，在校验后根据前面数据添加恢复字节流以恢复数据。我这里采用的是简单的异或校验，包含数据头的全部字节，依次异或获得的。

协议很简单，我也认为分析协议是很简单的事情，下面咱们就如何分析协议来实际的结合c#看一下。

er…再等等，在咱们实际开始编码以前，还有一个规则须要了解，咱们有了通信协议，如何结合串口的协议来分析，须要关心什么呢？哦。通常就是4个问题：缓存收到的全部数据，找到一条完整数据，分析数据，界面通知。

若是分的更详细一点，缓存收到的全部数据，咱们想到最高效的办法就是顺序表，也就是数组，但数组的操做比较复杂，当你使用完一条数据后，用过的须要移除；新数据若是过多的时候，缓存过大须要清理；数据搬移等等，颇有可能一个不当心就会丢数据致使软件出些莫名其妙的小问题。我的建议，使用List<byte>，内部是数组方式实现，每次数据不足够的时候会扩容1倍，数据的增删改都已经作的很完善了。不会出现什么小问题。

找到一条完整数据，如何找到完整数据呢？就咱们例子的这个协议，首先在缓存的数据中找AA 44，当咱们找到后，探测后面的字节，发现是05，而后看缓存剩下的数据是否足够，不足够就不用判断，减小时间消耗，若是剩余数据>=6个（包含1个字节的校验），咱们就算一个校验，看和最后的校验是否一致。

分析数据：鉴于网络的开放性，我没法肯定读者对c#的了解程度，介绍一下，经常使用的方式就是BitConvert.ToInt32这一系列的方法，把连续的字节（和变量长度同样）读取并转换为对应的变量。c++下使用memcpy，或直接类型转换后进行值拷贝，vb6下使用CopyMemory这个api。

校验：前面说过了。完整性判断的时候须要和校验对比，大多系统都不太严格，不支持重发，因此数据错误就直接丢弃。致使数据错误的缘由不少，好比电磁干扰致使数据不完整或错误、硬件驱动效率不够致使数据丢失、咱们的软件缓存出错等。这些软件因素数据系统错误，须要修改，可是电磁干扰么，有这个可能的。虽然不多。

其实我知道，就算是我，看别人的博客也是，喜欢看图片，看代码，文字性的东西，一看就头大。那我接下来贴出基于上一篇文章的改进版本，支持协议分析（协议不能配置，可配置的协议不是咱们讨论的范畴。能够看看有DFA(肯定性有限状态机))

咱们修改一下界面，以便能显示收到后分析的数据

代码以下：

[c-sharp] view plain copy

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.IO.Ports;
using System.Text.RegularExpressions;
namespace SerialportSample
{
public partial class SerialportSampleForm : Form
{
private SerialPort comm = new SerialPort();
private StringBuilder builder = new StringBuilder();//避免在事件处理方法中反复的建立，定义到外面。
private long received_count = 0;//接收计数
private long send_count = 0;//发送计数
private bool Listening = false;//是否没有执行完invoke相关操做
private bool Closing = false;//是否正在关闭串口，执行Application.DoEvents，并阻止再次invoke
private List<byte> buffer = new List<byte>(4096);//默认分配1页内存，并始终限制不容许超过
private byte[] binary_data_1 = new byte[9];//AA 44 05 01 02 03 04 05 EA
public SerialportSampleForm()
{
InitializeComponent();
}
//窗体初始化
private void Form1_Load(object sender, EventArgs e)
{
//初始化下拉串口名称列表框
string[] ports = SerialPort.GetPortNames();
Array.Sort(ports);
comboPortName.Items.AddRange(ports);
comboPortName.SelectedIndex = comboPortName.Items.Count > 0 ? 0 : -1;
comboBaudrate.SelectedIndex = comboBaudrate.Items.IndexOf("19200");
//初始化SerialPort对象
comm.NewLine = "/r/n";
comm.RtsEnable = true;//根据实际状况吧。
//添加事件注册
comm.DataReceived += comm_DataReceived;
}
void comm_DataReceived(object sender, SerialDataReceivedEventArgs e)
{
if (Closing) return;//若是正在关闭，忽略操做，直接返回，尽快的完成串口监听线程的一次循环
try
{
Listening = true;//设置标记，说明我已经开始处理数据，一下子要使用系统UI的。
int n = comm.BytesToRead;//先记录下来，避免某种缘由，人为的缘由，操做几回之间时间长，缓存不一致
byte[] buf = new byte[n];//声明一个临时数组存储当前来的串口数据
received_count += n;//增长接收计数
comm.Read(buf, 0, n);//读取缓冲数据
/////////////////////////////////////////////////////////////////////////////////////////////////////////////
//<协议解析>
bool data_1_catched = false;//缓存记录数据是否捕获到
//1.缓存数据
buffer.AddRange(buf);
//2.完整性判断
while (buffer.Count >= 4)//至少要包含头（2字节）+长度（1字节）+校验（1字节）
{
//请不要担忧使用>=，由于>=已经和>,<,=同样，是独立操做符，并非解析成>和=2个符号
//2.1 查找数据头
if (buffer[0] == 0xAA && buffer[1] == 0x44)
{
//2.2 探测缓存数据是否有一条数据的字节，若是不够，就不用费劲的作其余验证了
//前面已经限定了剩余长度>=4，那咱们这里必定能访问到buffer[2]这个长度
int len = buffer[2];//数据长度
//数据完整判断第一步，长度是否足够
//len是数据段长度,4个字节是while行注释的3部分长度
if (buffer.Count < len + 4) break;//数据不够的时候什么都不作
//这里确保数据长度足够，数据头标志找到，咱们开始计算校验
//2.3 校验数据，确认数据正确
//异或校验，逐个字节异或获得校验码
byte checksum = 0;
for (int i = 0; i < len + 3; i++)//len+3表示校验以前的位置
{
checksum ^= buffer[i];
}
if (checksum != buffer[len + 3]) //若是数据校验失败，丢弃这一包数据
{
buffer.RemoveRange(0, len + 4);//从缓存中删除错误数据
continue;//继续下一次循环
}
//至此，已经被找到了一条完整数据。咱们将数据直接分析，或是缓存起来一块儿分析
//咱们这里采用的办法是缓存一次，好处就是若是你某种缘由，数据堆积在缓存buffer中
//已经不少了，那你须要循环的找到最后一组，只分析最新数据，过往数据你已经处理不及时
//了，就不要浪费更多时间了，这也是考虑到系统负载可以下降。
buffer.CopyTo(0, binary_data_1, 0, len + 4);//复制一条完整数据到具体的数据缓存
data_1_catched = true;
buffer.RemoveRange(0, len + 4);//正确分析一条数据，从缓存中移除数据。
}
else
{
//这里是很重要的，若是数据开始不是头，则删除数据
buffer.RemoveAt(0);
}
}
//分析数据
if (data_1_catched)
{
//咱们的数据都是定好格式的，因此当咱们找到分析出的数据1，就知道固定位置必定是这些数据，咱们只要显示就能够了
string data = binary_data_1[3].ToString("X2") + " " + binary_data_1[4].ToString("X2") + " " +
binary_data_1[5].ToString("X2") + " " + binary_data_1[6].ToString("X2") + " " +
binary_data_1[7].ToString("X2");
//更新界面
this.Invoke((EventHandler)(delegate { txData.Text = data; }));
}
//若是须要别的协议，只要扩展这个data_n_catched就能够了。每每咱们协议多的状况下，还会包含数据编号，给来的数据进行
//编号，协议优化后就是：头+编号+长度+数据+校验
//</协议解析>
/////////////////////////////////////////////////////////////////////////////////////////////////////////////
builder.Clear();//清除字符串构造器的内容
//由于要访问ui资源，因此须要使用invoke方式同步ui。
this.Invoke((EventHandler)(delegate
{
//判断是不是显示为16禁止
if (checkBoxHexView.Checked)
{
//依次的拼接出16进制字符串
foreach (byte b in buf)
{
builder.Append(b.ToString("X2") + " ");
}
}
else
{
//直接按ASCII规则转换成字符串
builder.Append(Encoding.ASCII.GetString(buf));
}
//追加的形式添加到文本框末端，并滚动到最后。
this.txGet.AppendText(builder.ToString());
//修改接收计数
labelGetCount.Text = "Get:" + received_count.ToString();
}));
}
finally
{
Listening = false;//我用完了，ui能够关闭串口了。
}
}
private void buttonOpenClose_Click(object sender, EventArgs e)
{
//根据当前串口对象，来判断操做
if (comm.IsOpen)
{
Closing = true;
while (Listening) Application.DoEvents();
//打开时点击，则关闭串口
comm.Close();
}
else
{
//关闭时点击，则设置好端口，波特率后打开
comm.PortName = comboPortName.Text;
comm.BaudRate = int.Parse(comboBaudrate.Text);
try
{
comm.Open();
}
catch(Exception ex)
{
//捕获到异常信息，建立一个新的comm对象，以前的不能用了。
comm = new SerialPort();
//现实异常信息给客户。
MessageBox.Show(ex.Message);
}
}
//设置按钮的状态
buttonOpenClose.Text = comm.IsOpen ? "Close" : "Open";
buttonSend.Enabled = comm.IsOpen;
}
//动态的修改获取文本框是否支持自动换行。
private void checkBoxNewlineGet_CheckedChanged(object sender, EventArgs e)
{
txGet.WordWrap = checkBoxNewlineGet.Checked;
}
private void buttonSend_Click(object sender, EventArgs e)
{
//定义一个变量，记录发送了几个字节
int n = 0;
//16进制发送
if (checkBoxHexSend.Checked)
{
//咱们无论规则了。若是写错了一些，咱们容许的，只用正则获得有效的十六进制数
MatchCollection mc = Regex.Matches(txSend.Text, @"(?i)[/da-f]{2}");
List<byte> buf = new List<byte>();//填充到这个临时列表中
//依次添加到列表中
foreach (Match m in mc)
{
buf.Add(byte.Parse(m.Value, System.Globalization.NumberStyles.HexNumber));
}
//转换列表为数组后发送
comm.Write(buf.ToArray(), 0, buf.Count);
//记录发送的字节数
n = buf.Count;
}
else//ascii编码直接发送
{
//包含换行符
if (checkBoxNewlineSend.Checked)
{
comm.WriteLine(txSend.Text);
n = txSend.Text.Length + 2;
}
else//不包含换行符
{
comm.Write(txSend.Text);
n = txSend.Text.Length;
}
}
send_count += n;//累加发送字节数
labelSendCount.Text = "Send:" + send_count.ToString();//更新界面
}
private void buttonReset_Click(object sender, EventArgs e)
{
//复位接受和发送的字节数计数器并更新界面。
send_count = received_count = 0;
labelGetCount.Text = "Get:0";
labelSendCount.Text = "Send:0";
}
}
}

至此，你只要按这个协议格式发送数据到软件打开的串口。就能在数据的data标签显示出你的数据内容，咱们如今是直接显示为：

01 02 03 04 05

也就是数据段内容。

运行截图：

发送模拟数据的界面，使用通用工具SSCOMM32.exe

咱们在回顾一下，通常二进制格式数据就是这样分析，分析数据长度是否足够，找到数据头，数据长度，校验，而后分析。

分析方式不少。结合各自实际状况操做，可使用序列化方式，可是wince不支持，也能够用BitConvert方式将连续的字节读取为某个类型的变量。

但愿看到这里，能给你带来帮助，欢迎你们和我讨论，但愿经验丰富的朋友不吝赐教。上一篇中，有朋友说用BeginInvoke能够避免死锁问题，我暂时没有线，没有测试成功，改天测试后再公布结果。

DataReceived事件中，最高效的作法是指缓存数据，而后异步的去分析数据。可是，这样较复杂，在效率要求不是很高的状况下（大多数状况），能够在DataReceived事件中缓存数据后，马上进行数据完整性检查，有效性检查，分析数据，以及更新界面。但这么作有一个隐患，底层串口操做的效率依赖于数据分析和界面更新，任何一个环节频繁耗时过长，都会形成数据的堆积。文章只假设都不拖时间的状况。

谢谢观赏，通信协议分析系列，未完待续……

2010示例代码

2008示例代码