WPF与PLC通信优化：MVVM架构在工业报警系统中的应用

1. 项目背景与问题定位

去年接手某汽配厂MES系统升级项目时，遇到一个典型的工业现场数据采集难题。车间三条产线共96个工艺报警点（包括温度、压力、电机状态等）需要通过S7-1500 PLC接入新建的WPF上位机系统。初期采用传统WinForms混合架构开发，在产线满负荷运行时暴露出两个致命问题：

1. 报警延迟严重：当同时触发5-6个报警时，界面刷新延迟达到2-3秒
2. 漏报风险：由于线程阻塞导致两个关键电机过载报警未被捕获，险些造成工件批量报废

通过Wireshark抓包分析发现，原始架构存在三个设计缺陷：

• PLC通讯与UI渲染共用同一线程
• 报警点采用离散地址轮询（每个DBX单独读取）
• 缺乏有效的心跳检测机制

2. 架构设计与技术选型

2.1 整体架构分层

采用严格的MVVM模式重构系统，各层职责明确划分：

code复制┌───────────────────────────────────────┐
│                View层                 │
│  XAML界面(DataGrid+样式触发器)        │
└───────────────┬───────────────────────┘
                │ Binding
┌───────────────▼───────────────────────┐
│             ViewModel层               │
│  ObservableCollection<AlarmModel>     │
│  用户操作命令处理(RelayCommand)        │
└───────────────┬───────────────────────┘
                │ Event/Message
┌───────────────▼───────────────────────┐
│               Model层                 │
│  S7netplus通讯模块(PlcService)        │
│  报警逻辑处理(AlarmProcessor)         │
└───────────────────────────────────────┘

2.2 关键技术组件

1. MVVMLight 5.4.1.1：

   • ViewModelBase实现属性通知
   • Messenger用于跨层事件传递
   • RelayCommand处理用户交互

2. S7netplus 2.0.2：

   • 支持.NET 8的西门子PLC通讯库
   • 原生异步读写支持
   • DB块批量读取优化

3. WPF特性应用：

   • DataGrid虚拟化技术
   • 样式触发器实现报警状态可视化
   • DispatcherTimer做本地心跳检测

3. PLC端优化策略

3.1 报警数据块规划

与电气工程师协作，在PLC端建立专用报警DB块（DB100）：

这种设计的优势：

• 单次读取只需18字节数据包
• 位运算解析效率高于离散地址访问
• 心跳计数器实现双向通讯检测

3.2 PLC程序优化

在OB35循环中断组织块（100ms周期）中实现：

1. 心跳计数器自增
2. 报警状态集中更新
3. 报警消抖处理（防止误报）

STL复制// 心跳计数器
L  DB100.DBW0
L  1
+I 
T  DB100.DBW0

// 报警状态更新
A  "温度传感器1故障"
=  DB100.DBX2.0
A  "液压压力过高"
=  DB100.DBX3.2

4. Model层核心实现

4.1 PlcService通讯模块

csharp复制public class PlcService : IDisposable
{
    private Plc _plc;
    private Timer _readTimer;
    private const int DB_NUMBER = 100;
    private const int READ_LENGTH = 18;

    public event EventHandler<byte[]> DataUpdated;

    public void Connect(string ip)
    {
        _plc = new Plc(CpuType.S71500, ip, 0, 1);
        _plc.Open();
        
        _readTimer = new Timer(100);
        _readTimer.Elapsed += async (s, e) => 
        {
            var data = await _plc.ReadBytesAsync(DataType.DataBlock, DB_NUMBER, 0, READ_LENGTH);
            DataUpdated?.Invoke(this, data);
        };
        _readTimer.Start();
    }

    public async Task WriteAckAsync(int alarmId)
    {
        // 使用位操作写入确认状态
        byte[] mask = new byte[1] { (byte)(1 << (alarmId % 8)) };
        await _plc.WriteBytesAsync(DataType.DataBlock, DB_NUMBER, 2 + alarmId/8, mask);
    }
}

4.2 报警处理逻辑

csharp复制public class AlarmProcessor
{
    private readonly Dictionary<int, AlarmModel> _alarmMap;
    private byte[] _lastStatus;

    public AlarmProcessor()
    {
        _alarmMap = LoadAlarmConfig(); // 从配置文件加载报警定义
    }

    public IEnumerable<AlarmModel> ProcessData(byte[] plcData)
    {
        // 心跳检测
        if (_lastStatus == null || plcData[0] != _lastStatus[0] + 1)
        {
            throw new PlcCommException("心跳检测失败");
        }

        List<AlarmModel> activeAlarms = new List<AlarmModel>();
        for (int i = 2; i < 14; i++) // 遍历报警字节段
        {
            byte current = plcData[i];
            byte previous = _lastStatus?[i] ?? 0;
            byte changes = (byte)(current ^ previous);

            if (changes == 0) continue;

            for (int bit = 0; bit < 8; bit++)
            {
                if ((changes & (1 << bit)) != 0)
                {
                    int alarmId = (i - 2) * 8 + bit;
                    if (_alarmMap.TryGetValue(alarmId, out var alarm))
                    {
                        alarm.IsActive = (current & (1 << bit)) != 0;
                        alarm.LastChangeTime = DateTime.Now;
                        activeAlarms.Add(alarm);
                    }
                }
            }
        }

        _lastStatus = plcData;
        return activeAlarms;
    }
}

5. ViewModel层关键实现

5.1 报警集合管理

