C#多线程上位机开发与PLC数据采集优化实战-嵌云网-嵌入式AI开发资源站

C#多线程上位机开发与PLC数据采集优化实战

周恰恰

1. 项目背景与核心价值

去年在汽车生产线做设备改造时，我遇到一个典型需求：需要同时监控12台西门子S7-1200 PLC的运行状态，采集压力、温度等20多个工艺参数，还要实现异常报警和自动报表生成。传统单线程方案在数据刷新时频繁出现界面卡顿，最终我用C#开发的多线程上位机完美解决了这个问题。今天就把这套经过实战检验的方案拆解给大家。

这种架构的核心优势在于：

采用生产者-消费者模式分离UI线程与数据采集线程
通过线程安全队列实现跨线程数据交换
利用S7.Net Plus库高效读写PLC寄存器
动态线程池管理应对设备数量变化

2. 开发环境与工具链选型

2.1 硬件配置方案

推荐采用工控机配置：

CPU：Intel i5-1135G7（4核8线程）
内存：16GB DDR4（建议配置ECC内存）
网卡：Intel I210千兆工业网卡（需支持Profinet）

注意：普通商用网卡在持续高频通讯时可能出现丢包，建议使用工业级网卡

2.2 软件工具清单

工具类型	具体方案	版本要求
开发环境	Visual Studio 2022	17.4+
PLC驱动库	S7.Net Plus	1.0.15+
图表控件	LiveCharts2	2.0.0+
日志系统	Serilog + Seq	最新稳定版
单元测试	xUnit	2.4.2+

3. 核心架构设计与实现

3.1 多线程通信模型

csharp复制// 线程安全数据队列
private readonly BlockingCollection<PLCData> _dataQueue = new();

// 数据采集线程
void DataCollectorThread()
{
    while (!_cts.IsCancellationRequested)
    {
        var data = ReadPLCRegisters();
        _dataQueue.Add(data);  // 生产者
        Thread.Sleep(100);     // 采样间隔
    }
}

// UI更新线程
async Task UpdateUIThread()
{
    await foreach (var data in _dataQueue.GetConsumingEnumerable())
    {
        // 消费者
        chart1.Series[0].Points.AddY(data.Value);
    }
}

关键设计要点：

采用BlockingCollection实现线程安全队列
采样间隔根据PLC扫描周期调整（通常50-200ms）
使用CancellationTokenSource实现优雅退出

3.2 PLC寄存器映射方案

对于S7-1200的DB块数据，建议建立映射类：

csharp复制public class MachineData
{
    [S7Address(DB:1, Offset:0, Type:S7DataType.Int)]
    public short MotorSpeed { get; set; }
    
    [S7Address(DB:1, Offset:2, Type:S7DataType.Real)]
    public float Temperature { get; set; }
}

通过反射自动生成读写代码，实测比手动寻址效率提升40%。

4. 性能优化实战技巧

4.1 批量读取优化

csharp复制// 低效方式（多次请求）
var speed = plc.Read("DB1.DBW0");
var temp = plc.Read("DB1.DBD2");

// 高效方式（单次批量读取）
var result = plc.ReadBytes(DataType.DataBlock, 1, 0, 10);
var data = new MachineData {
    MotorSpeed = S7.Net.Types.Int.FromByteArray(result, 0),
    Temperature = S7.Net.Types.Real.FromByteArray(result, 2)
};

4.2 异常处理机制

csharp复制try
{
    await _plc.ReadAsync(...);
}
catch (PlcException ex) when (ex.ErrorCode == ErrorCode.ConnectionError)
{
    _logger.Error("PLC连接异常，尝试重连...");
    await ReconnectWithRetryAsync(3);
}
catch (Exception ex)
{
    _logger.Fatal(ex, "未处理的PLC异常");
    _emergencyStop?.Invoke();  // 触发急停
}

5. 典型问题排查指南

5.1 通讯超时问题

现象：频繁出现ReadTimeoutException
排查步骤：

使用Wireshark抓包确认物理层通讯
检查PLC的OB86组织块配置
验证TCP KeepAlive设置（默认2小时太长了）

解决方案：

csharp复制var plc = new Plc(CpuType.S71200, "192.168.0.1", 0, 1)
{
    Timeout = 5000,  // 5秒超时
    PingInterval = 30000  // 30秒心跳检测
};

5.2 界面卡顿优化

优化前指标：UI线程占用率85%
优化措施：

将Chart控件的BeginUpdate/EndUpdate包裹批量操作
启用DoubleBuffering
使用Invoke代替BeginInvoke

优化后指标：UI线程占用率<15%

6. 扩展功能实现

6.1 数据持久化方案

csharp复制// 使用SQLite实现边缘存储
using var connection = new SQLiteConnection("Data Source=plc_data.db");
connection.CreateTable<PLCDataRecord>();

// 定时批量插入
Timer _storageTimer = new Timer(_ => 
{
    var batch = _dataQueue.TakeAll(); 
    connection.InsertAll(batch);
}, null, 1000, 1000);

6.2 OPC UA集成

对于需要对接MES系统的场景，可增加OPC UA服务器：

csharp复制var server = new UaServer();
server.AddNode(new VariableNode
{
    NodeId = "ns=2;s=Temperature",
    Value = new DataValue(new Variant(25.5))
});

7. 部署与维护建议

安装包制作：使用Inno Setup打包时包含：
- .NET 6.0 Runtime
- VC++ 2019 Redistributable
- 网卡驱动（可选）
看门狗服务：编写Windows服务监控主程序：

csharp复制if (!Process.GetProcessesByName("HMI").Any())
{
    Process.Start("HMI.exe");
}

远程诊断：集成TeamViewer SDK实现远程协助功能

这套架构在汽车焊装线上已稳定运行2年，单台工控机最重负载时同时处理18台PLC的200+个信号点。核心在于合理分配线程职责，我总结的经验法则是：每个物理CPU核心不要超过3个活跃工作线程，否则上下文切换开销会抵消多线程优势。