C# USB串口设备插拔检测事件多次触发，如何实现单次响应？

问题描述 #

我正在开发一款检测PC端USB转串口设备插拔状态的程序，需求是：设备移除时暂停异步读取串口的方法，重新连接时恢复该操作。目前串口功能和检测代码本身能正常运行，但插拔事件会连续触发5-6次，导致程序逻辑混乱，还会丢失部分串口数据。

相关代码 #

public Form1()
{
    InitializeComponent();

    // Check to see if USB Serial cable has been plugged or unplugged
    SerialPortService.PortsChanged += (sender1, changedArgs) => DetectChange(changedArgs.EventType);
}

static SerialPortService()
{
    _serialPorts = GetAvailableSerialPorts();  // Get valid serial ports
    MonitorDeviceChanges();
}

public static void CleanUp()
{
    arrival.Stop();
    removal.Stop();
}

public static event EventHandler<PortsChangedArgs> PortsChanged;

private static void MonitorDeviceChanges()
{
    try
    {
        var deviceArrivalQuery = new WqlEventQuery("SELECT * FROM Win32_DeviceChangeEvent WHERE EventType = 2");
        var deviceRemovalQuery = new WqlEventQuery("SELECT * FROM Win32_DeviceChangeEvent WHERE EventType = 3");

        arrival = new ManagementEventWatcher(deviceArrivalQuery);
        removal = new ManagementEventWatcher(deviceRemovalQuery);

        arrival.EventArrived += (o, args) => RaisePortsChangedIfNecessary(global::IPPusher.EventType.Insertion);
        removal.EventArrived += (sender, eventArgs) => RaisePortsChangedIfNecessary(global::IPPusher.EventType.Removal);

        // Start listening for events
        arrival.Start();
        removal.Start();
    }
    catch (ManagementException err)
    {
        MessageBox.Show("Management exception = " + err, "Info", MessageBoxButtons.OK);
    }
}

private static void RaisePortsChangedIfNecessary(EventType eventType)
{
    if (eventType == global::IPPusher.EventType.Insertion)
    {
        Thread.Sleep(1000);  // sleep while the PC sorts out its COM ports
        var availableSerialPorts = GetAvailableSerialPorts();
        var added = availableSerialPorts.Except(_serialPorts).ToArray();
        var portInUse = availableSerialPorts.Max();
        
        Form1.IsPaused = false;
        PortsChanged.Raise(null, new PortsChangedArgs(eventType, added));  // Fire the insertion event

    }
    if (eventType == global::IPPusher.EventType.Removal)
    {
        serialMethods.CloseSerialPort(Form1.PortName); // close active serial port
        
        Thread.Sleep(1000);  // sleep to sort things out
        var availableSerialPorts = GetAvailableSerialPorts();
                    
        Form1.IsPaused = true;  // pause the async method
        var removed = _serialPorts.Except(availableSerialPorts).ToArray();
        _serialPorts = availableSerialPorts;
        PortsChanged.Raise(null, new PortsChangedArgs(eventType, removed));  // fire the removal event
    }
}
}

public enum EventType
{
    Insertion,
    Removal,
}

public class PortsChangedArgs : EventArgs
{
    private readonly EventType _eventType;

    private readonly string[] _serialPorts;

    public PortsChangedArgs(EventType eventType, string[] serialPorts)
    {
        _eventType = eventType;
        _serialPorts = serialPorts;
    }

    public EventType EventType => _eventType;
}
}

解决方案 #

1. 防抖机制（优先推荐） #

Windows的Win32_DeviceChangeEvent会在设备插拔的多个阶段（如驱动加载、设备枚举）触发重复事件，添加防抖逻辑可以过滤短时间内的重复触发：

在SerialPortService类中添加静态变量用于防抖控制：

private static DateTime _lastProcessedEventTime = DateTime.MinValue;
private static readonly object _eventLock = new object();

修改RaisePortsChangedIfNecessary方法，增加时间间隔判断：

private static void RaisePortsChangedIfNecessary(EventType eventType)
{
    lock (_eventLock)
    {
        var currentTime = DateTime.Now;
        // 设置2秒的最小间隔，可根据实际情况调整
        if (currentTime.Subtract(_lastProcessedEventTime).TotalMilliseconds < 2000)
        {
            return; // 跳过重复触发的事件
        }
        _lastProcessedEventTime = currentTime;
    }

    // 保留原有的事件处理逻辑
    if (eventType == global::IPPusher.EventType.Insertion)
    {
        Thread.Sleep(1000);
        var availableSerialPorts = GetAvailableSerialPorts();
        var added = availableSerialPorts.Except(_serialPorts).ToArray();
        
        Form1.IsPaused = false;
        PortsChanged?.Invoke(null, new PortsChangedArgs(eventType, added));
        _serialPorts = availableSerialPorts; // 更新全局端口列表，避免后续判断错误
    }
    if (eventType == global::IPPusher.EventType.Removal)
    {
        serialMethods.CloseSerialPort(Form1.PortName);
        
        Thread.Sleep(1000);
        var availableSerialPorts = GetAvailableSerialPorts();
        var removed = _serialPorts.Except(availableSerialPorts).ToArray();
        
        Form1.IsPaused = true;
        PortsChanged?.Invoke(null, new PortsChangedArgs(eventType, removed));
        _serialPorts = availableSerialPorts;
    }
}

2. 规范事件订阅管理 #

如果怀疑是重复订阅导致多次触发，需确保事件只被订阅一次，同时在窗口关闭时清理订阅：

修改Form1的代码，将匿名委托改为具名方法，并在生命周期事件中管理订阅：

public Form1()
{
    InitializeComponent();
    this.Load += Form1_Load;
    this.FormClosing += Form1_FormClosing;
}

private void Form1_Load(object sender, EventArgs e)
{
    // 先取消可能存在的订阅，再重新订阅，避免重复
    SerialPortService.PortsChanged -= OnPortsChanged;
    SerialPortService.PortsChanged += OnPortsChanged;
}

private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
    // 取消订阅并清理资源
    SerialPortService.PortsChanged -= OnPortsChanged;
    SerialPortService.CleanUp();
}

private void OnPortsChanged(object sender, PortsChangedArgs changedArgs)
{
    DetectChange(changedArgs.EventType);
}

3. 优化端口状态判断 #

在处理插入事件时，确认新增端口确实是目标设备后再恢复异步读取；处理移除事件时，先检查当前串口是否已断开，避免重复执行关闭操作，减少无效逻辑导致的混乱。

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