简介这是一份基于C#语言实现的OPC UA客户端示例工程面向工业自动化、智慧工厂及设备联网等场景适合希望深入学习OPC UA协议开发的初中级C#开发者也可作为快速构建自定义客户端的起点。压缩包共收录197个文件整体约6.93MB以148个dll依赖库为主另有9个cs源码、exe可执行程序、配置文件及图标资源既可直接编译运行也可按需替换库文件进行二次开发。目前已有1348人学习下载资源体积适中、结构直观特别适合作为OPC UA协议开发的入门样例和团队内部培训参考。示例项目ReferenceClient完整覆盖了OPC UA客户端的核心流程包括创建会话、浏览服务器节点树、读取与写入变量、订阅实时数据变化、调用远程方法以及针对网络异常的安全处理机制。源码采用类与接口分层组织清晰分离了会话管理、节点操作、订阅回调和异常处理逻辑便于阅读复用可有效降低自研OPC UA客户端的开发门槛。1. 为什么 ReferenceClient 是 OPC UA 客户端开发的第一份骨架代码很多人在拿到ReferenceClient这个压缩包时第一反应是“项目里怎么全是.cache文件”。我最初拆这个包时也是这个状态DesignTimeResolveAssemblyReferences.cache、CoreCompileInputs.cache看起来像垃圾文件但真正决定客户端能不能跑的其实是App.config里的服务器地址、安全策略和证书路径。Quickstarts.ReferenceClient 是 OPC Foundation 用 C# 写的一个完整示例它把“连接 → 浏览 → 读写 → 订阅”这条链路从头到尾演示了一遍而且依赖少、结构清晰适合刚开始接触 OPC UA 协议开发的 C# 上位机工程师。如果你想在工控上位机或边缘网关里做 OPC UA 协议开发又不想从零啃规范这份源码是一个比文档更直接的起点。2. OPC UA 会话与节点模型在 C# 中建立连接前的必修课开始写客户端之前先要把 OPC UA 的地址空间模型放到熟悉的 C# 对象模型里。很多从 OPC DA 时代过来的开发者习惯把服务器想象成一张 tag 表但在 OPC UA 里服务器暴露给客户端的是一个由节点组成的图结构也就是地址空间。客户端做的第一件事不是读数据而是通过浏览找到目标节点再对节点执行读写或订阅操作。2.1 从 OPC DA 到 OPC UA客户端为什么要面对地址空间传统 OPC DA 的接口里服务器暴露的是一组扁平的数据点客户端靠标签名进行绑定而 OPC UA 把一切可访问的对象都抽象成节点这些节点通过引用关系组成图结构。这样做的好处是服务器自带语义和结构描述客户端拿到 NodeId 之后还能获取到数据类型、访问级别、读写权限等元数据。对于 C# 开发者来说这意味着你处理的不再是裸的 tag 名而是一个有类型、有关系的对象模型。在实际项目中很多报警只有变量值还不够还需要知道变量的工程单位、设备状态、报警上下限。这些元数据在 OPC UA 中都是节点属性客户端可以在同一个会话里读取而不需要像以前那样专门写驱动去后台数据库里翻。这也是 OPC UA 能取代 OPC DA 成为工业互联互通主流协议的原因之一。2.2 节点、NodeId 与 BrowseName读地址空间必须分清的三个标识OPC UA 地址空间中的每个节点都有一个NodeId它是节点的唯一标识格式通常是ns2;sMachine/PLC/Temperature其中ns是命名空间索引s是字符串标识。BrowseName则是节点在被浏览时显示的名称它不一定是唯一的。在界面上展示节点树时通常把BrowseName.Name和NodeId一起显示方便调试。下面是四种最常见的节点类型和它们的用途节点类型NodeClass 枚举用途典型示例对象Object组织子节点和变量设备对象 Machine变量Variable保存数据和属性温度值 Temperature方法Method可调用的远程操作复位报警 Reset视图View针对特定场景的节点子集运行视图 RuntimeView2.3 用 Session 建立连接App.config 里的配置项如何影响连接行为ReferenceClient 的启动入口里ApplicationConfiguration是整个客户端的配置中心。它从App.config读取的 OPC UA 配置段包含了EndpointUrl、SecurityMode、SecurityPolicyUri、UserIdentity等信息。下面是 Quickstarts.ReferenceClient 中典型的配置片段opc:ApplicationConfiguration xmlns:opchttp://opcfoundation.org/UA/2008/02/Types.xsd ApplicationNameQuickstarts.ReferenceClient/ApplicationName ApplicationUriurn:Quickstarts:ReferenceClient/ApplicationUri SecurityConfiguration SecurityPolicyUrihttp://opcfoundation.org/UA/SecurityPolicy#Basic256Sha256/SecurityPolicyUri SecurityModeSignAndEncrypt/SecurityMode /SecurityConfiguration TransportQuotas OperationTimeout30000/OperationTimeout /TransportQuotas /opc:ApplicationConfiguration这里SecurityPolicyUri指定加密算法套件SecurityMode决定是否签名或加密OperationTimeout控制单个请求的超时时间。本地联调推荐先用None模式绕过证书问题跑通流程后再切回SignAndEncrypt。参考客户端里面ApplicationInstance.CheckApplicationInstanceCertificates(false)会跳过证书校验部署到生产环境时要改成true并配置好信任的证书列表。创建会话的 C# 代码放在SessionManager类里核心逻辑是加载配置、选择端点、创建会话三步private Session CreateSession() { var application new ApplicationInstance { ApplicationName Quickstarts.ReferenceClient, ApplicationType ApplicationType.Client, ApplicationUri urn:Quickstarts:ReferenceClient }; var config application.LoadApplicationConfiguration(App.config, false); application.CheckApplicationInstanceCertificates(false); var endpoint CoreClientUtils.SelectEndpoint(config, config.ServerUrl(), useSecurity: true); var session Session.Create( config, endpoint, new UserIdentity(new UserNameIdentityToken { UserName opcua, Password 123456 }), sessionName: ReferenceClient-Session, sessionTimeout: 60000).GetAwaiter().GetResult(); return session; }SelectEndpoint会根据配置里的安全策略和服务器返回的端点列表自动匹配一个可用端点Session.Create的参数分别是要传的sessionName和sessionTimeout后者表示服务器在多少毫秒内没有收到客户端请求就主动断开。实际项目里建议在会话创建成功后立刻调用session.KeepAlive KeepAliveHandler让 SDK 自动发送保活报文。3. 用 OPC.UA.Client SDK 实现节点浏览与读写界面3.1 NuGet 依赖引用与解决方案结构ReferenceClient 示例里并没有把主逻辑全部塞进 MainWindow而是拆成了 Session 管理、节点浏览、订阅管理几个类。自己写 C# 上位机时也可以沿用这个结构界面层用 WinForms 或 WPF数据层封装 OPC UA 客户端。先通过 NuGet 安装官方 SDKdotnet add package OPCFoundation.NetStandard.Opc.Ua.Client dotnet add package OPCFoundation.NetStandard.Opc.Ua.ConfigurationOPCFoundation.NetStandard.Opc.Ua.Client是客户端核心程序集包含Session、Subscription、MonitoredItem等类型Configuration程序集负责证书、地址和传输配置。如果你还在用 .NET Framework 4.7.2也可以安装对应版本的包API 基本一致只是命名空间里少了NetStandard前缀。提示dotnet add package 要在项目的csproj文件所在目录执行。如果公司网络环境访问 NuGet 受限可以先把.nupkg下载到本地再用nuget config set globalPackagesFolder指定包来源。3.2 浏览服务器地址空间用 Browse 递归构建节点树在界面上展示 OPC UA 服务器里的节点最直接的做法是从ObjectsFolder开始调用Browse。下面是一个 WinForms 环境下的递归浏览方法public void BrowseNode(Session session, NodeId sourceId, TreeNode treeNode) { var request new BrowseRequest { Header { Timestamp DateTime.UtcNow }, NodesToBrowse new BrowseDescriptionCollection { new BrowseDescription { NodeId sourceId, BrowseDirection BrowseDirection.Forward, ReferenceTypeId ReferenceTypeIds.HierarchicalReferences, IncludeSubtypes true, NodeClassMask (uint)NodeClass.Object | (uint)NodeClass.Variable, ResultMask (uint)BrowseResultMask.All } }, RequestedMaxReferencesPerNode 100 }; var response session.Browse(request); foreach (var refDesc in response.Results[0].References) { var child new TreeNode { Text ${refDesc.BrowseName.Name} [{refDesc.NodeId}] }; treeNode.Nodes.Add(child); BrowseNode(session, refDesc.NodeId, child); // 递归遍历子节点 } }BrowseDirection.Forward表示查找以该节点为源的所有正向引用ReferenceTypeId.HierarchicalReferences把组织、归纳、层次引用全部包括进来基本覆盖了设备模型里常见的父子关系。NodeClassMask只选择对象和变量避免把数据类型、字符类型等内部结构塞进界面节点树。RequestedMaxReferencesPerNode控制单次最多返回的引用条数当节点数量大时会出现 truncated 状态需要根据ContinuationPoint继续请求后续批次。另外节点之间如果存在循环引用递归会死循环建议在方法外维护一个HashSetNodeId进入递归前先判断是否已经访问过。3.3 读取与写入NodeId 与数据类型的匹配读取变量值需要拿到目标节点的NodeId并指定读取属性。下面是封装读写操作的代码public DataValue ReadValue(Session session, NodeId nodeId) { var request new ReadRequest { NodesToRead new ReadValueIdCollection { new ReadValueId { NodeId nodeId, AttributeId Attributes.Value, IndexRange null } } }; var response session.Read(request); var value response.Results[0]; if (StatusCode.IsBad(value.StatusCode)) throw new ServiceResultException(value.StatusCode); return value; } public void WriteValue(Session session, NodeId nodeId, object value) { var request new WriteRequest { NodesToWrite new WriteValueCollection { new WriteValue { NodeId nodeId, AttributeId Attributes.Value, Value new DataValue { Value value, StatusCode StatusCodes.Good, SourceTimestamp DateTime.UtcNow } } } }; session.Write(request); }读取的结果中StatusCode不是Good就表示节点不可读、不存在或无权限需要根据具体错误码决定是继续还是记录到日志。写入时要注意AttributeId Attributes.Value表示写的是节点当前值如果服务器把该节点设置成只读写入操作会返回BadNotWritable。DataValue.SourceTimestamp建议显式带上有些 PLC 网关在比较时间戳时会拒绝写入。对于从字符串拼接出来的 NodeId例如ns2;sPLC/HMI/Start直接用NodeId.Parse(ns2;sPLC/HMI/Start)更安全节点不存在时可以快速抛出异常。在界面上不同数据点的可读属性和数据类型差别很大可以先把节点属性缓存到表格里再接合读取。常用的读取属性见下表属性名AttributeId用途ValueAttributes.Value节点的当前值NodeClassAttributes.NodeClass节点类型DataTypeAttributes.DataType值的数据类型AccessLevelAttributes.AccessLevel可否读/可否写DisplayNameAttributes.DisplayName界面显示名称读取这些属性时只需把AttributeId换成表中对应值ReadValueId的其余字段保持不变。这样既可做节点树详情页也方便在订阅前判断某个变量是否可读。4. 订阅回调、UI 刷新与断线重连客户端稳定性实战4.1 用 Subscription 和 MonitoredItem 做数据变更通知轮询在读点较多时会产生大量无效应答而且延迟不稳定。OPC UA 订阅机制由服务器在数据变化时主动上报适合工控现场的高频数据监控。创建订阅的流程是先建Subscription再往里加MonitoredItem并为每个 Item 绑定数据变化回调最后调用Subscription.Create()把订阅注册到服务器。var subscription new Subscription(session, 0) // 订阅 id 由服务器分配 { PublishingInterval 200, KeepAliveCount 10, LifetimeCount 60, MaxNotificationsPerPublish 1000 }; var item new MonitoredItem { StartNodeId new NodeId(ns2;sPLC/IO/Temperature, 2), AttributeId Attributes.Value, SamplingInterval 100, QueueSize 10, DiscardOldest true }; item.DataValueChanged OnDataValueChanged; subscription.AddItem(item); session.AddSubscription(subscription); subscription.Create();PublishingInterval是服务器发送发布通知的周期SamplingInterval是服务器内部对数据点采样的间隔一般建议SamplingInterval比PublishingInterval小或相等否则两次发布之间数据可能没有更新。KeepAliveCount表示连续多少个发布周期没有数据通知时发送一个保活消息LifetimeCount是订阅在没有收到消息时最大存活周期QueueSize和DiscardOldest决定队列满时的数据淘汰策略。对于需要断点续传的报表类应用可以把DiscardOldest设为false让新数据等待旧数据被处理后再进入队列。参数名推荐值影响PublishingInterval100~500ms服务器推送周期SamplingInterval50~200ms实际采数周期QueueSize10~100未处理通知的缓存深度KeepAliveCount5~20保活频率LifetimeCount需大于 KeepAliveCount订阅存活周期4.2 回调线程与 UI 刷新避免出现“界面卡顿”OPC UA 回调默认运行在 SDK 的 I/O 线程池里直接在回调里更新 WinForms 的TextBox或 WPF 的Label会抛跨线程异常也容易触发c# 循环数据采集和ui刷新卡顿这类问题。常见做法是把回调数据暂存到并发队列由 UI 定时器统一取出并刷新界面private readonly ConcurrentQueue(string nodeId, object value) _dataQueue new(); private void OnDataValueChanged(MonitoredItem item, MonitoredItemNotification notification) { // notification.Value 是 DataValueWrappedValue 里才是原始值 _dataQueue.Enqueue((item.StartNodeId.ToString(), notification.Value.WrappedValue.Value)); } private void DispatchToUi() { while (_dataQueue.TryDequeue(out var item)) { textBoxValue.AppendText(${item.nodeId}: {item.value}{Environment.NewLine}); } } // UI 定时器每 50ms 调用一次 DispatchToUi timer.Interval 50; timer.Tick (s, e) DispatchToUi();ConcurrentQueue保证多线程入队、UI 线程出队时不会互相踩内存。UI 刷新周期可以比订阅周期慢但不能反过来否则队列会持续堆积。对于图表控件还可以在入队前判断数值变化量只有超过阈值才入队这样既能保证曲线平滑又减少 UI 绘制次数。4.3 断线重连抓住 KeepAlive 失联的临界点网络波动或服务器重启都会让Session进入BadConnectionClosed状态。ReferenceClient 里用了 SessionReconnectHandler 专门处理重连简单场景下可以自己写保活循环。关键点在于不能收到一个 BadNoCommunication 就立刻重建会话连续几次失联才触发重连会更稳定private class ReconnectGuard { private int _lostCount; public bool ShouldReconnect _lostCount 3; public void OnKeepAlive(Session session, ServiceResult result) { if (result.Code StatusCodes.BadNoCommunication) { _lostCount; } else { _lostCount 0; } } }在使用Session.KeepAlive时事件参数里的ServiceResult.Code会先变成Good再在断网时变成BadNoCommunication。只有连续 3 次收到失联信号才重建会话可以避免 Wi-Fi 闪断时频繁重连。ServiceResult不为 Bad 但也不为 Good 的情况比如节点暂时不可用不应该被当成失联处理。5. 用 Prosys OPC UA Browser 把客户端跑起来并验证订阅5.1 本地模拟服务器把 App.config 指向 Prosys手头没有 PLC 时Prosys OPC UA Browser 是常用的本地模拟服务器。启动后在 Server 面板里能看到端点地址例如opc.tcp://localhost:53530/opcua/server。把 ReferenceClient 的App.config中ServerUrl改成这个地址并把安全策略暂时改为None就可以绕开证书问题。注意如果客户端和服务器不在同一台机器ServerUrl里的localhost要改成服务器 IP否则即使连接报错也很难定位是地址问题还是安全配置问题。5.2 验证三步节点树、读写值、订阅回调连接成功后先检查界面上的节点树是否弹出。展开后找到Data分组里的模拟变量读取时注意对比 Browser 中的值从 Browser 修改某个模拟值观察客户端订阅回调是否在 2 秒内刷新。这三步全部通过说明浏览、读写、订阅三条链路都是通的可以放心接真实设备。5.3 采集数据向 MQTT 转发一种轻量做法OPC UA 客户端跑稳后数据要发给上层系统时常见做法是直接推到 MQTT。用 MQTTnet 实现很短var mqtt new MqttFactory().CreateMqttClient(); await mqtt.ConnectAsync(new MqttClientOptionsBuilder() .WithTcpServer(127.0.0.1, 1883) .Build(), CancellationToken.None); await mqtt.PublishAsync($opcua/{nodeId}, payload);nodeId如果包含/或;会直接影响 MQTT topic 的分层发布前先把nodeId里的非法字符替换成_。如果不想自己维护桥接程序也可以直接让 Node-RED 订阅 OPC UA 再转发到 MQTT但那样会多一条中间链路对于只有一两个采集端的场景放在客户端进程里更省事。本文还有配套的精品资源点击获取