如何使用C#串口通讯实现数据的发送和接收

public class serialporthelper
{
    private serialport serialport; // 串口对象
    private list<byte> _buffer = new list<byte>(); // 数据缓冲区
    /// <summary>
    /// 自定义串口消息接收事件
    /// </summary>
    public event receivedataeventhandler receivedataevent;
    public serialporthelper()
    {
        serialport = new serialport();
    }
    /// <summary>
    /// 获取当前计算机所有的串行端口名
    /// </summary>
    public static string[] getportarray()
    {
        return serialport.getportnames(); // 获取所有可用串口
    }
    /// <summary>
    /// 设置串口参数
    /// </summary>
    public void setserialport(string portname, int baudrate, parity parity, int databits, stopbits stopbits)
    {
        serialport.portname = portname; // 端口名
        serialport.baudrate = baudrate; // 波特率
        serialport.parity = parity; // 奇偶校验
        serialport.databits = databits; // 数据位
        serialport.stopbits = stopbits; // 停止位
        serialport.datareceived += receivedatamethod; // 订阅数据接收事件
    }
    /// <summary>
    /// 打开串口
    /// </summary>
    public void open()
    {
        try
        {
            serialport.open(); // 打开串口
        }
        catch (exception ex)
        {
            console.writeline("error opening serial port: " + ex.message);
        }
    }
    /// <summary>
    /// 关闭串口
    /// </summary>
    public void close()
    {
        serialport.close(); // 关闭串口
    }
    /// <summary>
    /// 发送数据（字节数组）
    /// </summary>
    public void senddatamethod(byte[] data)
    {
        if (!serialport.isopen)
        {
            open(); // 如果串口未打开，则先打开
        }
        serialport.write(data, 0, data.length); // 发送数据
    }
    /// <summary>
    /// 发送数据（字符串）
    /// </summary>
    public void senddatamethod(string data)
    {
        if (!serialport.isopen)
        {
            open(); // 如果串口未打开，则先打开
        }
        serialport.write(data); // 发送字符串
    }
    /// <summary>
    /// 数据接收事件处理方法
    /// </summary>
    private void receivedatamethod(object sender, serialdatareceivedeventargs e)
    {
        try
        {
            byte[] datachunk = new byte[serialport.bytestoread]; // 读取缓冲区中的数据
            serialport.read(datachunk, 0, datachunk.length);
            _buffer.addrange(datachunk); // 将数据添加到缓冲区
            while (_buffer.count >= 3) // 确保缓冲区中有足够的数据
            {
                byte thirdbyte = _buffer[1]; // 获取第三个字节（功能码）
                if (thirdbyte == 0x03) // 功能码0x03
                {
                    if (_buffer.count >= 19) // 检查是否有完整的数据包
                    {
                        byte[] completepacket = _buffer.getrange(0, 19).toarray(); // 提取完整数据包
                        triggerreceivedataevent(completepacket); // 触发接收事件
                        _buffer.removerange(0, 19); // 移除已处理的数据
                    }
                    else
                    {
                        break; // 数据不足，等待更多数据
                    }
                }
                else if (thirdbyte == 0x10 || thirdbyte == 0x06) // 功能码0x10或0x06
                {
                    byte[] datatoprocess = _buffer.toarray(); // 处理整个缓冲区
                    triggerreceivedataevent(datatoprocess); // 触发接收事件
                    _buffer.clear(); // 清空缓冲区
                }
                else
                {
                    _buffer.removerange(0, 3); // 移除无法识别的数据
                }
            }
        }
        catch (exception ex)
        {
            console.writeline("error processing serial port data: " + ex.message);
        }
    }
    /// <summary>
    /// 触发接收数据事件
    /// </summary>
    private void triggerreceivedataevent(byte[] data)
    {
        if (receivedataevent != null)
        {
            receivedataeventarg arg = new receivedataeventarg(data); // 创建事件参数
            receivedataevent.invoke(this, arg); // 触发事件
        }
    }
}

public class receivedataeventarg : eventargs
{
    public byte[] data { get; set; } // 接收到的数据
    public receivedataeventarg(byte[] data)
    {
        data = data; // 初始化数据
    }
}

public partial class mainwindow : window
{
    private serialporthelper serialporthelper;
    public mainwindow()
    {
        initializecomponent();
        settingcomports(); // 初始化串口
    }
    private void settingcomports()
    {
        string portname = "com8"; // 串口名称
        int baudrate = 115200; // 波特率
        parity parity = parity.none; // 奇偶校验
        int databits = 8; // 数据位
        stopbits stopbits = stopbits.one; // 停止位
        serialporthelper = new serialporthelper();
        serialporthelper.setserialport(portname, baudrate, parity, databits, stopbits); // 设置串口参数
        serialporthelper.open(); // 打开串口
        serialporthelper.receivedataevent += receivedataevent; // 订阅接收数据事件
    }
    /// <summary>
    /// 接收数据事件处理方法
    /// </summary>
    private void receivedataevent(object sender, receivedataeventarg e)
    {
        byte[] receiveddata = e.data; // 获取接收到的数据
        if (receiveddata[1] == 0x03) // 功能码0x03
        {
            int receivedatalength = receiveddata[2]; // 获取有效数据长度
            byte[] receivedatabuffer = new byte[receivedatalength];
            array.copy(receiveddata, 3, receivedatabuffer, 0, receivedatalength); // 提取有效数据
            ushort[] units = messagedata.getunitsfrombytearray(receivedatabuffer); // 解析数据
            if (units != null)
            {
                list<channeldata> channeldatas = databasehelper.getuutinfo(units); // 获取设备信息
                updatedeviceinfo(channeldatas); // 更新ui
            }
        }
    }
}