简介这套基于西门子官方OPC UA客户端源代码整理的实例工程以C#语言编写面向需要与SINUMERIK 840Dsl高端数控系统完成数据交换的工业通信工程师与机床集成开发人员主要解决生产现场设备数据采集、运行状态监控和工艺参数读写等实际问题。压缩包共68个文件、约1.29MB文件构成以C#源文件、工程配置文件、WinForms界面图片和OPC UA动态库为主另附README与License等说明文档目录结构清晰便于按需定位。项目中的OpcUaHelper-master封装了节点浏览、订阅、读写调用等客户端常用操作并涉及证书配置和安全策略处理可直接在Visual Studio中编译运行作为对接840Dsl的二次开发模板。该实例已有646人学习浏览能帮助开发者绕过繁琐的SDK细节快速验证OPC UA通信方案并减少重复开发工作量顺利投入到机床数据监控与集成项目中。 开头我就直说OPC UAOPC Unified Architecture的实例程序网上一搜一大把但大部分是官方Demo的搬运要么架构太复杂、要么文档跟不上真正能让你在半小时内跑通、并且搞清楚每一步在干什么的资料反而是稀缺货。我自己做工业数据采集和设备联网项目时被OPC UA的证书、端点、命名空间折腾过不少回所以今天这篇不打算给你堆概念直接把一套可以落地的“OPC UA最小实例”拆开讲先用C#把服务器和客户端跑起来再用Node-RED做可视化验证最后把现场最容易踩的坑一次性说清。这篇文章适合谁准备做设备数据采集的工程师、正在研究工业物联网通信的开发者、以及被OPC UA各种概念绕晕但急需一个可运行程序作为参考的朋友。你不需要对OPC UA有很深的了解跟着步骤走就能跑通但我会尽量把背后的原理也讲透让你不是“只会复制粘贴”。1. 动手前先把方向定清楚OPC UA到底解决了什么问题很多初学者一上来就找代码结果被地址空间、订阅、方法调用这些概念砸晕。先花几分钟把OPC UA的定位搞清楚后面写代码会顺畅得多。1.1 OPC UA不是OPC DA的简单升级老一代的OPC DA基于Windows的COM/DCOM技术设备厂商想把数据暴露给上位机就得在Windows机器上配一堆DCOM权限跨网络访问更是噩梦。OPC UA从根上换了一套设计不再依赖COM改为基于TCP或HTTP的二进制/XML协议所以它能跑在Linux、Windows、嵌入式设备上这也就是为什么它在智能制造、边缘网关场景里越来越火。从实例程序的角度你只需要记住一个核心模型服务器Server暴露数据客户端Client读写数据两边通过“端点”建立连接。数据在服务器里以“节点”的形式存在组织成一棵类似文件目录的树这就是所谓的“地址空间”。理解了这个你写客户端就是在找节点、读节点、订阅节点写服务器就是在往地址空间里塞节点。1.2 什么场景才需要自己写实例程序官方SDK自带Sample但很多人看完依然不会写自己的程序原因在于Sample覆盖了太多边界情况。我根据实际项目经验把典型需求归成三类数据采集型你的应用作为客户端去连PLC、机床、传感器的OPC UA服务器定时读数据或订阅变化。这是最常见的场景Node-RED、Python、C#都很适合。设备接入型你的设备或网关作为服务器把采集到的数据统一暴露给MES、SCADA等上位系统。这时需要自己定义地址空间和节点结构。协议转换型一边用Modbus、S7等协议采集底层数据一边用OPC UA暴露出去典型的边缘网关做法。这类通常要同时写服务器和客户端逻辑。这篇实例会覆盖前两类的最小实现第三类只需要把两段代码拼起来即可。1.3 技术选型C#、Python还是Node-RED选型没有绝对答案但可以按场景快速判断选型方案优点缺点适合场景C# OPCFoundation.NetStandard.Opc.Ua官方原生支持、功能完整、类型安全代码量偏大、学习曲线略陡正式项目、Windows/Linux服务Python opcua-asyncio上手快、代码简短、调试方便性能和大数据量场景弱一些原型验证、数据采集脚本Node-RED node-red-contrib-opcua图形化、零代码、联调效率高业务逻辑复杂时难维护快速演示、边缘网关、可视化我个人建议正式的数据采集服务用C#快速验证用Node-REDPython适合做算法验证和临时脚本。下面先讲C#版本的最小实例。2. 基于C#快速搭建一个OPC UA服务器实例C#实现OPC UA官方库是OPCFoundation.NetStandard.Opc.Ua它在NuGet上分为Server和Client两个主要包如果你只是写服务器引用OPCFoundation.NetStandard.Opc.Ua.Server就够了。2.1 创建项目和引入依赖我用的是.NET 6/8Visual Studio或命令行都可以。先建一个控制台应用dotnet new console -n OpcUaDemoServer cd OpcUaDemoServer dotnet add package OPCFoundation.NetStandard.Opc.Ua.Server这个包会自动带上依赖的核心库。如果你在写客户端单独引用OPCFoundation.NetStandard.Opc.Ua.Client。NuGet上还有老版的OPCFoundation.NetStandard.Opc.Ua全量包都能用但拆分后的包结构更清晰。2.2 最小服务器的完整代码下面这段代码是我实际项目中抽出骨架后的精简版核心只有三步创建应用、配置端点、添加数据节点。using Opc.Ua; using Opc.Ua.Server; var application new ApplicationInstance { ApplicationName OpcUaDemoServer, ApplicationType ApplicationType.Server, ApplicationUri urn:demo:opcua:server, ProductUri urn:demo:opcua:product }; // 自动生成并管理应用证书跳过证书逻辑的繁琐细节 var certificate await application.LoadApplicationCertificate(false); var config new ApplicationConfiguration { ApplicationUri application.ApplicationUri, ApplicationName application.ApplicationName, ApplicationType ApplicationType.Server, ServerConfiguration new ServerConfiguration { // 默认安全策略先放开方便本地调试 SecurityPolicies new StringCollection { SecurityPolicies.None, SecurityPolicies.Basic256Sha256 } }, TransportConfigurations new TransportConfigurationCollection(), TransportQuotas new TransportQuotas { OperationTimeout 60000 }, ClientConfiguration new ClientConfiguration { DefaultSessionTimeout 60000 }, TraceConfiguration new TraceConfiguration(), CertificateValidator new CertificateValidator(), SecurityConfiguration new SecurityConfiguration { ApplicationCertificate new CertificateIdentifier { StoreType CertificateStoreType.X509Store, StorePath CurrentUser\\UA_MachineKeys, SubjectName application.ApplicationUri } } }; var server new DemoNodeManager(application, config); await server.StartAsync(); Console.ReadLine(); await server.StopAsync();DemoNodeManager是核心它告诉服务器你的地址空间里有哪些节点。下面是一个最简实现在命名空间urn:demo:opcua:server下添加了一个可读写的模拟温度变量using Opc.Ua; using Opc.Ua.Server; public class DemoNodeManager : StandardNodeManager { private BaseDataVariableState _temperatureState; public DemoNodeManager(ApplicationInstance application, ApplicationConfiguration configuration) : base(application, configuration, null) { } protected override void OnCreateAddressSpace(IDictionaryNodeId, IListIReference externalReferences) { base.OnCreateAddressSpace(externalReferences); // 创建一个自定义命名空间索引一般为20是OPC UA内置1是服务器自身 var namespaceIndex NamespaceUris.GetIndexOrAppend(urn:demo:opcua:server); // 对象节点相当于文件夹 var folder new FolderState(null, new NodeId(Demo, namespaceIndex)); folder.BrowseName new QualifiedName(Demo, namespaceIndex); folder.DisplayName new LocalizedText(Demo); ((BaseInstanceState)folder).ReferenceTypeId ReferenceTypeIds.Organizes; ((BaseInstanceState)folder).TypeDefinitionId ObjectTypeIds.FolderType; folder.PostConstruct(this); AddPredefinedNode(folder); // 模拟变量温度 _temperatureState new BaseDataVariableState(null, new NodeId(Temperature, namespaceIndex)) { BrowseName new QualifiedName(Temperature, namespaceIndex), DisplayName new LocalizedText(Temperature), DataType DataTypeIds.Double, Value 25.0, AccessLevel AccessLevels.CurrentReadOrWrite, UserAccessLevel AccessLevels.CurrentReadOrWrite }; _temperatureState.PostConstruct(this); folder.AddComponent(_temperatureState); AddPredefinedNode(_temperatureState); // 用定时器模拟工件温度波动 var timer new System.Timers.Timer(1000); timer.Elapsed (s, e) { _temperatureState.Value 25.0 Random.Shared.NextDouble() * 15.0; _temperatureState.ClearChangeMasks(this, false); }; timer.Start(); } }这里有几个新手容易踩的细节命名空间索引NamespaceUris.GetIndexOrAppend按顺序分配索引第一个自定义命名空间通常是2。客户端访问节点时写的ns2;sTemperature这里的2就是这个索引。如果你加了多个命名空间索引会变所以客户端代码里最好通过服务器返回的命名空间数组去动态解析别硬编码。ValueChanged的必要性服务器不会每时每刻广播变量变化你必须在赋值后调用ClearChangeMasks它底层会触发监控项的“数据变化”通知。忘了这步客户端订阅会一直收不到更新。证书是个大坑第一版调试建议设置SecurityPolicies包含None客户端用无加密方式连接省去证书信任的麻烦。正式上线再换成Basic256Sha256并把证书加入对方信任列表。运行后控制台会输出端点地址一般是opc.tcp://localhost:62541/。如果你的机器有多个网卡可能显示的是IP或主机名客户端需要按实际地址访问。3. 客户端实例从连接、读变量到订阅变化服务器起来了接下来写一个C#客户端。它能帮你验证服务器是否正常也是后面做数据采集服务的基础。3.1 最小客户端实现先新建一个控制台项目引用客户端包dotnet new console -n OpcUaDemoClient cd OpcUaDemoClient dotnet add package OPCFoundation.NetStandard.Opc.Ua.Client核心代码里连接和读值大概是这样的using Opc.Ua; using Opc.Ua.Configuration; using Opc.Ua.Client; var endpointUrl opc.tcp://localhost:62541/; // 匿名连接安全策略为None本地调试最省事 var endpoint CoreClientUtils.SelectEndpoint(endpointUrl, useSecurity: false); using var session await Session.Create( new ApplicationConfiguration { ApplicationName OpcUaDemoClient, ApplicationType ApplicationType.Client, SecurityConfiguration new SecurityConfiguration { ApplicationCertificate new CertificateIdentifier { StoreType CertificateStoreType.X509Store, StorePath CurrentUser\\UA_MachineKeys } } }, new ConfiguredEndpoint(null, endpoint, EndpointConfiguration.Create()), false, demo-client, 30000, new UserIdentity(new AnonymousIdentityToken()), null ); // 读取服务器上的命名空间数组动态解析索引 var namespaceArray (string[])await session.ReadValueAsync(new NodeId(VariableIds.Server_NamespaceArray)); var demoNsIndex Array.IndexOf(namespaceArray, urn:demo:opcua:server); // 读取温度值 var tempNodeId new NodeId(Temperature, demoNsIndex); var tempValue (double)await session.ReadValueAsync(tempNodeId); Console.WriteLine($当前温度: {tempValue:F2});3.2 订阅模式用回调代替轮询实际项目里轮询读值不仅效率低还会给服务器造成不必要的压力。OPC UA的订阅Subscription机制本质是客户端告诉服务器“我关心哪些节点有变化就通知我”服务器按采样间隔检查并推送。创建订阅的代码var subscription new Subscription(session.DefaultSubscription) { PublishingInterval 1000, // 发布间隔1秒 KeepAliveCount 20, LifetimeCount 100 }; await session.AddSubscription(subscription); subscription.Create(); // 监控温度节点 var monitoredItem new MonitoredItem { StartNodeId tempNodeId, AttributeId Attributes.Value, SamplingInterval 500, // 采样间隔500ms QueueSize 10, DiscardOldest true }; monitoredItem.Notification (MonitoredItem item, MonitoredItemNotification notification) { var value notification.GetValue().Value; Console.WriteLine($订阅通知: {value:F2}); }; subscription.AddItem(monitoredItem); await subscription.ApplyChanges();关于采样间隔和发布间隔我补充一个容易混淆的知识点SamplingInterval是服务器检查数据变化的频率PublishingInterval是客户端收到通知包的频率。如果你的采样间隔是500ms、发布间隔是1s那么服务器会聚合约2个变化一次推给客户端。如果一次变化都没发生就只发KeepAlive心跳包这也是OPC UA流量远小于轮询的原因。3.3 写入操作与写入权限写操作在设备控制场景里经常用到。OPC UA的写是直接给节点赋值但服务器可以分别配置AccessLevel和UserAccessLevel一个是技术上的访问能力一个是当前用户是否允许操作。我上面的服务器代码里温度和湿度都设成了CurrentReadOrWrite所以匿名用户也能写var writeValue new WriteValue { NodeId tempNodeId, AttributeId Attributes.Value, Value new DataValue(31.5) }; WriteValueCollection results; ResponseHeader responseHeader; await session.Write(null, new WriteValueCollection { writeValue }, out results, out responseHeader);注意Write返回的是状态码列表results[0].StatusCode必须等于StatusCodes.Good才算写入成功。如果返回BadUserAccessDenied说明当前用户没有写权限返回BadWriteNotSupported则说明该节点的数据类型或访问级别不支持写入。4. 不写代码的验证方案Node-RED五分钟跑通连接与可视化C#代码跑通后你还需要一个工具来快速验证服务器行为、看实时曲线。Node-RED加上node-red-contrib-opcua节点是我目前用过最顺手的调试组合。4.1 安装与配置前提是你已经装了Node-REDnpm install -g node-red。然后在Node-RED的“节点管理”里搜索并安装node-red-contrib-opcua或者用命令npm install node-red-contrib-opcua安装完后左侧节点面板会多出OPC UA分类常用的有OPC-UA Server连接配置节点OPC-UA Client订阅某个节点或调用方法OPC-UA Write写入某个节点拖一个OPC-UA Server节点到画布双击编辑Endpoint填opc.tcp://localhost:62541/Security Policy选None连接成功后旁边的小圆点会变绿。4.2 用Dashboard做实时数据面板我先拖一个OPC-UA Client节点选择刚才配置的Server节点在地址里填ns2;sTemperature然后把它连到mqtt out或直接连到Dashboard的gauge、chart节点。这样一来1分钟内你就能在浏览器里看到温度曲线的实时刷新。实际联调中我发现一个高频问题有人把地址写成了ns0;sTemperature这当然报错因为ns0是OPC UA的保留命名空间只容纳标准节点自定义节点永远不在0号命名空间。另一个高频问题是服务端安全策略改成了Basic256Sha256Node-RED这边默认是None两边不匹配导致握手失败。所以调试阶段的原则是选型从简。服务器、客户端、Node-RED全部用None先把数据链路跑通再逐步引入加密和认证。安全策略切换时90%的报错来自证书信任不是你代码逻辑的问题心态上要有预期。4.3 Node-RED方式的实际使用边界Node-RED非常适合做原型和边缘侧小规模采集但它不是万能的。数据量大、节点数量多、需要严格事务控制的场景还是得回到C#或Java这类强类型语言。我见过有人用Node-RED接了200个PLC变量结果浏览器页面明显卡顿。这种时候消息队列加专业采集服务才是正解。5. 现场部署最容易踩的坑证书、时间同步与防火墙开发环境跑通只是一个开始真正到了现场问题几乎都集中在三个地方证书信任、时间同步、网络可达性。5.1 证书信任链路开发与生产的本质区别本地调试用None策略没问题但生产环境尤其是MES对接通常要求加密和签名这时候证书就绕不开了。OPC UA的应用证书本质上就是X.509证书。服务器启动时会加载自己的应用证书存储在CurrentUser\UA_MachineKeys或MachineKeys客户端第一次连接时服务器会把证书发给客户端客户端校验后决定是否信任。反过来如果客户端也配置了证书服务器同样要信任客户端证书。新手最常见的报错是BadCertificateUntrusted。这意味着客户端校验服务器证书时既不在受信任列表里也没有对应的CA证书链。解决办法有三类把服务器导出的der证书文件放到客户端信任目录。Opc.Ua库通常会把证书导出在与配置StorePath对应的证书存储里也可以写代码调用CertificateStore导出。如果双方都是自己控制的应用可以在程序启动时把证书互相加入信任列表这在库里有对应API。使用自建CA签发子证书然后把CA根证书装到所有客户端信任列表。这种方式适合设备数量多的项目但需要维护CA和证书有效期。有一个细节我多次踩坑LoadApplicationCertificate如果找不到证书有些库版本会自动生成有些会直接抛异常。排查时先看日志里证书路径再用certmgr.msc检查证书是否存在于指定存储。证书文件权限不足导致SpringBoard之类的界面化软件读不到也会让你误以为是代码问题。5.2 时间同步最容易忽略的一个坑OPC UA安全里有时间戳校验客户端和服务器的时间差超过限制通常是5分钟时即使证书没问题握手也会失败。现场工控机常年不校时、时间漂移是很正常的事我建议在现场统一配置NTP时间同步调试时如果发现证书明明信任了却还是BadCertificateTimeInvalid先检查两边系统时间不要在代码里粗暴关闭时间校验特殊情况下可以调整SecurityConfiguration里的时间偏移容差但生产环境不推荐。5.3 防火墙、主机名与地址绑定OPC UA默认端口是4840但OPC UA端点URL里会带上端口和路径比如opc.tcp://192.168.1.10:62541/。现场部署时如果服务器只监听localhost客户端用IP去连会直接拒绝。C#服务器里可以设置ServerConfiguration.BaseAddresses把它配置成opc.tcp://0.0.0.0:62541或者具体的局域网IP。防火墙方面只要放行对应TCP端口即可。OPC UA不像老的OPC DA依赖一堆动态端口把端口定死反而便于管理。还有一个主机名解析问题有些库在URL里写主机名而现场DNS没有解析记录连接会超时。简单粗暴的办法是客户端直接用IP地址但证书里的DNSName可能只匹配主机名导致证书校验失败。所以你会看到一个矛盾用IP连方便但证书校验可能需要用主机名。解决思路是证书里同时配置dns主机名和ipIP地址或者客户端连接时不校验主机名。这个要看具体库的API通常在RemoteCertificateValidator里可以配置。6. 实测过程中的一些经验和扩展思路代码能跑通只是第一步真正把OPC UA用到项目中还涉及性能和可靠性问题。我个人的测试环境是C#服务端跑在Windows 10上Node-RED跑在同一台机器的Docker里C#客户端从另一台Linux笔记本连接。在安全策略为None、200个模拟节点、采样间隔500ms的情况下CPU占用很低网络包也很少充分说明OPC UA的订阅模型效率比轮询高一个量级。但如果把200个节点的采样间隔降到10ms服务器端的CPU就开始上来了因为这涉及每个节点的内存队列排序、变化判定和发布打包。关于扩展方向我建议按这个顺序学习先改命名空间和节点结构把自己的设备数据加进去再给服务器加历史数据存储HistoricalNode让客户端能查历史曲线然后引入用户认证用UserIdentity的用户名密码模式替代匿名最后研究复杂数据类型和自定义对象类型比如把一个电机建模成包含转速、温度、报警状态的对象。另外提醒一点官方文档和GitHub上的UA-NETStandard仓库有很多现成示例比如Quickstarts里面包含了从服务器到客户端、从订阅到事件、从历史数据到报警的代码每个都是精简过的。我个人不建议直接抄里面的大工程而是对照它的某个小例子看自己项目缺哪块再定向去读效率会高很多。本文还有配套的精品资源点击获取
OPC UA最小实例：C#与Node-RED快速实现工业数据采集
简介这套基于西门子官方OPC UA客户端源代码整理的实例工程以C#语言编写面向需要与SINUMERIK 840Dsl高端数控系统完成数据交换的工业通信工程师与机床集成开发人员主要解决生产现场设备数据采集、运行状态监控和工艺参数读写等实际问题。压缩包共68个文件、约1.29MB文件构成以C#源文件、工程配置文件、WinForms界面图片和OPC UA动态库为主另附README与License等说明文档目录结构清晰便于按需定位。项目中的OpcUaHelper-master封装了节点浏览、订阅、读写调用等客户端常用操作并涉及证书配置和安全策略处理可直接在Visual Studio中编译运行作为对接840Dsl的二次开发模板。该实例已有646人学习浏览能帮助开发者绕过繁琐的SDK细节快速验证OPC UA通信方案并减少重复开发工作量顺利投入到机床数据监控与集成项目中。 开头我就直说OPC UAOPC Unified Architecture的实例程序网上一搜一大把但大部分是官方Demo的搬运要么架构太复杂、要么文档跟不上真正能让你在半小时内跑通、并且搞清楚每一步在干什么的资料反而是稀缺货。我自己做工业数据采集和设备联网项目时被OPC UA的证书、端点、命名空间折腾过不少回所以今天这篇不打算给你堆概念直接把一套可以落地的“OPC UA最小实例”拆开讲先用C#把服务器和客户端跑起来再用Node-RED做可视化验证最后把现场最容易踩的坑一次性说清。这篇文章适合谁准备做设备数据采集的工程师、正在研究工业物联网通信的开发者、以及被OPC UA各种概念绕晕但急需一个可运行程序作为参考的朋友。你不需要对OPC UA有很深的了解跟着步骤走就能跑通但我会尽量把背后的原理也讲透让你不是“只会复制粘贴”。1. 动手前先把方向定清楚OPC UA到底解决了什么问题很多初学者一上来就找代码结果被地址空间、订阅、方法调用这些概念砸晕。先花几分钟把OPC UA的定位搞清楚后面写代码会顺畅得多。1.1 OPC UA不是OPC DA的简单升级老一代的OPC DA基于Windows的COM/DCOM技术设备厂商想把数据暴露给上位机就得在Windows机器上配一堆DCOM权限跨网络访问更是噩梦。OPC UA从根上换了一套设计不再依赖COM改为基于TCP或HTTP的二进制/XML协议所以它能跑在Linux、Windows、嵌入式设备上这也就是为什么它在智能制造、边缘网关场景里越来越火。从实例程序的角度你只需要记住一个核心模型服务器Server暴露数据客户端Client读写数据两边通过“端点”建立连接。数据在服务器里以“节点”的形式存在组织成一棵类似文件目录的树这就是所谓的“地址空间”。理解了这个你写客户端就是在找节点、读节点、订阅节点写服务器就是在往地址空间里塞节点。1.2 什么场景才需要自己写实例程序官方SDK自带Sample但很多人看完依然不会写自己的程序原因在于Sample覆盖了太多边界情况。我根据实际项目经验把典型需求归成三类数据采集型你的应用作为客户端去连PLC、机床、传感器的OPC UA服务器定时读数据或订阅变化。这是最常见的场景Node-RED、Python、C#都很适合。设备接入型你的设备或网关作为服务器把采集到的数据统一暴露给MES、SCADA等上位系统。这时需要自己定义地址空间和节点结构。协议转换型一边用Modbus、S7等协议采集底层数据一边用OPC UA暴露出去典型的边缘网关做法。这类通常要同时写服务器和客户端逻辑。这篇实例会覆盖前两类的最小实现第三类只需要把两段代码拼起来即可。1.3 技术选型C#、Python还是Node-RED选型没有绝对答案但可以按场景快速判断选型方案优点缺点适合场景C# OPCFoundation.NetStandard.Opc.Ua官方原生支持、功能完整、类型安全代码量偏大、学习曲线略陡正式项目、Windows/Linux服务Python opcua-asyncio上手快、代码简短、调试方便性能和大数据量场景弱一些原型验证、数据采集脚本Node-RED node-red-contrib-opcua图形化、零代码、联调效率高业务逻辑复杂时难维护快速演示、边缘网关、可视化我个人建议正式的数据采集服务用C#快速验证用Node-REDPython适合做算法验证和临时脚本。下面先讲C#版本的最小实例。2. 基于C#快速搭建一个OPC UA服务器实例C#实现OPC UA官方库是OPCFoundation.NetStandard.Opc.Ua它在NuGet上分为Server和Client两个主要包如果你只是写服务器引用OPCFoundation.NetStandard.Opc.Ua.Server就够了。2.1 创建项目和引入依赖我用的是.NET 6/8Visual Studio或命令行都可以。先建一个控制台应用dotnet new console -n OpcUaDemoServer cd OpcUaDemoServer dotnet add package OPCFoundation.NetStandard.Opc.Ua.Server这个包会自动带上依赖的核心库。如果你在写客户端单独引用OPCFoundation.NetStandard.Opc.Ua.Client。NuGet上还有老版的OPCFoundation.NetStandard.Opc.Ua全量包都能用但拆分后的包结构更清晰。2.2 最小服务器的完整代码下面这段代码是我实际项目中抽出骨架后的精简版核心只有三步创建应用、配置端点、添加数据节点。using Opc.Ua; using Opc.Ua.Server; var application new ApplicationInstance { ApplicationName OpcUaDemoServer, ApplicationType ApplicationType.Server, ApplicationUri urn:demo:opcua:server, ProductUri urn:demo:opcua:product }; // 自动生成并管理应用证书跳过证书逻辑的繁琐细节 var certificate await application.LoadApplicationCertificate(false); var config new ApplicationConfiguration { ApplicationUri application.ApplicationUri, ApplicationName application.ApplicationName, ApplicationType ApplicationType.Server, ServerConfiguration new ServerConfiguration { // 默认安全策略先放开方便本地调试 SecurityPolicies new StringCollection { SecurityPolicies.None, SecurityPolicies.Basic256Sha256 } }, TransportConfigurations new TransportConfigurationCollection(), TransportQuotas new TransportQuotas { OperationTimeout 60000 }, ClientConfiguration new ClientConfiguration { DefaultSessionTimeout 60000 }, TraceConfiguration new TraceConfiguration(), CertificateValidator new CertificateValidator(), SecurityConfiguration new SecurityConfiguration { ApplicationCertificate new CertificateIdentifier { StoreType CertificateStoreType.X509Store, StorePath CurrentUser\\UA_MachineKeys, SubjectName application.ApplicationUri } } }; var server new DemoNodeManager(application, config); await server.StartAsync(); Console.ReadLine(); await server.StopAsync();DemoNodeManager是核心它告诉服务器你的地址空间里有哪些节点。下面是一个最简实现在命名空间urn:demo:opcua:server下添加了一个可读写的模拟温度变量using Opc.Ua; using Opc.Ua.Server; public class DemoNodeManager : StandardNodeManager { private BaseDataVariableState _temperatureState; public DemoNodeManager(ApplicationInstance application, ApplicationConfiguration configuration) : base(application, configuration, null) { } protected override void OnCreateAddressSpace(IDictionaryNodeId, IListIReference externalReferences) { base.OnCreateAddressSpace(externalReferences); // 创建一个自定义命名空间索引一般为20是OPC UA内置1是服务器自身 var namespaceIndex NamespaceUris.GetIndexOrAppend(urn:demo:opcua:server); // 对象节点相当于文件夹 var folder new FolderState(null, new NodeId(Demo, namespaceIndex)); folder.BrowseName new QualifiedName(Demo, namespaceIndex); folder.DisplayName new LocalizedText(Demo); ((BaseInstanceState)folder).ReferenceTypeId ReferenceTypeIds.Organizes; ((BaseInstanceState)folder).TypeDefinitionId ObjectTypeIds.FolderType; folder.PostConstruct(this); AddPredefinedNode(folder); // 模拟变量温度 _temperatureState new BaseDataVariableState(null, new NodeId(Temperature, namespaceIndex)) { BrowseName new QualifiedName(Temperature, namespaceIndex), DisplayName new LocalizedText(Temperature), DataType DataTypeIds.Double, Value 25.0, AccessLevel AccessLevels.CurrentReadOrWrite, UserAccessLevel AccessLevels.CurrentReadOrWrite }; _temperatureState.PostConstruct(this); folder.AddComponent(_temperatureState); AddPredefinedNode(_temperatureState); // 用定时器模拟工件温度波动 var timer new System.Timers.Timer(1000); timer.Elapsed (s, e) { _temperatureState.Value 25.0 Random.Shared.NextDouble() * 15.0; _temperatureState.ClearChangeMasks(this, false); }; timer.Start(); } }这里有几个新手容易踩的细节命名空间索引NamespaceUris.GetIndexOrAppend按顺序分配索引第一个自定义命名空间通常是2。客户端访问节点时写的ns2;sTemperature这里的2就是这个索引。如果你加了多个命名空间索引会变所以客户端代码里最好通过服务器返回的命名空间数组去动态解析别硬编码。ValueChanged的必要性服务器不会每时每刻广播变量变化你必须在赋值后调用ClearChangeMasks它底层会触发监控项的“数据变化”通知。忘了这步客户端订阅会一直收不到更新。证书是个大坑第一版调试建议设置SecurityPolicies包含None客户端用无加密方式连接省去证书信任的麻烦。正式上线再换成Basic256Sha256并把证书加入对方信任列表。运行后控制台会输出端点地址一般是opc.tcp://localhost:62541/。如果你的机器有多个网卡可能显示的是IP或主机名客户端需要按实际地址访问。3. 客户端实例从连接、读变量到订阅变化服务器起来了接下来写一个C#客户端。它能帮你验证服务器是否正常也是后面做数据采集服务的基础。3.1 最小客户端实现先新建一个控制台项目引用客户端包dotnet new console -n OpcUaDemoClient cd OpcUaDemoClient dotnet add package OPCFoundation.NetStandard.Opc.Ua.Client核心代码里连接和读值大概是这样的using Opc.Ua; using Opc.Ua.Configuration; using Opc.Ua.Client; var endpointUrl opc.tcp://localhost:62541/; // 匿名连接安全策略为None本地调试最省事 var endpoint CoreClientUtils.SelectEndpoint(endpointUrl, useSecurity: false); using var session await Session.Create( new ApplicationConfiguration { ApplicationName OpcUaDemoClient, ApplicationType ApplicationType.Client, SecurityConfiguration new SecurityConfiguration { ApplicationCertificate new CertificateIdentifier { StoreType CertificateStoreType.X509Store, StorePath CurrentUser\\UA_MachineKeys } } }, new ConfiguredEndpoint(null, endpoint, EndpointConfiguration.Create()), false, demo-client, 30000, new UserIdentity(new AnonymousIdentityToken()), null ); // 读取服务器上的命名空间数组动态解析索引 var namespaceArray (string[])await session.ReadValueAsync(new NodeId(VariableIds.Server_NamespaceArray)); var demoNsIndex Array.IndexOf(namespaceArray, urn:demo:opcua:server); // 读取温度值 var tempNodeId new NodeId(Temperature, demoNsIndex); var tempValue (double)await session.ReadValueAsync(tempNodeId); Console.WriteLine($当前温度: {tempValue:F2});3.2 订阅模式用回调代替轮询实际项目里轮询读值不仅效率低还会给服务器造成不必要的压力。OPC UA的订阅Subscription机制本质是客户端告诉服务器“我关心哪些节点有变化就通知我”服务器按采样间隔检查并推送。创建订阅的代码var subscription new Subscription(session.DefaultSubscription) { PublishingInterval 1000, // 发布间隔1秒 KeepAliveCount 20, LifetimeCount 100 }; await session.AddSubscription(subscription); subscription.Create(); // 监控温度节点 var monitoredItem new MonitoredItem { StartNodeId tempNodeId, AttributeId Attributes.Value, SamplingInterval 500, // 采样间隔500ms QueueSize 10, DiscardOldest true }; monitoredItem.Notification (MonitoredItem item, MonitoredItemNotification notification) { var value notification.GetValue().Value; Console.WriteLine($订阅通知: {value:F2}); }; subscription.AddItem(monitoredItem); await subscription.ApplyChanges();关于采样间隔和发布间隔我补充一个容易混淆的知识点SamplingInterval是服务器检查数据变化的频率PublishingInterval是客户端收到通知包的频率。如果你的采样间隔是500ms、发布间隔是1s那么服务器会聚合约2个变化一次推给客户端。如果一次变化都没发生就只发KeepAlive心跳包这也是OPC UA流量远小于轮询的原因。3.3 写入操作与写入权限写操作在设备控制场景里经常用到。OPC UA的写是直接给节点赋值但服务器可以分别配置AccessLevel和UserAccessLevel一个是技术上的访问能力一个是当前用户是否允许操作。我上面的服务器代码里温度和湿度都设成了CurrentReadOrWrite所以匿名用户也能写var writeValue new WriteValue { NodeId tempNodeId, AttributeId Attributes.Value, Value new DataValue(31.5) }; WriteValueCollection results; ResponseHeader responseHeader; await session.Write(null, new WriteValueCollection { writeValue }, out results, out responseHeader);注意Write返回的是状态码列表results[0].StatusCode必须等于StatusCodes.Good才算写入成功。如果返回BadUserAccessDenied说明当前用户没有写权限返回BadWriteNotSupported则说明该节点的数据类型或访问级别不支持写入。4. 不写代码的验证方案Node-RED五分钟跑通连接与可视化C#代码跑通后你还需要一个工具来快速验证服务器行为、看实时曲线。Node-RED加上node-red-contrib-opcua节点是我目前用过最顺手的调试组合。4.1 安装与配置前提是你已经装了Node-REDnpm install -g node-red。然后在Node-RED的“节点管理”里搜索并安装node-red-contrib-opcua或者用命令npm install node-red-contrib-opcua安装完后左侧节点面板会多出OPC UA分类常用的有OPC-UA Server连接配置节点OPC-UA Client订阅某个节点或调用方法OPC-UA Write写入某个节点拖一个OPC-UA Server节点到画布双击编辑Endpoint填opc.tcp://localhost:62541/Security Policy选None连接成功后旁边的小圆点会变绿。4.2 用Dashboard做实时数据面板我先拖一个OPC-UA Client节点选择刚才配置的Server节点在地址里填ns2;sTemperature然后把它连到mqtt out或直接连到Dashboard的gauge、chart节点。这样一来1分钟内你就能在浏览器里看到温度曲线的实时刷新。实际联调中我发现一个高频问题有人把地址写成了ns0;sTemperature这当然报错因为ns0是OPC UA的保留命名空间只容纳标准节点自定义节点永远不在0号命名空间。另一个高频问题是服务端安全策略改成了Basic256Sha256Node-RED这边默认是None两边不匹配导致握手失败。所以调试阶段的原则是选型从简。服务器、客户端、Node-RED全部用None先把数据链路跑通再逐步引入加密和认证。安全策略切换时90%的报错来自证书信任不是你代码逻辑的问题心态上要有预期。4.3 Node-RED方式的实际使用边界Node-RED非常适合做原型和边缘侧小规模采集但它不是万能的。数据量大、节点数量多、需要严格事务控制的场景还是得回到C#或Java这类强类型语言。我见过有人用Node-RED接了200个PLC变量结果浏览器页面明显卡顿。这种时候消息队列加专业采集服务才是正解。5. 现场部署最容易踩的坑证书、时间同步与防火墙开发环境跑通只是一个开始真正到了现场问题几乎都集中在三个地方证书信任、时间同步、网络可达性。5.1 证书信任链路开发与生产的本质区别本地调试用None策略没问题但生产环境尤其是MES对接通常要求加密和签名这时候证书就绕不开了。OPC UA的应用证书本质上就是X.509证书。服务器启动时会加载自己的应用证书存储在CurrentUser\UA_MachineKeys或MachineKeys客户端第一次连接时服务器会把证书发给客户端客户端校验后决定是否信任。反过来如果客户端也配置了证书服务器同样要信任客户端证书。新手最常见的报错是BadCertificateUntrusted。这意味着客户端校验服务器证书时既不在受信任列表里也没有对应的CA证书链。解决办法有三类把服务器导出的der证书文件放到客户端信任目录。Opc.Ua库通常会把证书导出在与配置StorePath对应的证书存储里也可以写代码调用CertificateStore导出。如果双方都是自己控制的应用可以在程序启动时把证书互相加入信任列表这在库里有对应API。使用自建CA签发子证书然后把CA根证书装到所有客户端信任列表。这种方式适合设备数量多的项目但需要维护CA和证书有效期。有一个细节我多次踩坑LoadApplicationCertificate如果找不到证书有些库版本会自动生成有些会直接抛异常。排查时先看日志里证书路径再用certmgr.msc检查证书是否存在于指定存储。证书文件权限不足导致SpringBoard之类的界面化软件读不到也会让你误以为是代码问题。5.2 时间同步最容易忽略的一个坑OPC UA安全里有时间戳校验客户端和服务器的时间差超过限制通常是5分钟时即使证书没问题握手也会失败。现场工控机常年不校时、时间漂移是很正常的事我建议在现场统一配置NTP时间同步调试时如果发现证书明明信任了却还是BadCertificateTimeInvalid先检查两边系统时间不要在代码里粗暴关闭时间校验特殊情况下可以调整SecurityConfiguration里的时间偏移容差但生产环境不推荐。5.3 防火墙、主机名与地址绑定OPC UA默认端口是4840但OPC UA端点URL里会带上端口和路径比如opc.tcp://192.168.1.10:62541/。现场部署时如果服务器只监听localhost客户端用IP去连会直接拒绝。C#服务器里可以设置ServerConfiguration.BaseAddresses把它配置成opc.tcp://0.0.0.0:62541或者具体的局域网IP。防火墙方面只要放行对应TCP端口即可。OPC UA不像老的OPC DA依赖一堆动态端口把端口定死反而便于管理。还有一个主机名解析问题有些库在URL里写主机名而现场DNS没有解析记录连接会超时。简单粗暴的办法是客户端直接用IP地址但证书里的DNSName可能只匹配主机名导致证书校验失败。所以你会看到一个矛盾用IP连方便但证书校验可能需要用主机名。解决思路是证书里同时配置dns主机名和ipIP地址或者客户端连接时不校验主机名。这个要看具体库的API通常在RemoteCertificateValidator里可以配置。6. 实测过程中的一些经验和扩展思路代码能跑通只是第一步真正把OPC UA用到项目中还涉及性能和可靠性问题。我个人的测试环境是C#服务端跑在Windows 10上Node-RED跑在同一台机器的Docker里C#客户端从另一台Linux笔记本连接。在安全策略为None、200个模拟节点、采样间隔500ms的情况下CPU占用很低网络包也很少充分说明OPC UA的订阅模型效率比轮询高一个量级。但如果把200个节点的采样间隔降到10ms服务器端的CPU就开始上来了因为这涉及每个节点的内存队列排序、变化判定和发布打包。关于扩展方向我建议按这个顺序学习先改命名空间和节点结构把自己的设备数据加进去再给服务器加历史数据存储HistoricalNode让客户端能查历史曲线然后引入用户认证用UserIdentity的用户名密码模式替代匿名最后研究复杂数据类型和自定义对象类型比如把一个电机建模成包含转速、温度、报警状态的对象。另外提醒一点官方文档和GitHub上的UA-NETStandard仓库有很多现成示例比如Quickstarts里面包含了从服务器到客户端、从订阅到事件、从历史数据到报警的代码每个都是精简过的。我个人不建议直接抄里面的大工程而是对照它的某个小例子看自己项目缺哪块再定向去读效率会高很多。本文还有配套的精品资源点击获取