csharp复制public class MainViewModel : ViewModelBase
{
    private readonly ObservableCollection<AlarmModel> _alarms = new ObservableCollection<AlarmModel>();
    private readonly object _lockObj = new object();

    public ICollectionView AlarmView { get; }

    public MainViewModel(IPlcService plcService)
    {
        // 配置集合视图过滤和排序
        AlarmView = CollectionViewSource.GetDefaultView(_alarms);
        AlarmView.Filter = o => ((AlarmModel)o).IsActive;
        AlarmView.SortDescriptions.Add(new SortDescription("LastChangeTime", ListSortDirection.Descending));

        // 订阅PLC数据更新
        plcService.DataUpdated += (s, e) => 
        {
            var newAlarms = _alarmProcessor.ProcessData(e);
            Application.Current.Dispatcher.Invoke(() =>
            {
                lock (_lockObj)
                {
                    foreach (var alarm in newAlarms)
                    {
                        var existing = _alarms.FirstOrDefault(a => a.Id == alarm.Id);
                        if (existing != null)
                        {
                            existing.UpdateFrom(alarm);
                        }
                        else
                        {
                            _alarms.Add(alarm);
                        }
                    }
                }
            });
        };
    }
}

5.2 命令绑定实现

csharp复制public RelayCommand<int> AcknowledgeCommand => new RelayCommand<int>(alarmId =>
{
    try
    {
        _plcService.WriteAckAsync(alarmId).Wait();
        var alarm = _alarms.First(a => a.Id == alarmId);
        alarm.IsAcknowledged = true;
    }
    catch (Exception ex)
    {
        _messenger.Send(new ErrorMessage(ex.ToString()));
    }
});

6. View层优化技巧

6.1 DataGrid性能优化

xml复制<DataGrid ItemsSource="{Binding AlarmView}" 
          EnableRowVirtualization="True"
          EnableColumnVirtualization="True"
          VirtualizingPanel.IsVirtualizing="True"
          VirtualizingPanel.VirtualizationMode="Recycling">
    <DataGrid.Resources>
        <Style TargetType="DataGridRow">
            <Style.Triggers>
                <DataTrigger Binding="{Binding IsActive}" Value="True">
                    <Setter Property="Background" Value="#FFF0F0"/>
                    <Setter Property="FontWeight" Value="Bold"/>
                </DataTrigger>
                <DataTrigger Binding="{Binding IsAcknowledged}" Value="False">
                    <Setter Property="Foreground" Value="Red"/>
                </DataTrigger>
            </Style.Triggers>
        </Style>
    </DataGrid.Resources>
</DataGrid>

6.2 动画效果实现

xml复制<Style TargetType="Border" x:Key="AlarmIndicator">
    <Style.Triggers>
        <DataTrigger Binding="{Binding IsActive}" Value="True">
            <DataTrigger.EnterActions>
                <BeginStoryboard>
                    <Storyboard>
                        <ColorAnimation From="Transparent" To="Red" 
                                      Storyboard.TargetProperty="Background.Color"
                                      Duration="0:0:0.5" 
                                      AutoReverse="True"
                                      RepeatBehavior="Forever"/>
                    </Storyboard>
                </BeginStoryboard>
            </DataTrigger.EnterActions>
        </DataTrigger>
    </Style.Triggers>
</Style>

7. 性能优化关键点

7.1 通讯性能对比

7.2 线程模型优化

1. 三层线程架构：

   • PLC通讯线程：专用Timer线程（优先级BelowNormal）
   • 数据处理线程：ThreadPool后台线程
   • UI线程：仅负责最终绑定更新

2. 锁机制选择：

   • 对_alarms集合使用lock语句
   • 对PLC连接对象使用ReaderWriterLockSlim

8. 异常处理与日志

8.1 错误分类处理

csharp复制public class PlcErrorHandler
{
    public void HandleException(Exception ex)
    {
        switch (ex)
        {
            case PlcCommException plcEx:
                _messenger.Send(new ReconnectMessage());
                break;
                
            case TimeoutException timeoutEx:
                _logger.Warn("PLC响应超时，尝试降低读取频率");
                _plcService.AdjustInterval(200);
                break;
                
            default:
                _logger.Error(ex, "未处理的异常");
                break;
        }
    }
}

8.2 日志配置示例

json复制{
  "Serilog": {
    "WriteTo": [
      {
        "Name": "File",
        "Args": {
          "path": "Logs/alarm-.log",
          "rollingInterval": "Day",
          "retainedFileCountLimit": 7
        }
      },
      {
        "Name": "Udp",
        "Args": {
          "remoteAddress": "192.168.1.100",
          "remotePort": 514
        }
      }
    ]
  }
}

9. 部署与维护建议

1. 安装包制作：

   • 使用WiX Toolset创建MSI安装包
   • 包含.NET 8运行时自动安装
   • 配置Windows服务自启动

2. 远程诊断：

   • 集成WCF服务暴露诊断接口
   • 实现实时通讯状态监控
   • 支持远程日志下载

3. 升级策略：

   • 使用ClickOnce实现自动更新
   • 配置文件与报警定义独立存储
   • 保留版本回滚能力

10. 实测性能指标

经过两周连续运行测试，系统达到以下指标：

• 平均响应延迟：120-180ms（从PLC触发到界面更新）
• CPU占用率：<15%（i5-8250U @1.6GHz）
• 内存占用：稳定在150-180MB
• 网络流量：约1.2KB/s（含心跳包）

关键改进前后的对比数据：

这套架构已经在三个同类项目中成功复用，最近一个项目甚至实现了1500+报警点的稳定监控。对于需要开发工业级上位机系统的同行，我的建议是：前期多花时间在架构设计上，后期维护成本能降低80%以上。