简介这份资源面向工业自动化与物联网方向的C#开发者提供基于.NET Core的OPC UA开发套件覆盖OPC UA规范1.03版适合希望快速上手跨平台OPC UA通信、构建服务端与客户端应用的中级学习者。压缩包共195个文件以179个dll动态库为核心辅以4个exe示例程序、4个config配置文件、4个xml说明及4个ico图标整体约15.06MB体积轻便便于本地部署调试。内容包含Opc.Ua.Core等基础库以及SampleClient、BoilerClient、BoilerServer、ReferenceServer等示例分别演示客户端数据读写、变量订阅、方法调用以及锅炉模拟服务端与标准参考服务端的实现方式可帮助读者理解信息模型、安全模型与传输层协议。目前已有557人学习下载适合作为学习OPC UA通信机制、搭建工业数据交换方案的实践参考。1. 从一台数控机床的数据采集说起opc_C#OPCUA_.netcore_opcua客户端到底在做什么车间里一台数控机床跑了三年系统日志一直靠人工抄表。你想把它接进 MES第一步就是让上位机把机床 PLC 里的运行状态、主轴转速、报警码读出来。这时候绕不开 OPC UA——它不是某个软件而是一套跨平台、带安全模型的工业通信协议。标题里的opc_C#OPCUA_.netcore_opcua客户端本质就是用 C# 在 .NET Core 上写一个 OPC UA 客户端去连 PLC 或 OPC 服务器把节点数据读回来。覆盖 1.03 版指的是 OPC UA 规范里那套被广泛实现的 1.03 接口版本绝大多数西门子、倍福、三菱的服务器都兼容它。适合谁做上位机、设备联网、数据采集的 C# 工程师尤其是从 WinForm 转 .NET Core 的那批人。下面我按自己落地的顺序把选型、连接、读写、订阅、避坑全讲一遍。2. 选库与建工程.NET Core 下 OPC UA 客户端的第一行代码2.1 为什么是 OPCFoundation.NetStandard.Opc.UaC# 做 OPC UA 客户端能选的库其实不多。商业库有 Kepware 的 SDK、Unified Automation 的 .NET SDK功能全但授权费不低开源这边主流就是 OPC Foundation 官方维护的OPCFoundation.NetStandard.Opc.Ua系列包。它直接对应 1.03 规范.NET Standard 2.0/2.1 目标能在 .NET Core、.NET 5/6/7/8 上跑也能在 Linux 容器里跑——这点对现在做边缘网关的人很关键很多现场工控机已经换成 Linux 或 Docker 部署。我一般会装这几个包按职责拆开包名作用是否必装OPCFoundation.NetStandard.Opc.Ua.Client客户端会话、订阅、读写必装OPCFoundation.NetStandard.Opc.Ua.Configuration应用配置、证书管理必装OPCFoundation.NetStandard.Opc.Ua.Core协议栈核心被依赖自动装OPCFoundation.NetStandard.Opc.Ua.Server自己搭服务端时用按需装包命令dotnet add package OPCFoundation.NetStandard.Opc.Ua.Client dotnet add package OPCFoundation.NetStandard.Opc.Ua.Configuration参数说明不指定版本时 NuGet 拉最新稳定版但生产环境我建议锁版本比如--version 1.5.x因为 OPC UA 栈在证书校验、端点协商上有过行为变更跨版本升级偶尔会让原本能连的服务器连不上。锁版本是给自己留后悔药。2.2 建一个能跑起来的最小客户端工程新建控制台工程目标框架选net8.0或你现场支持的 LTS 版本dotnet new console -n OpcUaClientDemo cd OpcUaClientDemo然后在Program.cs里写最小连接逻辑。注意OPC UA 客户端启动前必须先有应用配置和证书否则连不上任何启用安全策略的服务器using Opc.Ua; using Opc.Ua.Client; using Opc.Ua.Configuration; // 1. 构建应用配置应用名、应用类型、证书存放目录 var appConfig new ApplicationConfiguration { ApplicationName OpcUaClientDemo, ApplicationType ApplicationType.Client, SecurityConfiguration new SecurityConfiguration { // 自动接受不受信任的服务器证书仅调试用 AutoAcceptUntrustedCertificates true, // 客户端自身证书存放目录 ApplicationCertificate new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/own }, TrustedIssuerCertificates new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/issuer }, TrustedPeerCertificates new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/trusted }, RejectedCertificateStore new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/rejected } }, TransportConfigurations new TransportConfigurationCollection(), TransportQuotas new TransportQuotas { OperationTimeout 15000 }, ClientConfiguration new ClientConfiguration { DefaultSessionTimeout 60000 } }; // 2. 校验并补全配置生成自签名证书 await appConfig.Validate(ApplicationType.Client); var application new ApplicationInstance { ApplicationConfiguration appConfig }; bool certOk await application.CheckApplicationInstanceCertificate(false, 2048); if (!certOk) throw new Exception(应用证书创建失败); // 3. 选择端点并建立会话 var endpointDescription CoreClientUtils.SelectEndpoint( appConfig, opc.tcp://192.168.1.10:4840, useSecurity: false); var endpointConfiguration EndpointConfiguration.Create(appConfig); var endpoint new ConfiguredEndpoint(null, endpointDescription, endpointConfiguration); var session await Session.Create( appConfig, endpoint, false, OpcUaClientDemo, 60000, new UserIdentity(new AnonymousIdentityToken()), null); Console.WriteLine($会话已建立SessionId{session.SessionId});逻辑说明第一步把证书目录、超时、会话时长这些参数集中配好避免散落在各处第二步CheckApplicationInstanceCertificate会在证书不存在时自动生成一张 2048 位自签名证书这是 OPC UA 安全握手的前提第三步SelectEndpoint会去服务器拉端点列表useSecurity: false表示先用无安全策略打通链路验证通了再上签名加密。参数说明OperationTimeout我一般设 15000 毫秒现场网络抖动大可以放到 30000DefaultSessionTimeout60000 是会话保活时间订阅场景下要配合KeepAliveInterval一起调。UserIdentity这里用匿名实际项目里西门子、倍福服务器常要求用户名密码换成new UserIdentity(user, pwd)即可。提示AutoAcceptUntrustedCertificates true只适合调试。生产环境必须把服务器证书导入pki/trusted否则等于把安全模型关掉了这在设备联网项目里是审计红线。3. 读、写、订阅三件事把 PLC 数据真正拿到手3.1 读节点NodeId 怎么找、批量读怎么写OPC UA 里所有数据都挂在节点上读数据就是给NodeId要值。NodeId 的格式是ns2;sMachine1.Speed这种ns是命名空间索引s后面是标识符。找 NodeId 有两个办法一是用 UaExpert 这类客户端连上去浏览地址空间把 NodeId 复制出来二是问 PLC 工程师要变量表西门子 TIA 里导出的符号表能直接映射。批量读比单点读效率高得多一次请求拿一组节点// 构造要读的节点集合 var nodesToRead new ReadValueIdCollection { new ReadValueId { NodeId new NodeId(Machine1.Speed, 2), AttributeId Attributes.Value }, new ReadValueId { NodeId new NodeId(Machine1.Status, 2), AttributeId Attributes.Value }, new ReadValueId { NodeId new NodeId(Machine1.AlarmCode, 2), AttributeId Attributes.Value } }; // 一次请求读回全部 session.Read(null, 0, TimestampsToReturn.Both, nodesToRead, out DataValueCollection results, out DiagnosticInfoCollection diagnostics); for (int i 0; i results.Count; i) { var v results[i]; Console.WriteLine($节点{i}: 值{v.Value}, 状态{v.StatusCode}, 时间{v.SourceTimestamp}); }逻辑说明Read的第一个参数是请求上下文传 null 用默认第二个 0 是maxAge表示接受缓存的最大年龄0 代表强制从设备读实时值TimestampsToReturn.Both同时返回源时间戳和服务器时间戳做时序数据入库时源时间戳更准。参数说明maxAge设 0 会增加服务器负担但数据实时如果只是做趋势展示设 1000 毫秒能显著降低 PLC 通信压力。StatusCode一定要判Good才是有效值BadNodeIdUnknown说明 NodeId 写错了BadNotConnected说明会话断了。3.2 写节点类型不匹配是最常见的翻车点写值用Write坑主要在数据类型。OPC UA 是强类型的你写int进去服务器期望short就会返回BadTypeMismatchvar writeValues new WriteValueCollection { new WriteValue { NodeId new NodeId(Machine1.SetSpeed, 2), AttributeId Attributes.Value, Value new DataValue(new Variant((short)1500)) // 注意显式转 short } }; session.Write(null, writeValues, out StatusCodeCollection writeResults, out DiagnosticInfoCollection diag); foreach (var sc in writeResults) Console.WriteLine($写入结果: {sc});逻辑说明Variant是 OPC UA 的值容器构造时传入的 CLR 类型决定了线上类型。写之前最好先Read一次该节点看返回值的实际类型再决定用什么类型写。参数说明(short)1500这种显式转换不是多余很多 PLC 的整型变量是Int16C# 默认字面量是int不转就类型不匹配。浮点同理float和double要分清。3.3 订阅别用轮询用 Subscription MonitoredItem做设备状态监控轮询读是下策节点一多就把服务器压垮。正确姿势是订阅服务器端数据变化时主动推给你// 创建订阅发布间隔 500ms var subscription new Subscription(session.DefaultSubscription) { PublishingInterval 500, KeepAliveCount 10, LifetimeCount 30, MaxNotificationsPerPublish 1000, PublishingEnabled true }; session.AddSubscription(subscription); await subscription.CreateAsync(); // 给订阅挂监控项 var item new MonitoredItem(subscription.DefaultItem) { DisplayName Machine1.Speed, StartNodeId new NodeId(Machine1.Speed, 2), AttributeId Attributes.Value, SamplingInterval 200, QueueSize 10, DiscardOldest true }; item.Notification (monitoredItem, args) { foreach (var value in args.Notification.Value) Console.WriteLine($变化通知: {value.Value} {value.SourceTimestamp}); }; subscription.AddItem(item); await subscription.ApplyChangesAsync();逻辑说明PublishingInterval是服务器向客户端推送的周期SamplingInterval是服务器去 PLC 采样的周期两者独立。QueueSize是监控项缓存队列长度DiscardOldest true表示队列满时丢最旧的保证你拿到的是较新数据。参数说明KeepAliveCount和LifetimeCount决定订阅保活一般LifetimeCount至少是KeepAliveCount的 3 倍。SamplingInterval不要小于 PLC 的扫描周期否则采到的都是重复值白白增加负载。现场经验是采样 200 到 500 毫秒发布 500 到 1000 毫秒兼顾实时和负载。注意订阅回调是在通信线程上触发的别在里面做耗时操作或直接更新 UI。我一般把值塞进ConcurrentQueue另起线程消费这是上位机不卡界面的基本操作。4. 避坑与排查连接、证书、订阅失效的 5 个血泪现场4.1 现象连不上报 BadSecurityChecksFailed原因客户端和服务器证书互不信任。OPC UA 1.03 的安全策略要求双向证书校验客户端证书没被服务器信任或服务器证书没进客户端信任列表握手就断。解决调试期先确认AutoAcceptUntrustedCertificates生效生产环境把服务器证书从pki/rejected目录挪到pki/trusted重启客户端。反过来把客户端证书pki/own下的.der文件交给服务器管理员导入信任列表。这一步在西门子、倍福服务器上都要做缺一不可。4.2 现象能连上但读值全是 BadNodeIdUnknown原因NodeId 的命名空间索引写错了。ns2里的 2 是服务器地址空间里的命名空间索引不同服务器、不同工程文件里这个索引会变不是固定的。解决用 UaExpert 连上去在地址空间树里找到目标变量右键复制 NodeId别手敲。如果服务器重启后索引变了说明命名空间是动态注册的这种情况要在连接后先读Server_NamespaceArray节点按 URI 动态解析索引而不是写死数字。4.3 现象订阅建了但收不到通知原因SamplingInterval设得比PublishingInterval还大或者监控项的QueueSize为 0或者服务器端该节点不支持订阅比如某些静态配置节点。解决先确认SamplingInterval PublishingIntervalQueueSize至少设 1建议 10用 UaExpert 对同一节点建订阅验证服务器是否支持。如果服务器本身不支持订阅只能退回轮询但要控制频率。4.4 现象跑几小时后会话断开重连后订阅全丢原因会话超时或网络闪断OPC UA 会话断了之后挂在会话上的订阅不会自动恢复。解决给Session挂KeepAlive事件和SessionClosing事件检测到断开后走重连逻辑重连成功后重建订阅和监控项。我一般封装一个ReconnectHandler把订阅配置存成模板重连后按模板重建避免手工恢复漏项。4.5 现象Linux 容器里跑证书生成失败原因容器内没有写权限或pki目录没挂载出来CheckApplicationInstanceCertificate写证书时抛异常。解决把pki目录挂成 volume确保容器内进程对目录有读写权限或者提前在镜像构建阶段生成好证书运行时只读挂载。容器里跑 OPC UA 客户端证书持久化是必须的否则每次重启都换证书服务器信任列表就废了。5. 进阶把客户端做成能长期跑的数据采集服务5.1 用依赖注入和后台服务托管客户端控制台 demo 只能验证链路真正上线要跑成 Windows 服务或 Linux systemd 服务。.NET Core 的BackgroundService是标准做法public class OpcUaWorker : BackgroundService { private readonly ILoggerOpcUaWorker _logger; private ISession _session; public OpcUaWorker(ILoggerOpcUaWorker logger) _logger logger; protected override async Task ExecuteAsync(CancellationToken token) { while (!token.IsCancellationRequested) { try { if (_session null || !_session.Connected) { _session await ConnectAsync(); // 封装好的连接方法 await SubscribeAsync(_session); // 重建订阅 } await Task.Delay(5000, token); // 5 秒巡检一次 } catch (Exception ex) { _logger.LogError(ex, OPC UA 连接异常准备重连); await Task.Delay(10000, token); } } } }逻辑说明外层 while 做连接巡检断了就重连并重建订阅Task.Delay给重连留缓冲避免疯狂重试打爆服务器。把连接、订阅封装成独立方法重连逻辑和首次连接复用同一套代码。参数说明巡检间隔 5000 毫秒适合大多数现场重试间隔 10000 毫秒是经验值太短会在服务器重启时形成连接风暴。日志一定要打OPC UA 的异常信息里StatusCode是排查关键。5.2 数据落地与验证怎么确认采集是对的采集服务跑起来后验证不能只看日志。我的做法是三层验证第一层用 UaExpert 同时连同一服务器对比同一节点的值和变化频率第二层把采集值写进时序库InfluxDB、TDengine 都行看曲线是否连续、有无断点第三层制造一次真实变化比如手动改 PLC 变量看订阅通知是否在预期时间内到达。验证项方法合格标准值正确性UaExpert 对比数值一致实时性手动触发变化通知延迟 发布周期 × 2连续性时序库曲线无异常断点重连拔网线再插30 秒内恢复订阅5.3 一个我踩过的坑别在回调里同步写数据库早期我把数据库写入直接放在订阅回调里节点一多回调线程被阻塞服务器推送开始堆积最后订阅被服务器判定超时踢掉。后来改成回调只入内存队列独立消费者批量写库问题消失。这个习惯我保持到现在OPC UA 回调里只做最轻的事重活全部异步化。做设备联网这行客户端能连上只是起点能连续跑三个月不出事才算交付。我现在的习惯是任何 OPC UA 客户端上线前先让它空跑 72 小时盯着重连日志和内存占用确认没有缓慢泄漏再接生产数据。希望帮到你。本文还有配套的精品资源点击获取
C# .NET Core OPC UA客户端开发实战：连接、读写、订阅与避坑
简介这份资源面向工业自动化与物联网方向的C#开发者提供基于.NET Core的OPC UA开发套件覆盖OPC UA规范1.03版适合希望快速上手跨平台OPC UA通信、构建服务端与客户端应用的中级学习者。压缩包共195个文件以179个dll动态库为核心辅以4个exe示例程序、4个config配置文件、4个xml说明及4个ico图标整体约15.06MB体积轻便便于本地部署调试。内容包含Opc.Ua.Core等基础库以及SampleClient、BoilerClient、BoilerServer、ReferenceServer等示例分别演示客户端数据读写、变量订阅、方法调用以及锅炉模拟服务端与标准参考服务端的实现方式可帮助读者理解信息模型、安全模型与传输层协议。目前已有557人学习下载适合作为学习OPC UA通信机制、搭建工业数据交换方案的实践参考。1. 从一台数控机床的数据采集说起opc_C#OPCUA_.netcore_opcua客户端到底在做什么车间里一台数控机床跑了三年系统日志一直靠人工抄表。你想把它接进 MES第一步就是让上位机把机床 PLC 里的运行状态、主轴转速、报警码读出来。这时候绕不开 OPC UA——它不是某个软件而是一套跨平台、带安全模型的工业通信协议。标题里的opc_C#OPCUA_.netcore_opcua客户端本质就是用 C# 在 .NET Core 上写一个 OPC UA 客户端去连 PLC 或 OPC 服务器把节点数据读回来。覆盖 1.03 版指的是 OPC UA 规范里那套被广泛实现的 1.03 接口版本绝大多数西门子、倍福、三菱的服务器都兼容它。适合谁做上位机、设备联网、数据采集的 C# 工程师尤其是从 WinForm 转 .NET Core 的那批人。下面我按自己落地的顺序把选型、连接、读写、订阅、避坑全讲一遍。2. 选库与建工程.NET Core 下 OPC UA 客户端的第一行代码2.1 为什么是 OPCFoundation.NetStandard.Opc.UaC# 做 OPC UA 客户端能选的库其实不多。商业库有 Kepware 的 SDK、Unified Automation 的 .NET SDK功能全但授权费不低开源这边主流就是 OPC Foundation 官方维护的OPCFoundation.NetStandard.Opc.Ua系列包。它直接对应 1.03 规范.NET Standard 2.0/2.1 目标能在 .NET Core、.NET 5/6/7/8 上跑也能在 Linux 容器里跑——这点对现在做边缘网关的人很关键很多现场工控机已经换成 Linux 或 Docker 部署。我一般会装这几个包按职责拆开包名作用是否必装OPCFoundation.NetStandard.Opc.Ua.Client客户端会话、订阅、读写必装OPCFoundation.NetStandard.Opc.Ua.Configuration应用配置、证书管理必装OPCFoundation.NetStandard.Opc.Ua.Core协议栈核心被依赖自动装OPCFoundation.NetStandard.Opc.Ua.Server自己搭服务端时用按需装包命令dotnet add package OPCFoundation.NetStandard.Opc.Ua.Client dotnet add package OPCFoundation.NetStandard.Opc.Ua.Configuration参数说明不指定版本时 NuGet 拉最新稳定版但生产环境我建议锁版本比如--version 1.5.x因为 OPC UA 栈在证书校验、端点协商上有过行为变更跨版本升级偶尔会让原本能连的服务器连不上。锁版本是给自己留后悔药。2.2 建一个能跑起来的最小客户端工程新建控制台工程目标框架选net8.0或你现场支持的 LTS 版本dotnet new console -n OpcUaClientDemo cd OpcUaClientDemo然后在Program.cs里写最小连接逻辑。注意OPC UA 客户端启动前必须先有应用配置和证书否则连不上任何启用安全策略的服务器using Opc.Ua; using Opc.Ua.Client; using Opc.Ua.Configuration; // 1. 构建应用配置应用名、应用类型、证书存放目录 var appConfig new ApplicationConfiguration { ApplicationName OpcUaClientDemo, ApplicationType ApplicationType.Client, SecurityConfiguration new SecurityConfiguration { // 自动接受不受信任的服务器证书仅调试用 AutoAcceptUntrustedCertificates true, // 客户端自身证书存放目录 ApplicationCertificate new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/own }, TrustedIssuerCertificates new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/issuer }, TrustedPeerCertificates new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/trusted }, RejectedCertificateStore new CertificateIdentifier { StoreType CertificateStoreType.Directory, StorePath pki/rejected } }, TransportConfigurations new TransportConfigurationCollection(), TransportQuotas new TransportQuotas { OperationTimeout 15000 }, ClientConfiguration new ClientConfiguration { DefaultSessionTimeout 60000 } }; // 2. 校验并补全配置生成自签名证书 await appConfig.Validate(ApplicationType.Client); var application new ApplicationInstance { ApplicationConfiguration appConfig }; bool certOk await application.CheckApplicationInstanceCertificate(false, 2048); if (!certOk) throw new Exception(应用证书创建失败); // 3. 选择端点并建立会话 var endpointDescription CoreClientUtils.SelectEndpoint( appConfig, opc.tcp://192.168.1.10:4840, useSecurity: false); var endpointConfiguration EndpointConfiguration.Create(appConfig); var endpoint new ConfiguredEndpoint(null, endpointDescription, endpointConfiguration); var session await Session.Create( appConfig, endpoint, false, OpcUaClientDemo, 60000, new UserIdentity(new AnonymousIdentityToken()), null); Console.WriteLine($会话已建立SessionId{session.SessionId});逻辑说明第一步把证书目录、超时、会话时长这些参数集中配好避免散落在各处第二步CheckApplicationInstanceCertificate会在证书不存在时自动生成一张 2048 位自签名证书这是 OPC UA 安全握手的前提第三步SelectEndpoint会去服务器拉端点列表useSecurity: false表示先用无安全策略打通链路验证通了再上签名加密。参数说明OperationTimeout我一般设 15000 毫秒现场网络抖动大可以放到 30000DefaultSessionTimeout60000 是会话保活时间订阅场景下要配合KeepAliveInterval一起调。UserIdentity这里用匿名实际项目里西门子、倍福服务器常要求用户名密码换成new UserIdentity(user, pwd)即可。提示AutoAcceptUntrustedCertificates true只适合调试。生产环境必须把服务器证书导入pki/trusted否则等于把安全模型关掉了这在设备联网项目里是审计红线。3. 读、写、订阅三件事把 PLC 数据真正拿到手3.1 读节点NodeId 怎么找、批量读怎么写OPC UA 里所有数据都挂在节点上读数据就是给NodeId要值。NodeId 的格式是ns2;sMachine1.Speed这种ns是命名空间索引s后面是标识符。找 NodeId 有两个办法一是用 UaExpert 这类客户端连上去浏览地址空间把 NodeId 复制出来二是问 PLC 工程师要变量表西门子 TIA 里导出的符号表能直接映射。批量读比单点读效率高得多一次请求拿一组节点// 构造要读的节点集合 var nodesToRead new ReadValueIdCollection { new ReadValueId { NodeId new NodeId(Machine1.Speed, 2), AttributeId Attributes.Value }, new ReadValueId { NodeId new NodeId(Machine1.Status, 2), AttributeId Attributes.Value }, new ReadValueId { NodeId new NodeId(Machine1.AlarmCode, 2), AttributeId Attributes.Value } }; // 一次请求读回全部 session.Read(null, 0, TimestampsToReturn.Both, nodesToRead, out DataValueCollection results, out DiagnosticInfoCollection diagnostics); for (int i 0; i results.Count; i) { var v results[i]; Console.WriteLine($节点{i}: 值{v.Value}, 状态{v.StatusCode}, 时间{v.SourceTimestamp}); }逻辑说明Read的第一个参数是请求上下文传 null 用默认第二个 0 是maxAge表示接受缓存的最大年龄0 代表强制从设备读实时值TimestampsToReturn.Both同时返回源时间戳和服务器时间戳做时序数据入库时源时间戳更准。参数说明maxAge设 0 会增加服务器负担但数据实时如果只是做趋势展示设 1000 毫秒能显著降低 PLC 通信压力。StatusCode一定要判Good才是有效值BadNodeIdUnknown说明 NodeId 写错了BadNotConnected说明会话断了。3.2 写节点类型不匹配是最常见的翻车点写值用Write坑主要在数据类型。OPC UA 是强类型的你写int进去服务器期望short就会返回BadTypeMismatchvar writeValues new WriteValueCollection { new WriteValue { NodeId new NodeId(Machine1.SetSpeed, 2), AttributeId Attributes.Value, Value new DataValue(new Variant((short)1500)) // 注意显式转 short } }; session.Write(null, writeValues, out StatusCodeCollection writeResults, out DiagnosticInfoCollection diag); foreach (var sc in writeResults) Console.WriteLine($写入结果: {sc});逻辑说明Variant是 OPC UA 的值容器构造时传入的 CLR 类型决定了线上类型。写之前最好先Read一次该节点看返回值的实际类型再决定用什么类型写。参数说明(short)1500这种显式转换不是多余很多 PLC 的整型变量是Int16C# 默认字面量是int不转就类型不匹配。浮点同理float和double要分清。3.3 订阅别用轮询用 Subscription MonitoredItem做设备状态监控轮询读是下策节点一多就把服务器压垮。正确姿势是订阅服务器端数据变化时主动推给你// 创建订阅发布间隔 500ms var subscription new Subscription(session.DefaultSubscription) { PublishingInterval 500, KeepAliveCount 10, LifetimeCount 30, MaxNotificationsPerPublish 1000, PublishingEnabled true }; session.AddSubscription(subscription); await subscription.CreateAsync(); // 给订阅挂监控项 var item new MonitoredItem(subscription.DefaultItem) { DisplayName Machine1.Speed, StartNodeId new NodeId(Machine1.Speed, 2), AttributeId Attributes.Value, SamplingInterval 200, QueueSize 10, DiscardOldest true }; item.Notification (monitoredItem, args) { foreach (var value in args.Notification.Value) Console.WriteLine($变化通知: {value.Value} {value.SourceTimestamp}); }; subscription.AddItem(item); await subscription.ApplyChangesAsync();逻辑说明PublishingInterval是服务器向客户端推送的周期SamplingInterval是服务器去 PLC 采样的周期两者独立。QueueSize是监控项缓存队列长度DiscardOldest true表示队列满时丢最旧的保证你拿到的是较新数据。参数说明KeepAliveCount和LifetimeCount决定订阅保活一般LifetimeCount至少是KeepAliveCount的 3 倍。SamplingInterval不要小于 PLC 的扫描周期否则采到的都是重复值白白增加负载。现场经验是采样 200 到 500 毫秒发布 500 到 1000 毫秒兼顾实时和负载。注意订阅回调是在通信线程上触发的别在里面做耗时操作或直接更新 UI。我一般把值塞进ConcurrentQueue另起线程消费这是上位机不卡界面的基本操作。4. 避坑与排查连接、证书、订阅失效的 5 个血泪现场4.1 现象连不上报 BadSecurityChecksFailed原因客户端和服务器证书互不信任。OPC UA 1.03 的安全策略要求双向证书校验客户端证书没被服务器信任或服务器证书没进客户端信任列表握手就断。解决调试期先确认AutoAcceptUntrustedCertificates生效生产环境把服务器证书从pki/rejected目录挪到pki/trusted重启客户端。反过来把客户端证书pki/own下的.der文件交给服务器管理员导入信任列表。这一步在西门子、倍福服务器上都要做缺一不可。4.2 现象能连上但读值全是 BadNodeIdUnknown原因NodeId 的命名空间索引写错了。ns2里的 2 是服务器地址空间里的命名空间索引不同服务器、不同工程文件里这个索引会变不是固定的。解决用 UaExpert 连上去在地址空间树里找到目标变量右键复制 NodeId别手敲。如果服务器重启后索引变了说明命名空间是动态注册的这种情况要在连接后先读Server_NamespaceArray节点按 URI 动态解析索引而不是写死数字。4.3 现象订阅建了但收不到通知原因SamplingInterval设得比PublishingInterval还大或者监控项的QueueSize为 0或者服务器端该节点不支持订阅比如某些静态配置节点。解决先确认SamplingInterval PublishingIntervalQueueSize至少设 1建议 10用 UaExpert 对同一节点建订阅验证服务器是否支持。如果服务器本身不支持订阅只能退回轮询但要控制频率。4.4 现象跑几小时后会话断开重连后订阅全丢原因会话超时或网络闪断OPC UA 会话断了之后挂在会话上的订阅不会自动恢复。解决给Session挂KeepAlive事件和SessionClosing事件检测到断开后走重连逻辑重连成功后重建订阅和监控项。我一般封装一个ReconnectHandler把订阅配置存成模板重连后按模板重建避免手工恢复漏项。4.5 现象Linux 容器里跑证书生成失败原因容器内没有写权限或pki目录没挂载出来CheckApplicationInstanceCertificate写证书时抛异常。解决把pki目录挂成 volume确保容器内进程对目录有读写权限或者提前在镜像构建阶段生成好证书运行时只读挂载。容器里跑 OPC UA 客户端证书持久化是必须的否则每次重启都换证书服务器信任列表就废了。5. 进阶把客户端做成能长期跑的数据采集服务5.1 用依赖注入和后台服务托管客户端控制台 demo 只能验证链路真正上线要跑成 Windows 服务或 Linux systemd 服务。.NET Core 的BackgroundService是标准做法public class OpcUaWorker : BackgroundService { private readonly ILoggerOpcUaWorker _logger; private ISession _session; public OpcUaWorker(ILoggerOpcUaWorker logger) _logger logger; protected override async Task ExecuteAsync(CancellationToken token) { while (!token.IsCancellationRequested) { try { if (_session null || !_session.Connected) { _session await ConnectAsync(); // 封装好的连接方法 await SubscribeAsync(_session); // 重建订阅 } await Task.Delay(5000, token); // 5 秒巡检一次 } catch (Exception ex) { _logger.LogError(ex, OPC UA 连接异常准备重连); await Task.Delay(10000, token); } } } }逻辑说明外层 while 做连接巡检断了就重连并重建订阅Task.Delay给重连留缓冲避免疯狂重试打爆服务器。把连接、订阅封装成独立方法重连逻辑和首次连接复用同一套代码。参数说明巡检间隔 5000 毫秒适合大多数现场重试间隔 10000 毫秒是经验值太短会在服务器重启时形成连接风暴。日志一定要打OPC UA 的异常信息里StatusCode是排查关键。5.2 数据落地与验证怎么确认采集是对的采集服务跑起来后验证不能只看日志。我的做法是三层验证第一层用 UaExpert 同时连同一服务器对比同一节点的值和变化频率第二层把采集值写进时序库InfluxDB、TDengine 都行看曲线是否连续、有无断点第三层制造一次真实变化比如手动改 PLC 变量看订阅通知是否在预期时间内到达。验证项方法合格标准值正确性UaExpert 对比数值一致实时性手动触发变化通知延迟 发布周期 × 2连续性时序库曲线无异常断点重连拔网线再插30 秒内恢复订阅5.3 一个我踩过的坑别在回调里同步写数据库早期我把数据库写入直接放在订阅回调里节点一多回调线程被阻塞服务器推送开始堆积最后订阅被服务器判定超时踢掉。后来改成回调只入内存队列独立消费者批量写库问题消失。这个习惯我保持到现在OPC UA 回调里只做最轻的事重活全部异步化。做设备联网这行客户端能连上只是起点能连续跑三个月不出事才算交付。我现在的习惯是任何 OPC UA 客户端上线前先让它空跑 72 小时盯着重连日志和内存占用确认没有缓慢泄漏再接生产数据。希望帮到你。本文还有配套的精品资源点击获取