【Unity学习】关于串口通信插件SerialPortUtilityPro的简单使用个人案例

【Unity学习】关于串口通信插件SerialPortUtilityPro的简单使用个人案例

前言

  • 关于插件资源,请去资源商店购买或使用其试用版,本帖不提供下载。

  • 因为项目需要涉及到了串口通信相关的开发任务,本人之前没有涉及到串口相关的知识,所以此贴仅为个人记录使用经验帖

  • 关于插件的具体使用,插件中有具体使用教程。

需求分析

项目要求发送16进制数据给对方并实时接收其发送过来的16进制数据进行解析。
发送的16进制格式:B5 A6 A2 01 01 A5 EA
接收的16进制格式:B5 A6 01 10 01 00 02 5F FE EC 06 ED 4A 33 75 30 00 66 07 3E 1D 9F
前两位B5 A6表示帧头,第三位表示消息类型,第四位表示消息长度,最后两位表示累计和校验,校验和计算范围为消息类型、消息长度和实际数据。中间的表示需要的实际数据,其中接收的数据第五位表示状态数据的数量,此处表示只有一个状态,若为两个则如下所示:
B5 A6 01 1F 02 00 02 5F FE EC 06 ED 4A 33 75 30 00 66 07 3E 01 02 5F FE EC 06 ED 4A 33 75 30 00 66 07 3E 39 CD

串口发送数据

计算累计和校验方法如下:

 /// <summary>
    /// 串口工具类
    /// </summary>
    public static class SerialPortTools
    {
        /// <summary>
        /// 计算累计和校验
        /// </summary>
        /// <param name="data">需要累积的数据</param>
        /// <returns></returns>
        public static byte[] Checksum(byte[] data)
        {
            byte[] CK = new byte[2];
            for (int i = 0; i < data.Length; i++)
            {
                CK[0] += data[i];
                CK[1] += CK[0];
            }
            return CK;
        }

   		 /// <summary>
        /// 判断两个byte数组是否相等
        /// </summary>
        /// <param name="a"></param>
        /// <param name="b"></param>
        /// <returns></returns>
        public static bool IsEqual(byte[] a,byte[] b)
        {
            if (a.Length!=b.Length)
            {
                return false;
            }
            for (int i = 0; i < a.Length; i++)
            {
                if (!a[i].Equals(b[i]))
                {
                    return false;
                }
            }
            return true;
        }
    }

拼接需要发送的16进制数据:

public static class SerialPortData
{
		public static Byte[] SendIdData(string ugvID)
        {
            Byte[] buffer = new Byte[7];
            buffer[0] = 0xB5;//帧头
            buffer[1] = 0xA6;//帧头
            buffer[2] = 0xA2;//消息类型
            buffer[3] = 0x01;//数据长度
            int.TryParse(ugvID, out int id);
            buffer[4] = Byte.Parse(Convert.ToString(id, 16), System.Globalization.NumberStyles.HexNumber);//实际数据
            Byte[] CK = SerialPortTools.Checksum(new Byte[] { buffer[2], buffer[3], buffer[4] });
            buffer[5] = CK[0];//校验CK_A
            buffer[6] = CK[1];//校验CK_B
            return buffer;
        }
}

使用SerialPortUtilityPro插件发送数据:

SerialPortUtilityPro spup =FindObjectOfType<SerialPortUtilityPro>();
if (!spup.IsConnected()) return;
spup.Write(SerialPortData.SendIdData("1"));

串口接收数据并解析

串口数据解析类如下:

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using System;

public class SerialPortEventHandler : MonoBehaviour
    {
        public SerialPortUtility.SerialPortUtilityPro serialPort;
        private Queue<byte> tempDataQueue;
        private byte dataType;//数据类型
        private byte[] testData;//用来进行累加和校验的数据
        private byte dataLength;//数据长度
        private byte[] realData;//去除帧头、数据类型、数据长度之后的实际数据
        private byte[] CR = new byte[2];//校验位
        private int number;
        private byte[][] stateBuffers;//因为可能接收多个状态数据,此处选择二维数组进行存储
        private bool isInitialNum = false;
        private string latitude, longitude, height, speed, direction;

        /// <summary>
        /// 串口读取二进制流数据
        /// </summary>
        /// <param name="data"></param>
        public void ReadStreamingBinary(object data)
        {
            var bin = data as byte[];
            tempDataQueue = new Queue<byte>();
            for (int i = 0; i < bin.Length; i++)
            {
                tempDataQueue.Enqueue(bin[i]);
            }
            //确认帧头正确
            if (tempDataQueue.Dequeue().Equals(0xB5) && tempDataQueue.Dequeue().Equals(0xA6))
            {
                dataType = tempDataQueue.Dequeue();//获取消息类型
                dataLength = tempDataQueue.Dequeue();//获取消息长度
                realData = new byte[dataLength];
                for (int i = 0; i < realData.Length; i++)
                {
                    realData[i] = tempDataQueue.Dequeue();
                }
                testData = new byte[2 + dataLength];
                testData[0] = dataType;
                testData[1] = dataLength;
                Array.Copy(realData, 0, testData, 2, dataLength);
                //获取校验位
                CR[0] = tempDataQueue.Dequeue();
                CR[1] = tempDataQueue.Dequeue();
                //根据累加和校验数据是否准确,若准确则进行数据解析分发
                if (SerialPortTools.IsEqual(SerialPortTools.Checksum(testData), CR))
                {
                    HandleMessage(dataType);
                }
            }
        }

        private void HandleMessage(byte dataType)
        {
            switch (dataType)
            {
                case 0x01:
                    Status(realData);
                    break;
                default:
                    break;
            }
        }

        private void Status(byte[] realData)
        {
            string byteArray = BitConverter.ToString(realData);
            Debug.Log(byteArray);
            number = realData[0];
            //将状态数据分解成数组存储
            stateBuffers = new byte[number][];
            for (int i = 0; i < number; i++)
            {
                stateBuffers[i] = new byte[15];
                Array.Copy(realData, 1 + 15 * i, stateBuffers[i], 0, 15);
            }
            //初始化位置
            if (!isInitialNum)
            {
                for (int i = 0; i < number; i++)
                {
                    latitude = Convert.ToString(stateBuffers[i][1], 16).PadLeft(2, '0') +
                        Convert.ToString(stateBuffers[i][2], 16).PadLeft(2, '0') +
                        Convert.ToString(stateBuffers[i][3], 16).PadLeft(2, '0') +
                        Convert.ToString(stateBuffers[i][4], 16).PadLeft(2, '0');
                    longitude = Convert.ToString(stateBuffers[i][5], 16).PadLeft(2, '0') +
                        Convert.ToString(stateBuffers[i][6], 16).PadLeft(2, '0') +
                        Convert.ToString(stateBuffers[i][7], 16).PadLeft(2, '0') +
                        Convert.ToString(stateBuffers[i][8], 16).PadLeft(2, '0');
                    height = Convert.ToString(stateBuffers[i][9], 16).PadLeft(2, '0') +
                        Convert.ToString(stateBuffers[i][10], 16).PadLeft(2, '0');
                    direction = Convert.ToString(stateBuffers[i][13], 16).PadLeft(2, '0') +
                     Convert.ToString(stateBuffers[i][14], 16).PadLeft(2, '0');
                }
                isInitialNum = true;
            }
        }
    }

将SerialPortEventHandler类中的ReadStreamingBinary方法绑定到下图组件中去:
请添加图片描述

结语

以上就是在unity中简单的使用串口收发数据并解析的过程,仅作为个人使用记录!