C# PCHMI实战5个工业自动化界面开发案例详解附源码在工业自动化领域一个直观、稳定且功能强大的人机交互界面HMI往往是连接操作人员与复杂生产系统的桥梁。对于熟悉C#的开发者而言如何将这门强大的通用语言与专业的工业界面开发平台结合创造出既满足工业级可靠性要求又具备高度定制化潜力的应用是一个极具价值的课题。PCHMI作为一款成熟的工业HMI软件平台其与C#的结合为开发者打开了一扇新的大门——你不再局限于组态软件的固定模板而是可以调用.NET生态的丰富资源深度定制从数据采集、逻辑处理到界面呈现的每一个环节。本文将从五个真实的工业场景出发手把手带你剖析如何用C#和PCHMI协同工作并附上可直接参考或复用的核心代码片段目标是让每一位有C#基础的工程师都能快速上手工业界面开发。1. 环境准备与基础通信架构搭建在动手开发第一个界面之前搭建一个稳定可靠的通信基础是重中之重。工业现场环境复杂通信的实时性和稳定性直接决定了整个系统的可用性。C#与PCHMI的结合通常有两种主流架构模式选择哪一种取决于你对系统灵活性和开发效率的权衡。第一种是松耦合架构。在这种模式下PCHMI作为独立的、功能完整的HMI/SCADA运行负责与底层PLC、仪表等设备进行通信、数据采集和基础画面展示。C#开发的应用程序则作为一个“高级客户端”通过PCHMI提供的标准接口最常见的是OPC UA/DA去读取数据和下发指令。这种模式的优点是分工明确PCHMI负责处理繁杂的工业协议和实时数据流C#程序则可以专注于业务逻辑、高级数据分析、报表生成等上层应用。系统稳定性高因为核心通信层由专业的工业软件保障。第二种是紧耦合架构也是本文案例主要采用的方式。我们直接利用C#作为主开发语言通过调用PCHMI的SDK或直接使用成熟的第三方工业通信库如用于西门子S7系列的Snap7用于Modbus的NModbus来建立与设备的连接。PCHMI的某些组件或运行时库可能被集成进来用于提供一些经过验证的控件或服务。这种方式赋予了开发者最大的控制权从通信线程管理、数据包解析到界面渲染全部可以自定义。提示对于初次涉足工业通信的C#开发者建议从Modbus TCP协议开始尝试。它相对简单资料丰富且NModbus库非常成熟易用。无论选择哪种架构项目的基础依赖管理都很关键。假设我们使用.NET 6和Visual Studio 2022进行开发首先需要通过NuGet包管理器引入必要的库。以下是一个典型的dotnetCLI命令示例用于创建一个新的WPF项目并添加基础通信库dotnet new wpf -n IndustrialHMI.Demo cd IndustrialHMI.Demo dotnet add package NModbus dotnet add package OPCFoundation.NetStandard.Opc.Ua dotnet add package OPCFoundation.NetStandard.Opc.Ua.Client dotnet add package Serilog.Sinks.File这里我们引入了NModbus用于Modbus设备通信OPC基金会官方库用于可能的OPC UA集成以及Serilog用于后续的日志记录这对于工业应用的故障排查至关重要。接下来我们需要建立一个基础的数据模型和通信管理器。工业数据通常是周期性的、结构化的。定义一个简单的数据点Tag类是很好的起点namespace IndustrialHMI.Demo.Core.Models { public class IndustrialTag { public string TagId { get; set; } // 唯一标识如“MT01.Speed” public string Name { get; set; } // 显示名称如“主电机转速” public string Description { get; set; } public TagDataType DataType { get; set; } // 枚举Bool, Int16, Int32, Float, Double, String public object Value { get; set; } // 当前值 public DateTime Timestamp { get; set; } // 时间戳 public double? AlarmHigh { get; set; } // 高报警限 public double? AlarmLow { get; set; } // 低报警限 public string Unit { get; set; } // 单位如“RPM”, “°C” } public enum TagDataType { Bool, Int16, Int32, Float, Double, String } }通信管理器CommsManager则负责维护设备连接、定时读写数据并提供线程安全的数据访问接口。这是一个高度简化的示例框架using System.Collections.Concurrent; using NModbus; namespace IndustrialHMI.Demo.Core.Services { public class CommsManager : IDisposable { private readonly ConcurrentDictionarystring, IndustrialTag _tagCache; private readonly IModbusMaster _modbusMaster; private readonly System.Timers.Timer _readTimer; private bool _isConnected; public CommsManager(string ipAddress, int port 502) { _tagCache new ConcurrentDictionarystring, IndustrialTag(); var factory new ModbusFactory(); // 注意实际项目中需要更完善的TCP客户端管理和错误处理 var adapter factory.CreateTcpClient(ipAddress, port); _modbusMaster factory.CreateMaster(adapter); _readTimer new System.Timers.Timer(1000); // 1秒周期 _readTimer.Elapsed async (sender, e) await ReadDataAsync(); } public bool Start() { try { // 尝试建立连接 // _modbusMaster.Transport.Connect(); // 具体连接方法取决于库版本 _isConnected true; _readTimer.Start(); return true; } catch (Exception ex) { // 记录日志 return false; } } private async Task ReadDataAsync() { if (!_isConnected) return; // 示例读取保持寄存器40001开始的10个寄存器对应地址0 ushort startAddress 0; ushort numRegisters 10; try { var values await Task.Run(() _modbusMaster.ReadHoldingRegisters(1, startAddress, numRegisters)); // 将读取到的值更新到对应的Tag中 // 这里需要根据预定义的Tag映射表来处理 UpdateTagValue(Tag1, values[0]); } catch (Exception ex) { // 处理通信异常可能触发重连机制 _isConnected false; } } private void UpdateTagValue(string tagId, ushort value) { if (_tagCache.TryGetValue(tagId, out var tag)) { tag.Value value; tag.Timestamp DateTime.Now; // 触发值改变事件通知UI更新 } } public void Dispose() { _readTimer?.Stop(); _readTimer?.Dispose(); _modbusMaster?.Dispose(); } } }这个基础框架搭建好后我们就可以在此基础上针对不同的应用场景构建具体的功能模块和用户界面了。2. 案例一多设备状态监控与可视化仪表盘状态监控是HMI最核心的功能。一个优秀的监控界面不仅要准确反映实时数据更要通过视觉设计让操作员在数秒内掌握整个系统的运行健康度。我们将构建一个用于监控一条小型装配线的可视化仪表盘。这条假设的装配线包含三个主要工站上料站、装配站和检测站。每个工站有电机转速、气缸状态、当前周期时间等关键参数。我们的目标是创建一个WPF窗口集中展示这些信息。首先在ViewModel中我们需要维护一个工站Workstation的集合每个工站包含其所属的Tag列表。// WorkstationViewModel.cs public class WorkstationViewModel : ObservableObject // 假设实现了INotifyPropertyChanged { public string StationName { get; set; } public ObservableCollectionIndustrialTag Tags { get; set; } public Brush StatusColor GetStatusColor(); private Brush GetStatusColor() { var runTag Tags.FirstOrDefault(t t.TagId.EndsWith(.Run)); var faultTag Tags.FirstOrDefault(t t.TagId.EndsWith(.Fault)); // 逻辑判断故障为红色运行为绿色停止为灰色 if (faultTag?.Value is bool fault fault) return Brushes.Red; if (runTag?.Value is bool running running) return Brushes.Green; return Brushes.Gray; } }在XAML界面设计上我们摒弃传统的网格加数字标签的枯燥形式采用更直观的图形化控件。我们可以使用LiveCharts或OxyPlot库来绘制实时趋势曲线用自定义的用户控件来模拟设备的外观。例如对于一个电机的监控我们可以设计一个如下的用户控件MotorStatusControl.xamlUserControl x:ClassIndustrialHMI.Demo.Views.Controls.MotorStatusControl ... Border BorderBrush#FFCCCCCC BorderThickness1 CornerRadius5 Padding10 StackPanel TextBlock Text{Binding MotorName} FontWeightBold HorizontalAlignmentCenter/ !-- 用Ellipse模拟电机颜色绑定状态 -- Ellipse Width40 Height40 StrokeDarkGray StrokeThickness2 Ellipse.Fill MultiBinding Converter{StaticResource MotorStatusToColorConverter} Binding PathIsRunning/ Binding PathHasFault/ /MultiBinding /Ellipse.Fill /Ellipse !-- 转速显示使用ProgressBar增强视觉感 -- TextBlock Text转速: Margin0,5,0,0/ Grid ProgressBar Value{Binding Speed} Maximum{Binding SpeedMax} Height10/ TextBlock Text{Binding Speed, StringFormat{}{0:F0} RPM} HorizontalAlignmentCenter VerticalAlignmentCenter ForegroundWhite FontSize9/ /Grid !-- 电流显示 -- TextBlock Text{Binding Current, StringFormat电流: {0:F1} A} / /StackPanel /Border /UserControl后台的CommsManager会周期性地更新绑定到这些控件上的IndustrialTag的值。为了高效更新UI务必确保数据更新是在UI线程上进行的可以使用Dispatcher.Invoke或通过MVVM模式中属性变更通知的自动分发。对于整线概览我们可以使用一个仪表盘来显示整体设备综合效率OEE。这里展示一个使用LiveCharts绘制实时OEE趋势图的简单示例// 在DashboardViewModel中 public SeriesCollection OeeSeries { get; set; } public Funcdouble, string YFormatter { get; set; } value value.ToString(P0); // 格式化为百分比 public DashboardViewModel() { OeeSeries new SeriesCollection { new LineSeries { Title OEE, Values new ChartValuesdouble { 0.85, 0.87, 0.82, 0.89, 0.90, 0.88 }, // 初始数据 PointGeometry DefaultGeometries.Circle, PointGeometrySize 8 } }; // 启动一个定时器模拟从后台服务获取最新OEE值并添加到图表中 var timer new DispatcherTimer { Interval TimeSpan.FromSeconds(2) }; timer.Tick (s, e) { var random new Random(); double newOee 0.80 random.NextDouble() * 0.15; // 模拟80%-95%的OEE OeeSeries[0].Values.Add(newOee); // 保持图表只显示最近20个点 if (OeeSeries[0].Values.Count 20) OeeSeries[0].Values.RemoveAt(0); }; timer.Start(); }通过这样的设计操作员扫一眼屏幕就能通过颜色、图形和趋势快速定位到异常工站而无需阅读大量数字文本。3. 案例二配方管理与参数远程设定在自动化生产中同一台设备往往需要生产不同型号的产品这就需要“配方”功能。配方是一组预设的工艺参数集合例如温度、压力、速度、时间等。我们将开发一个配方管理模块支持配方的创建、编辑、保存、加载和一键下发至设备。首先定义配方的数据模型和存储方式。为了简单和独立性我们可以使用JSON文件进行存储当然在实际项目中可能会使用数据库。// Recipe.cs public class Recipe { public string RecipeId { get; set; } public string RecipeName { get; set; } public string Description { get; set; } public DateTime CreatedTime { get; set; } public DateTime ModifiedTime { get; set; } public ListRecipeParameter Parameters { get; set; } new(); } public class RecipeParameter { public string TagId { get; set; } // 对应设备中的变量地址 public string ParameterName { get; set; } public double SetValue { get; set; } public string Unit { get; set; } public double MinValue { get; set; } public double MaxValue { get; set; } }我们需要一个RecipeManager类来负责配方的持久化操作。using System.Text.Json; public class RecipeManager { private readonly string _recipeDirectory; public RecipeManager(string appDataPath) { _recipeDirectory Path.Combine(appDataPath, Recipes); Directory.CreateDirectory(_recipeDirectory); } public async Task SaveRecipeAsync(Recipe recipe) { recipe.ModifiedTime DateTime.Now; string filePath Path.Combine(_recipeDirectory, ${recipe.RecipeId}.json); var options new JsonSerializerOptions { WriteIndented true }; string jsonString JsonSerializer.Serialize(recipe, options); await File.WriteAllTextAsync(filePath, jsonString); } public async TaskRecipe LoadRecipeAsync(string recipeId) { string filePath Path.Combine(_recipeDirectory, ${recipeId}.json); if (!File.Exists(filePath)) return null; string jsonString await File.ReadAllTextAsync(filePath); return JsonSerializer.DeserializeRecipe(jsonString); } public ListRecipe GetAllRecipes() { var recipes new ListRecipe(); foreach (var file in Directory.GetFiles(_recipeDirectory, *.json)) { try { string jsonString File.ReadAllText(file); var recipe JsonSerializer.DeserializeRecipe(jsonString); recipes.Add(recipe); } catch { /* 忽略损坏的文件 */ } } return recipes.OrderByDescending(r r.ModifiedTime).ToList(); } }在UI层面我们可以设计一个主从视图。左侧是一个ListBox显示所有配方右侧是一个DataGrid或动态生成的输入控件集合用于编辑选中配方的参数。配方下发是核心功能。当操作员点击“加载”或“应用”按钮时需要将配方中每个参数RecipeParameter.SetValue写入到对应的设备变量TagId中。这个过程必须是事务性的要么全部成功要么全部失败或提供明确的状态反馈。// RecipeViewModel.cs 中的方法 public async Task ApplyRecipeToDevice(Recipe recipe, ICommsService commsService) { var results new List(string ParamName, bool Success, string Message)(); foreach (var param in recipe.Parameters) { try { // 假设 commsService.WriteTag 方法已实现 bool writeSuccess await commsService.WriteTagAsync(param.TagId, param.SetValue); results.Add((param.ParameterName, writeSuccess, writeSuccess ? 成功 : 写入失败)); // 重要工业通信中连续快速写入可能导致PLC处理不过来需要适当延时 await Task.Delay(50); // 50毫秒间隔 } catch (Exception ex) { results.Add((param.ParameterName, false, $异常: {ex.Message})); } } // 生成并显示应用报告 string report $配方 {recipe.RecipeName} 下发完成。\n; report $总计 {recipe.Parameters.Count} 个参数。\n; report $成功: {results.Count(r r.Success)} 个。\n; report $失败: {results.Count(r !r.Success)} 个。\n; if (results.Any(r !r.Success)) { report 失败详情:\n; foreach (var fail in results.Where(r !r.Success)) { report $- {fail.ParamName}: {fail.Message}\n; } } // 使用 MessageBox 或日志系统显示报告 MessageBox.Show(report, 配方下发结果, MessageBoxButton.OK, results.All(r r.Success) ? MessageBoxImage.Information : MessageBoxImage.Warning); }为了提升用户体验还可以实现“配方对比”功能在应用前显示当前设备参数与配方设定值的差异让操作员进行最终确认。4. 案例三实时报警管理与历史追溯工业系统中的报警管理绝非简单的弹窗提示。一个专业的报警系统需要具备实时显示、分级如警告、故障、紧急、确认、过滤、记录和查询分析等完整功能。我们将构建一个基于WPFDataGrid的实时报警窗口和一个基于时间范围查询的历史报警查看器。首先定义报警模型public class Alarm { public string AlarmId { get; set; } public string TagId { get; set; } public string AlarmText { get; set; } // 如“电机A过载” public AlarmLevel Level { get; set; } public DateTime TriggerTime { get; set; } public DateTime? AcknowledgeTime { get; set; } public DateTime? ClearTime { get; set; } public bool IsActive ClearTime null; // 未清除即为活跃报警 public object TriggerValue { get; set; } public double? Threshold { get; set; } } public enum AlarmLevel { Info, // 信息蓝色 Warning, // 警告黄色 Fault, // 故障橙色 Critical // 紧急红色 }我们需要一个全局的AlarmManager它订阅CommsManager中Tag值的变化并根据预定义的报警规则如高低限、状态变化来触发或清除报警。public class AlarmManager { private readonly ConcurrentDictionarystring, Alarm _activeAlarms; private readonly ListAlarmRule _rules; private readonly ILogger _logger; public event EventHandlerAlarmEventArgs AlarmTriggered; public event EventHandlerAlarmEventArgs AlarmCleared; public AlarmManager(ILogger logger) { _activeAlarms new ConcurrentDictionarystring, Alarm(); _rules LoadAlarmRules(); // 从配置文件或数据库加载规则 _logger logger; } public void EvaluateTagUpdate(IndustrialTag updatedTag) { foreach (var rule in _rules.Where(r r.TagId updatedTag.TagId)) { bool shouldTrigger rule.CheckCondition(updatedTag.Value); string alarmKey ${rule.TagId}_{rule.RuleType}; if (shouldTrigger !_activeAlarms.ContainsKey(alarmKey)) { // 触发新报警 var newAlarm new Alarm { ... }; if (_activeAlarms.TryAdd(alarmKey, newAlarm)) { AlarmTriggered?.Invoke(this, new AlarmEventArgs(newAlarm)); _logger.Warning($报警触发: {newAlarm.AlarmText}); // 可以在这里触发声音、闪烁等 } } else if (!shouldTrigger _activeAlarms.TryRemove(alarmKey, out var clearedAlarm)) { // 报警条件不满足清除报警 clearedAlarm.ClearTime DateTime.Now; AlarmCleared?.Invoke(this, new AlarmEventArgs(clearedAlarm)); _logger.Information($报警清除: {clearedAlarm.AlarmText}); } } } public void AcknowledgeAlarm(string alarmId) { // 确认报警逻辑 } }在WPF界面中实时报警窗口可以使用一个DataGrid来绑定到AlarmManager中的活动报警集合。利用DataGrid的样式触发器可以根据AlarmLevel改变行的背景色。DataGrid ItemsSource{Binding ActiveAlarms} AutoGenerateColumnsFalse IsReadOnlyTrue DataGrid.Columns DataGridTextColumn Header时间 Binding{Binding TriggerTime, StringFormat{}{0:HH:mm:ss}}/ DataGridTextColumn Header等级 Binding{Binding Level} DataGridTextColumn.ElementStyle Style TargetTypeTextBlock Setter PropertyForeground Value{Binding Level, Converter{StaticResource AlarmLevelToColorConverter}}/ /Style /DataGridTextColumn.ElementStyle /DataGridTextColumn DataGridTextColumn Header描述 Binding{Binding AlarmText} Width*/ DataGridTextColumn Header值 Binding{Binding TriggerValue, StringFormat{}{0:F2}}/ DataGridTemplateColumn Header确认 DataGridTemplateColumn.CellTemplate DataTemplate Button Content确认 Command{Binding DataContext.AckAlarmCommand, RelativeSource{RelativeSource AncestorTypeDataGrid}} CommandParameter{Binding AlarmId} IsEnabled{Binding AcknowledgeTime, Converter{StaticResource NullToBoolConverter}}/ /DataTemplate /DataGridTemplateColumn.CellTemplate /DataGridTemplateColumn /DataGrid.Columns /DataGrid对于历史报警查询我们可以设计一个简单的过滤界面包含开始时间、结束时间、报警等级等筛选条件查询结果可以导出为CSV或Excel文件。这里的关键是将报警记录持久化到数据库如SQLite或SQL Server中并建立高效的索引以便快速查询。5. 案例四生产数据记录、报表与可视化分析数据记录与分析是提升生产效率、进行预防性维护的基础。本案例将实现一个将关键生产数据如产量、节拍、能耗、OEE周期性地记录到数据库并能够生成日报、周报等统计报表的功能模块。第一步设计数据记录表。我们使用SQLite作为本地轻量级数据库。-- 创建生产批次记录表 CREATE TABLE ProductionBatch ( BatchId TEXT PRIMARY KEY, ProductCode TEXT NOT NULL, StartTime DATETIME NOT NULL, EndTime DATETIME, PlannedQuantity INTEGER, ActualQuantity INTEGER DEFAULT 0, GoodQuantity INTEGER DEFAULT 0, Status TEXT CHECK(Status IN (Running, Completed, Aborted)) ); -- 创建周期数据快照表每分钟记录一次关键参数 CREATE TABLE DataSnapshot ( SnapshotId INTEGER PRIMARY KEY AUTOINCREMENT, BatchId TEXT, Timestamp DATETIME NOT NULL, TagId TEXT NOT NULL, TagValue REAL, FOREIGN KEY (BatchId) REFERENCES ProductionBatch(BatchId) );第二步实现数据记录服务。创建一个DataLoggingService它内部使用一个定时器周期性地从TagCache中读取需要记录的Tag值并批量插入数据库。using Microsoft.Data.Sqlite; public class DataLoggingService : IDataLoggingService { private readonly string _connectionString; private readonly System.Timers.Timer _loggingTimer; private readonly Liststring _tagsToLog; // 需要记录的TagId列表 public DataLoggingService(string dbPath, IEnumerablestring tagsToLog, int intervalSeconds 60) { _connectionString $Data Source{dbPath}; _tagsToLog tagsToLog.ToList(); _loggingTimer new System.Timers.Timer(intervalSeconds * 1000); _loggingTimer.Elapsed async (s, e) await LogDataAsync(); InitializeDatabase(); } private void InitializeDatabase() { using var connection new SqliteConnection(_connectionString); connection.Open(); // 执行上述CREATE TABLE语句如果表不存在 // ... } private async Task LogDataAsync() { var snapshotTime DateTime.Now; var currentBatchId GetCurrentRunningBatchId(); // 获取当前正在生产的批次号 var records new ListDataSnapshotRecord(); foreach (var tagId in _tagsToLog) { if (TagCache.TryGetValue(tagId, out var tag)) { records.Add(new DataSnapshotRecord { BatchId currentBatchId, Timestamp snapshotTime, TagId tagId, TagValue Convert.ToDouble(tag.Value) }); } } await BulkInsertDataSnapshotsAsync(records); } private async Task BulkInsertDataSnapshotsAsync(ListDataSnapshotRecord records) { if (records.Count 0) return; using var connection new SqliteConnection(_connectionString); await connection.OpenAsync(); using var transaction await connection.BeginTransactionAsync(); var command connection.CreateCommand(); command.CommandText INSERT INTO DataSnapshot (BatchId, Timestamp, TagId, TagValue) VALUES ($batchId, $timestamp, $tagId, $tagValue); foreach (var record in records) { command.Parameters.Clear(); command.Parameters.AddWithValue($batchId, (object)record.BatchId ?? DBNull.Value); command.Parameters.AddWithValue($timestamp, record.Timestamp); command.Parameters.AddWithValue($tagId, record.TagId); command.Parameters.AddWithValue($tagValue, record.TagValue); await command.ExecuteNonQueryAsync(); } await transaction.CommitAsync(); } public void StartLogging() _loggingTimer.Start(); public void StopLogging() _loggingTimer.Stop(); }第三步报表生成与可视化。我们可以使用ClosedXML或EPPlus库来生成Excel报表。例如生成一个生产批次总结报表public void GenerateBatchReport(string batchId, string outputPath) { using (var workbook new XLWorkbook()) { var worksheet workbook.Worksheets.Add(生产报告); // 查询数据库获取批次和快照数据 var batchInfo GetBatchInfo(batchId); var snapshots GetSnapshotsForBatch(batchId); // 填充报表标题和批次信息 worksheet.Cell(1, 1).Value $生产批次报告 - {batchId}; worksheet.Cell(3, 1).Value 产品代码:; worksheet.Cell(3, 2).Value batchInfo.ProductCode; worksheet.Cell(4, 1).Value 开始时间:; worksheet.Cell(4, 2).Value batchInfo.StartTime.ToString(yyyy-MM-dd HH:mm:ss); // ... 填充其他信息 // 创建数据表格 int row 7; worksheet.Cell(row, 1).Value 时间; worksheet.Cell(row, 2).Value 电机转速 (RPM); worksheet.Cell(row, 3).Value 温度 (°C); // ... 其他列标题 row; foreach (var snapshot in snapshots.OrderBy(s s.Timestamp)) { worksheet.Cell(row, 1).Value snapshot.Timestamp; // 根据TagId将值填入对应列这里需要根据数据结构进行映射 row; } // 添加图表以电机转速为例 var chart worksheet.AddChart(); chart.ChartType XLChartType.Line; chart.SetTitle($批次 {batchId} - 电机转速趋势); // 设置图表数据范围... chart.SetXAxis(null, 时间); chart.SetYAxis(null, 转速 (RPM)); workbook.SaveAs(outputPath); } }在应用程序内我们还可以集成图表控件让用户选择时间段和变量动态生成历史趋势图进行分析。结合报警数据和生产数据可以进一步分析故障发生前后的工艺参数变化为根因分析提供数据支持。6. 案例五基于OPC UA的跨平台数据集成与Web发布随着工业4.0和物联网的发展将车间数据安全、标准地提供给上层MES、ERP系统或远程监控中心变得日益重要。OPC UA开放平台通信统一架构正是为此而生的标准。本案例将展示如何在C#应用中集成OPC UA既作为客户端从设备读取数据也作为服务器将处理后的数据发布出去并简要介绍如何通过ASP.NET Core创建一个简单的Web监控页面。作为OPC UA客户端我们可以使用OPC基金会官方的.NET Standard库连接到现场的OPC UA服务器可能是Kepware、PLC内置服务器或PCHMI的OPC UA服务模块。using Opc.Ua; using Opc.Ua.Client; public class OpcUaClientService { private ApplicationConfiguration _config; private Session _session; public async Task ConnectAsync(string serverUrl) { _config new ApplicationConfiguration { ApplicationName IndustrialHMI Client, ApplicationType ApplicationType.Client, SecurityConfiguration new SecurityConfiguration { ApplicationCertificate new CertificateIdentifier { StoreType Directory }, TrustedPeerCertificates new CertificateTrustList { StoreType Directory }, // ... 其他安全配置 } }; await _config.Validate(ApplicationType.Client); var endpointDescription CoreClientUtils.SelectEndpoint(serverUrl, useSecurity: true); var endpointConfiguration EndpointConfiguration.Create(_config); var endpoint new ConfiguredEndpoint(null, endpointDescription, endpointConfiguration); _session await Session.Create( _config, endpoint, false, false, _config.ApplicationName, 60000, new UserIdentity(), null); Console.WriteLine($已连接到: {serverUrl}); } public async TaskDataValue ReadNodeAsync(string nodeId) { if (_session null) throw new InvalidOperationException(会话未连接); var readValueCollection new ReadValueIdCollection { new ReadValueId { NodeId new NodeId(nodeId), AttributeId Attributes.Value } }; var response await _session.ReadAsync(null, 0, TimestampsToReturn.Both, readValueCollection, CancellationToken.None); return response.Results[0]; } // ... 写入、订阅等方法 }作为OPC UA服务器我们也可以让自己的C#应用成为一个OPC UA服务器将我们处理好的生产数据如聚合后的OEE、报警状态发布出去供其他系统订阅。这需要使用OPC UA的服务器端库并定义自己的地址空间和变量节点。Web发布对于远程监控我们可以创建一个ASP.NET Core Web API提供安全的RESTful接口来获取实时数据、报警列表和历史数据。同时使用SignalR可以实现数据的实时推送。// 在ASP.NET Core项目中 [ApiController] [Route(api/[controller])] public class MachineDataController : ControllerBase { private readonly ICommsManager _commsManager; public MachineDataController(ICommsManager commsManager) { _commsManager commsManager; } [HttpGet(tags)] public IActionResult GetAllTags() { var tags _commsManager.GetAllTags(); // 获取所有Tag的当前值 return Ok(tags); } [HttpGet(alarms/active)] public IActionResult GetActiveAlarms() { var alarms _alarmManager.GetActiveAlarms(); return Ok(alarms); } }前端可以使用Vue.js、React或Blazor等技术调用这些API构建一个现代化的、响应式的监控看板。通过这种方式管理人员在办公室或手机上也能实时掌握生产现场的状态。安全是重中之重。无论是OPC UA通信还是Web API都必须实施严格的身份验证、授权和加密如HTTPS。OPC UA本身提供了基于证书和用户密码的复杂安全模型而Web API则需要使用JWT令牌等机制来确保只有授权用户才能访问。从桌面端的WPF深度定制到基于Web的跨平台访问C#与PCHMI或类似的工业通信组件的结合为工业自动化界面开发提供了从底层设备连接到顶层数据分析的全栈解决方案。每个案例中的代码都只是一个起点在实际项目中你需要根据具体的设备协议、性能要求和安全规范进行大量的优化和扩展。例如通信层的重连机制、数据压缩、前端界面的虚拟化列表以支持成千上万个数据点的高效渲染等。希望这些案例能为你自己的项目提供一个坚实的脚手架和清晰的思路。