C#中Serial Port串口连接、断开及自动重连功能如何处理？

1. 基础连接实现 #

直接使用.NET内置的System.IO.Ports.SerialPort类完成串口初始化，示例初始化代码：

using System.IO.Ports;

private SerialPort _com3Port;
private readonly object _portLock = new object();

private void InitSerialPort()
{
    _com3Port = new SerialPort("COM3")
    {
        BaudRate = 9600, // 按需替换为你的实际波特率
        Parity = Parity.None,
        DataBits = 8,
        StopBits = StopBits.One,
        ReadTimeout = 1000,
        WriteTimeout = 1000
    };
    // 注册数据接收和错误事件
    _com3Port.DataReceived += OnDataReceived;
    _com3Port.ErrorReceived += OnErrorReceived;
    
    TryOpenPort();
}

private bool TryOpenPort()
{
    lock (_portLock)
    {
        try
        {
            if (!_com3Port.IsOpen)
            {
                _com3Port.Open();
                // 打开成功后立即发送一次测试指令确认对端设备在线
                return SendTestCommand();
            }
            return true;
        }
        catch (Exception ex)
        {
            // 记录打开失败日志
            Console.WriteLine($"端口打开失败：{ex.Message}");
            return false;
        }
    }
}

2. 断开状态识别逻辑 #

串口本身没有内置的链路状态检测能力，SerialPort.IsOpen仅标识本地端口是否被当前程序占用，对端设备断电/重启不会改变该属性值，必须通过应用层心跳实现状态检测：

• 提前和COM4的模拟设备约定专用的心跳查询指令，比如约定发送指定字节流后，设备会返回固定格式的应答
• 启动一个定时任务，比如每2秒发送一次心跳指令
• 满足以下任意一个条件即判定为链路断开：
  • 发送心跳指令时捕获到IOException、InvalidOperationException异常
  • 连续3次发送心跳后，未在超时时间内收到设备的合法应答
  • 串口ErrorReceived事件收到SerialError.RXOver、SerialError.Overrun等硬件错误通知

3. 自动重连逻辑实现 #

判定链路断开后，按以下流程执行重连：

private System.Timers.Timer _reconnectTimer;
private int _heartbeatFailCount = 0;

private void OnLinkDisconnected()
{
    // 先释放原有串口资源
    lock (_portLock)
    {
        if (_com3Port != null && _com3Port.IsOpen)
        {
            _com3Port.Close();
            _com3Port.Dispose();
        }
    }
    // 启动重连定时器，每2秒尝试重连一次
    _reconnectTimer = new System.Timers.Timer(2000);
    _reconnectTimer.Elapsed += (s, e) =>
    {
        bool connectSuccess = TryOpenPort();
        if (connectSuccess)
        {
            _reconnectTimer.Stop();
            _reconnectTimer.Dispose();
            _heartbeatFailCount = 0;
            // 重连成功后恢复正常业务逻辑
            Console.WriteLine("COM3端口重连成功");
        }
        else
        {
            Console.WriteLine("重连失败，等待下次尝试");
        }
    };
    _reconnectTimer.Start();
}

// 心跳检测逻辑示例
private void HeartbeatCheck(object sender, ElapsedEventArgs e)
{
    if (!_com3Port.IsOpen) return;
    try
    {
        lock (_portLock)
        {
            // 发送心跳指令，按实际约定替换指令内容
            byte[] heartbeatCmd = new byte[] { 0x01, 0x03, 0x00, 0x00, 0x00, 0x01, 0x85, 0xCF };
            _com3Port.Write(heartbeatCmd, 0, heartbeatCmd.Length);
            // 等待应答，实际项目建议在DataReceived事件里处理应答校验
            byte[] buffer = new byte[1024];
            int readLen = _com3Port.Read(buffer, 0, buffer.Length);
            if (readLen == 0 || !ValidateHeartbeatResponse(buffer, readLen))
            {
                _heartbeatFailCount++;
            }
            else
            {
                _heartbeatFailCount = 0;
            }
        }
    }
    catch (Exception)
    {
        _heartbeatFailCount++;
    }
    // 连续3次心跳失败判定断开
    if (_heartbeatFailCount >= 3)
    {
        OnLinkDisconnected();
    }
}

4. 注意事项 #

• 所有串口读写操作都要加锁，避免多线程同时操作导致的未知异常
• 重连间隔不要小于1秒，避免频繁操作端口占用系统资源
• 心跳超时时间需要和实际设备的响应速度匹配，建议设置为500ms~2s
• 如果使用了DTR/RTS硬件握手，需要保证串口参数配置和对端设备完全一致，避免误判为断开

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