如何在C# Windows Forms中实现按钮启停循环以监控OPC UA标签？

针对你的需求，核心是要在不阻塞UI线程的前提下，实现一个可启停的持续监控循环。以下是两种可行的方案，均能解决你之前用Timer无法实现持续运行的问题：

方案一：使用Task + CancellationTokenSource（推荐，现代C#方式） #

这种方式利用异步任务和取消令牌，既能实现持续循环，又能安全终止任务，同时不会卡住UI界面。

实现步骤 #

1. 声明类级别的变量，用于控制任务和取消信号
2. 启动按钮点击事件中创建任务，执行监控循环
3. 停止按钮点击事件中发送取消信号，清理资源
4. 后台线程更新UI时需通过Invoke确保线程安全

代码示例 #

private CancellationTokenSource _cts;
private Task _monitoringTask;

private void btnStartMonitoring_Click(object sender, EventArgs e)
{
    // 避免重复启动
    if (_monitoringTask?.Status == TaskStatus.Running)
        return;

    _cts = new CancellationTokenSource();
    _monitoringTask = Task.Run(async () =>
    {
        // 这里可以先建立OPC UA连接
        var opcClient = InitializeOpcUaClient();

        while (!_cts.Token.IsCancellationRequested)
        {
            try
            {
                // 读取OPC UA标签数据
                var tagData = opcClient.ReadTags();

                // 更新UI（必须通过Invoke切换到UI线程）
                this.Invoke((Action)(() =>
                {
                    txtMonitoringLog.Text += $"[{DateTime.Now:HH:mm:ss}] 读取数据：{tagData}\r\n";
                    // 滚动到日志底部
                    txtMonitoringLog.SelectionStart = txtMonitoringLog.Text.Length;
                    txtMonitoringLog.ScrollToCaret();
                }));
            }
            catch (Exception ex)
            {
                // 捕获读取异常，避免任务终止
                this.Invoke((Action)(() =>
                {
                    txtMonitoringLog.Text += $"[{DateTime.Now:HH:mm:ss}] 读取错误：{ex.Message}\r\n";
                }));
            }

            // 控制读取间隔，可根据需求调整，这里设为1秒
            await Task.Delay(1000, _cts.Token);
        }

        // 停止时断开OPC UA连接
        opcClient.Disconnect();
    }, _cts.Token);
}

private void btnStopMonitoring_Click(object sender, EventArgs e)
{
    // 发送取消信号
    _cts?.Cancel();
    
    try
    {
        // 等待任务完成
        _monitoringTask?.Wait();
    }
    catch (AggregateException)
    {
        // 取消任务会抛出异常，属于正常情况，无需处理
    }
    finally
    {
        // 清理资源
        _cts?.Dispose();
        _cts = null;
        _monitoringTask = null;
    }
}

// 模拟OPC UA客户端初始化和数据读取方法
private OpcUaClient InitializeOpcUaClient()
{
    // 替换为实际的OPC UA客户端初始化逻辑，比如连接到指定URL
    return new OpcUaClient();
}

public class OpcUaClient
{
    public string ReadTags()
    {
        // 替换为实际的标签读取逻辑
        return "标签1：123 | 标签2：456";
    }

    public void Disconnect()
    {
        // 断开OPC UA连接的逻辑
    }
}

方案二：使用BackgroundWorker（适合.NET Framework老版本） #

BackgroundWorker是.NET Framework中封装好的后台线程组件，适合简单的后台任务场景，自带取消和进度报告机制。

代码示例 #

private BackgroundWorker _monitoringWorker;

public MainForm()
{
    InitializeComponent();
    
    // 初始化BackgroundWorker
    _monitoringWorker = new BackgroundWorker();
    _monitoringWorker.DoWork += MonitoringWorker_DoWork;
    _monitoringWorker.ProgressChanged += MonitoringWorker_ProgressChanged;
    _monitoringWorker.WorkerSupportsCancellation = true;
    _monitoringWorker.WorkerReportsProgress = true;
}

private void btnStart_Click(object sender, EventArgs e)
{
    if (!_monitoringWorker.IsBusy)
        _monitoringWorker.RunWorkerAsync();
}

private void btnStop_Click(object sender, EventArgs e)
{
    if (_monitoringWorker.IsBusy)
        _monitoringWorker.CancelAsync();
}

private void MonitoringWorker_DoWork(object sender, DoWorkEventArgs e)
{
    var worker = sender as BackgroundWorker;
    var opcClient = InitializeOpcUaClient();

    while (!worker.CancellationPending)
    {
        try
        {
            var tagData = opcClient.ReadTags();
            // 报告进度，传递读取到的数据
            worker.ReportProgress(0, tagData);
        }
        catch (Exception ex)
        {
            worker.ReportProgress(0, $"读取错误：{ex.Message}");
        }

        // 控制读取间隔
        System.Threading.Thread.Sleep(1000);
    }

    opcClient.Disconnect();
    e.Cancel = true;
}

private void MonitoringWorker_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
    string data = e.UserState as string;
    txtMonitoringLog.Text += $"[{DateTime.Now:HH:mm:ss}] {data}\r\n";
    txtMonitoringLog.SelectionStart = txtMonitoringLog.Text.Length;
    txtMonitoringLog.ScrollToCaret();
}

关键注意事项 #

• 线程安全：后台线程绝对不能直接操作WinForms控件，必须通过Invoke（方案一）或ReportProgress（方案二）切换到UI线程更新界面。
• OPC UA连接管理：启动监控时建立连接，停止时务必断开，避免资源泄漏。
• 异常处理：在数据读取逻辑中加入try-catch，防止单次读取异常导致整个监控任务终止。
• 避免重复启动：启动前检查任务/Worker是否处于运行状态，防止多次点击启动按钮创建多个监控任务。

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