使用C# SerialPort类读取3M高波特率串口数据丢包如何解决

问题根因 #

当前代码在高波特率下丢数据的核心原因如下：

• DataReceived事件默认触发阈值为1字节，触发时大概率没有完整的一行数据进入缓冲区，直接调用ReadLine()会阻塞等待换行符，此时新数据持续涌入极易导致缓冲区溢出丢包
• 默认SerialPort.ReadBufferSize仅为4096字节，3M波特率下每秒可传输约300KB数据，缓冲区会在十几毫秒内被填满导致溢出
• ReadLine()内置的字符编码转换、行匹配逻辑在高流速下处理效率不足，会加剧缓冲区积压

解决方案 #

1. 调整串口基础配置 #

首先放大接收缓冲区，降低事件触发频次减少性能开销，配置示例如下：

SerialPort DeviceUSBSerialPort = new SerialPort("COM3", 3000000)
{
    ReadBufferSize = 1048576, // 将接收缓冲区调整为1MB，可根据实际场景进一步放大
    ReceivedBytesThreshold = 1024, // 累计到1024字节再触发事件，减少触发次数
    DtrEnable = true,
    RtsEnable = true,
    ReadTimeout = 500,
    // 编码要和发送端保持一致，示例为UTF8，可替换为ASCII、GB2312等
    Encoding = Encoding.UTF8
};

2. 重构数据接收逻辑，改用字节流预缓存再拆行 #

不要在DataReceived事件中直接调用ReadLine()，改为先读取所有可用字节到自定义内存缓存，再从缓存中拆分完整行，剩余不完整数据留待下次处理，完整代码如下：

// 全局变量定义
private readonly object _bufferLock = new object();
private readonly MemoryStream _receiveBuffer = new MemoryStream();
private readonly byte[] _tempReadBuffer = new byte[4096];
// 换行符要和发送端保持一致，示例为\r\n，若仅为\n可改为new byte[] { 0x0A }
private readonly byte[] _newLineBytes = Encoding.UTF8.GetBytes(Environment.NewLine);

private void Port_DataReceived(object sender, SerialDataReceivedEventArgs e)
{
    if (e.EventType != SerialData.Chars) return;
    var port = (SerialPort)sender;

    lock (_bufferLock)
    {
        // 一次性读走所有可用字节，避免缓冲区积压
        int bytesRead;
        while (port.BytesToRead > 0)
        {
            bytesRead = port.Read(_tempReadBuffer, 0, _tempReadBuffer.Length);
            _receiveBuffer.Write(_tempReadBuffer, 0, bytesRead);
        }

        byte[] allBufferData = _receiveBuffer.ToArray();
        int startOffset = 0;
        int newLinePos;

        // 拆分所有完整行
        while ((newLinePos = IndexOfBytes(allBufferData, _newLineBytes, startOffset)) != -1)
        {
            int lineByteLength = newLinePos - startOffset;
            string line = port.Encoding.GetString(allBufferData, startOffset, lineByteLength);
            
            // 此处处理完整行逻辑，更新UI请使用BeginInvoke避免阻塞
            Console.WriteLine(line);

            startOffset = newLinePos + _newLineBytes.Length;
        }

        // 剩余不完整数据放回缓存，等待后续数据拼接
        _receiveBuffer.SetLength(0);
        if (startOffset < allBufferData.Length)
        {
            _receiveBuffer.Write(allBufferData, startOffset, allBufferData.Length - startOffset);
        }
    }
}

// 辅助方法：在源字节数组中查找目标字节序列的位置
private int IndexOfBytes(byte[] source, byte[] target, int startIndex)
{
    if (source.Length == 0 || target.Length == 0 || startIndex >= source.Length)
        return -1;

    for (int i = startIndex; i <= source.Length - target.Length; i++)
    {
        bool isMatch = true;
        for (int j = 0; j < target.Length; j++)
        {
            if (source[i + j] != target[j])
            {
                isMatch = false;
                break;
            }
        }
        if (isMatch) return i;
    }
    return -1;
}

3. 额外优化建议 #

• 进入设备管理器找到对应串口，在驱动属性的高级设置中，将驱动层的接收缓冲区调整为最大值，部分CH340、CP2102等USB转串口芯片默认驱动缓冲区仅为2KB，极易丢包
• 行数据的业务处理逻辑不要直接写在事件中，可将拆分好的行存入线程安全队列，用单独的后台线程处理业务逻辑，进一步降低事件处理的耗时
• 若涉及UI更新，务必使用BeginInvoke异步调度到UI线程，不要使用阻塞的Invoke调用

内容的提问来源于stack exchange，提问作者Praveen sharma