DB11 TCP数据协议拆包接收主要方法
北京地标(DB11) 据接收器.
/// <summary> /// DB11协议拆包器 /// </summary> public class SplictProtocol { /// <summary> /// 用于处理数据协义的功能 /// </summary> List<byte> bytes = new List<byte>(5000); private int len = -1; /// <summary> /// 包头 /// </summary> private bool FindPackageHead = false; /// <summary> /// 索引 /// </summary> int index = -1; public List<byte[]> Splict(byte[] arr) { List<byte[]> list = new List<byte[]>(); try { if (arr != null) { //锁处理 lock (bytes) { //开始从队列中取数据 for (int k = 0; k < arr.Length; k++) { //队列有数据 byte b = arr[k]; //如果超过最大接收字节数 if (1000 * 1024 <= bytes.Count) { bytes.Clear(); } //添加到对像集合 bytes.Add(b); //3.从集合的前面开始取数据.找包头,进行拆包 if (bytes.Count >= 24) { if (!FindPackageHead) { for (int i = 0; i < bytes.Count; i++) { if (bytes[i] == 0x23 && (i + 1 < bytes.Count && bytes[i + 1] == 0x23)) { index = i; FindPackageHead = true; break; } } } if (index > -1) { //22 数据单元长度索引 if (bytes.Count > index + 23) { if (len == -1) { int xx = 0; //数据长度 len = new byte[2] { bytes[index + 22], bytes[index + 23] }.ReadUshort(ref xx).SwapUInt16(); } if (bytes.Count > index + len + 24) { var bb = bytes.Skip(index).Take(24 + len + 1).ToArray(); list.Add(bb); //初始化状态 FindPackageHead = false; len = index = -1; //移除所有数据 bytes.Clear(); } } } } } } } else { //Thread.Sleep(1); } } catch (Exception ex) { bytes.Clear(); //初始化状态 FindPackageHead = false; len = index = -1; } return list; } }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。