简介面向Visual Studio 2012下VB.NET开发者的OPC UA客户端示例工程定位是帮助工业自动化开发人员解决OPC服务器数据读写、节点浏览与会话管理等问题也适合刚开始接触OPC UA通信编程的读者作为入门参考。压缩包共55个文件大小约2.67MB主要包含6个VB源码文件、9个DLL运行库、4个EXE可执行程序以及XML配置文件、解决方案等其中VB源码对应主窗体与业务逻辑DLL为运行依赖EXE为可执行实例XML和配置用于描述连接参数与项目设置打开工程即可查看整体结构和关键模块。目前已有1389人学习。示例代码完整覆盖连接配置、创建会话、浏览节点、读取数据、写入数据、异常处理和关闭资源等关键环节注释详细、逻辑清晰读者可对照掌握OPC UA客户端从无到有的实现思路也能将工程作为基础模板迁移到自己的VB.NET项目中直接改造使用尤其适合设备数据采集与产线监控场景。1. 为什么 VB.NET 还能稳稳写 OPC UA 客户端用 VB.NET 写 OPC UA 客户端听到这句话很多人的第一反应是这技术是不是有点老但只要你接过一两个工厂 MES 或 SCADA 的上位机项目就会发现在真正的车间现场VB.NET 工程还老老实实跑在大量工控机上。OPC UA 本身只是传输协议和地址空间模型跟语言关系不大。本文就按我实际项目里踩出来的路线讲怎么用 VB.NET 引 OPCFoundation .NET Standard 库把一个能读、能订阅、能重连的最小客户端搭起来再把证书、超时、数据质量这些坑一个个填平。2. 认识 OPC UA 客户端的技术骨架协议模型与选型2.1 客户端要处理的核心对象地址空间、会话与订阅OPC UA 和咱们熟悉的 OPC DA就是 COM/DCOM 那套有个最根本的区别它不是一个简单的读变量接口而是一个面向服务的架构。客户端连上服务器之后首先面对的是一个树状的地址空间里面的每个节点都叫 NodeId比如ns2;sTemperature这种写法。常见的节点属性是Value、BrowseName、Description而你真正要采集的数据主要挂在Value上。连接过程也不是一根 TCP 拉到黑而是分四步建立安全通道、创建会话、激活会话、然后才能读写或订阅。这里面有三个对象你绕不开——EndpointDescription描述服务器的端点 URL、安全模式和安全策略Session是你后续所有操作的入口Subscription是订阅集合它下面挂着多个MonitoredItem。这三个对象的生命周期直接决定了你的客户端是稳定还是三天两头断线。2.2 三家常见库的对比以及为什么最终选官方标准库动手之前先解决选型问题。目前 VB.NET 能用的 OPC UA 客户端库大致有三条路OPC Foundation 官方出的 .NET Standard 库NuGet 包名是OPCFoundation.NetStandard.Opc.Ua.Client加OPCFoundation.NetStandard.Opc.Ua.Core还有基于安全通道封装的高层库比如某些商业组件再有就是干脆用 Node-RED 或者别的中间件绕开原生开发。我的建议很简单优先用官方标准库。第一它跨语言C# 能怎么调VB.NET 就怎么调API 完全一致第二社区和官方示例最全遇到问题可以搜到真实项目里的答案第三它底层直接实现了 UA Secure Conversation 协议自带证书和通道安全逻辑不需要自己处理加密细节。相比之下某些商业封装虽然上手快但调试的时候你根本不知道它内部做了哪些安全策略的协商出了问题纯靠猜。对比项官方 .NET Standard 库商业封装组件中间件方案语言兼容VB.NET/C# 原生VB.NET 原生不涉及 Lang 层安全策略支持完整支持三档模式通常支持依赖中间件调试透明度高可看协议层日志低黑匣子中长期维护基金会持续更新商业公司维护看开源活跃度部署体积小纯托管代码中大既然选了官方标准库接下来的几章我就用 .NET 6 以上的 VB.NET 控制台项目演示一套最小可用客户端。注意我会直接使用Opc.Ua.Client和Opc.Ua这两个命名空间它们分别对应高层的会话/订阅操作和底层的数据结构。3. 搭建最小可运行的 VB.NET OPC UA 客户端从建项目到读一个变量3.1 创建 VB.NET 控制台项目并引入 OPC UA 客户端包先把项目骨架搭起来。.NET SDK 7 以上版本可以直接用命令行创建 VB.NET 项目然后通过dotnet add package把官方库引进来。这里有两个包Opc.Ua.Core提供 NodeId、DataValue、EndpointDescription 这些基础类型Opc.Ua.Client提供 Session 和 Subscription 这些高层对象。dotnet new console -lang VB -o OpcUaClientDemo cd OpcUaClientDemo dotnet add package OPCFoundation.NetStandard.Opc.Ua.Client-lang VB这个参数能让你直接用 VB 模板生成.vbproj和Program.vb。如果你装的是连 SDK 都带好的 Visual Studio也可以在模板里直接选 Visual Basic 控制台应用效果一样。加包时Opc.Ua.Client会作为上层包把Opc.Ua.Core和Opc.Ua.Security一起拉下来所以你不需要手动引三个包。打开Program.vb确认一下默认内容是Module Program而不是 C# 的Program.cs。如果之前装过别的 SDK 版本可能有模板缓存问题建议直接删掉.csproj目录下重新建或者用dotnet new list看看模板是否正常。我第一次用命令行建 VB 项目时因为 SDK 版本太旧-lang VB参数不被识别最后是升级到 .NET 7 才解决的。3.2 用 30 行代码建立会话并读取一个 NodeId现在写核心逻辑。这里我会做一个Module Program里面包含一个全局的_session字段这样后面读变量、订阅都共用同一个会话。ApplicationConfiguration是客户端配置入口证书、安全策略、传输配额的属性都挂在它下面。Imports Opc.Ua Imports Opc.Ua.Client Imports Opc.Ua.Configuration Public Module Program Private _session As Session Public Sub Main() Dim endpointUrl As String opc.tcp://127.0.0.1:4840 Dim application As New ApplicationInstance() application.ApplicationName VbNetOpcUaClient application.ApplicationType ApplicationType.Client Dim config As New ApplicationConfiguration() config.ApplicationName VbNetOpcUaClient config.ApplicationUri urn:VbNetOpcUaClient config.TransportQuotas New TransportQuotas() 调试期先自动接受服务器证书上线前一定要关掉 config.SecurityConfiguration.AutoAcceptUntrustedCertificates True Dim endpointDescription As EndpointDescription CoreClientUtils.SelectEndpoint(config, endpointUrl, False) Dim endpointConfig As EndpointConfiguration EndpointConfiguration.Create(config) Dim endpoint As New ConfiguredEndpoint(endpointUrl, endpointDescription, endpointConfig) Dim userIdentity As IUserIdentity New UserIdentity(New AnonymousIdentityToken()) Dim sessionTask As Task(Of Session) Session.Create(config, endpoint, True, VbNetSession, 60000, userIdentity, Nothing) _session sessionTask.GetAwaiter().GetResult() Console.WriteLine(连接成功会话状态: _session.Good.ToString()) Dim value As Object ReadNode(ns2;sDemo.Tag1) Console.WriteLine(Tag1 当前值: value) _session.Close() End Sub Private Function ReadNode(nodeId As String) As Object Dim readId As New ReadValueId() readId.NodeId New NodeId(nodeId) readId.AttributeId Attributes.Value Dim readCollection As New ReadValueIdCollection() readCollection.Add(readId) Dim results As DataValueCollection Nothing Dim diagnostics As DiagnosticInfoCollection Nothing _session.Read(readCollection, 0, TimestampsToReturn.Both, results, diagnostics) If results IsNot Nothing AndAlso results.Count 0 Then Return results(0).Value End If Return Nothing End Function End Module这段代码你照着抄就能跑通一个最基本的读操作。逻辑上分三步先用SelectEndpoint从服务器端点列表里挑一个可用的再用Session.Create建立会话最后一个参数useSecurity我传的是True配合前面的AutoAcceptUntrustedCertificates True会让调试期免去手动导证书的麻烦。Session.Create返回的是Task(Of Session)用GetAwaiter().GetResult()同步等待比用.Result更安全不容易挂起。ReadNode函数里有一个容易忽略的点New NodeId(nodeId)需要传入完整的节点标识比如ns2;sDemo.Tag1。如果你只写Demo.Tag1它会被当成不带命名空间的字符串节点绝大多数服务器会直接回你BadNodeIdUnknown。另外TimestampsToReturn.Both是同时取源时间戳和服务器时间戳如果只想拿数据本身用TimestampsToReturn.Neither可以省掉一部分传输量。3.3 订阅数据变化把被动读变成主动推送轮询读变量在低速采集场景还能用但如果你的变量一秒变十次或者你同时盯着几十个点轮询不仅废 CPU还会把服务器请求队列打满。这时候就要上订阅机制。订阅的核心关系是Subscription挂在Session上MonitoredItem挂在Subscription上每个监视项负责一个节点的某条属性。Private Sub CreateSubscription(nodeId As String) Dim subscription As New Subscription(_session) subscription.PublishingInterval 500 服务器推送周期单位毫秒 subscription.LifetimeCount 100 生命周期计数 subscription.MaxKeepAliveCount 10 保活心跳计数 把订阅加到会话上并让服务器确认 _session.AddSubscription(subscription) subscription.Create() Dim item As New MonitoredItem(New NodeId(nodeId), Attributes.Value) item.SamplingInterval 500 采样周期必须 推送周期 item.QueueSize 10 队列长度防积压 item.DiscardOldest True 队列满时丢最旧的 AddHandler item.Notification, AddressOf OnDataChange subscription.AddItem(item) subscription.ApplyChanges() End Sub Private Sub OnDataChange(monitoredItem As MonitoredItem, e As MonitoredItemNotificationEventArgs) If e.NotificationValue IsNot Nothing AndAlso e.NotificationValue.Value.Count 0 Then Dim itemValue As MonitoredItemNotification e.NotificationValue.Value(0) Console.WriteLine($节点 {monitoredItem.StartNodeId} 变化: {itemValue.Value.Value} (质量: {itemValue.StatusCode.Code})) End If End Sub这里最容易翻车的参数搭配是PublishingInterval和SamplingInterval。如果采样间隔比推送间隔长比如你推得飞快但采得慢服务器每个推送周期都会给你重复值白白占用带宽反过来如果你采样间隔缩小到几十毫秒但推送间隔是 1 秒那队列里会堆满变化值客户端处理不过来。我一般把两者设成相同值或者采样间隔稍小于推送间隔比如推送 500ms 采样 250ms。订阅还有一个隐蔽特性QueueSize决定了队列满了之后是丢旧还是丢新。监视模拟量时建议DiscardOldest True只保留最新数据但如果是设备报警信号你反而希望每次变化都触发这时候QueueSize要设大一些并且把DiscardOldest设为 False否则多个报警挤在一起被丢掉后端的告警逻辑就会漏。4. 安全策略与连接参数证书、身份验证和超时的实操配置4.1 三种安全模式下的证书互通如何用一个自签证书端到端跑通OPC UA 的安全模式有三档None、Sign、SignAndEncrypt。None走裸 TCP不加密也不签名适合内网调试Sign只验证数据完整性不加密内容SignAndEncrypt既验签名又加密是产线默认推荐。很多工程师在本地测试时全选None拿到现场连不上就怪防火墙其实八成是服务器的端点只允许加密模式而你的客户端配置根本没有匹配的证书策略。客户端这边要准备两个角色本机证书和信任列表。官方标准库处理证书的常用做法是让ApplicationInstance在第一次启动时自动生成一张自签证书然后把它注册到本地证书库里。关键代码在config.SecurityConfiguration里挂证书目录和信任目录Dim certStorePath Path.Combine(AppDomain.CurrentDomain.BaseDirectory, pki) Dim trustedPath Path.Combine(AppDomain.CurrentDomain.BaseDirectory, pki, trusted) config.SecurityConfiguration.ApplicationCertificate New CertificateIdentifier() config.SecurityConfiguration.ApplicationCertificate.StoreType CertificateStoreType.Directory config.SecurityConfiguration.ApplicationCertificate.StorePath certStorePath config.SecurityConfiguration.TrustedPeerCertificates New CertificateTrustList() config.SecurityConfiguration.TrustedPeerCertificates.StoreType CertificateStoreType.Directory config.SecurityConfiguration.TrustedPeerCertificates.StorePath trustedPath config.CertificateValidator New CertificateValidator(config.SecurityConfiguration) 自动生成自签证书回滚意味不生效时可手动删 pki 目录重来 application.CheckApplicationInstanceCertificate(False, 2048).GetAwaiter().GetResult()StoreType Directory表示用目录存证书而不是 Windows 注册表这样你把这个程序拷到别的工控机上整个pki目录一起带走就行不用动系统证书库。CheckApplicationInstanceCertificate(False, 2048)会在目录为空时自动生成一张 2048 位 RSA 自签证书第二个参数建议至少 2048512 或 1024 在较新的 OPC UA 服务器上大概率被拒。4.2 匿名登录与用户密码登录到底怎么选安全策略解决的是传输层加密和签名身份验证解决的是你能否使用这个会话。UserIdentity有三种AnonymousIdentityToken、UserNameIdentityToken、IssuedIdentityTokenX.509 证书登录属于这一类。匿名登录在 PLC 内置的 OPC UA Server 里很常见但连接前最好先用 UAExpert 之类的工具打开服务器端点的安全策略看一圈确认它允许匿名。用账号密码时UserIdentity签名和加密的处理方式略有不同。因为密码是在 Client 端通过端点证书加密后传到 Server 的如果你的连接选了SecurityMode.None密码等于明文在网络上传这在等保检查里直接不合格。所以但凡要传用户名密码安全模式至少得是Sign最好是SignAndEncrypt。代码如下Dim userIdentity As IUserIdentity New UserIdentity(admin, 123456) Dim sessionTask As Task(Of Session) Session.Create(config, endpoint, True, VbNetSession, 60000, userIdentity, Nothing)有一个血泪经验同一个服务器可能有多个端点比如opc.tcp://192.168.1.10:4840和opc.tcp://192.168.1.10:4841一个允许匿名一个只允许用户名密码。SelectEndpoint默认返回的是第一个可用端点如果你传了用户密码但选到的端点不支持用户名认证连接会报BadUserAccessDenied。解决办法是先调用GetEndpoints()把所以端点列出来然后按服务器证书和认证类型过滤再手动指定端点。4.3 超时与重连参数SessionTimeout、RequestTimeout 和自动重连Session.Create里的第四万个参数是sessionTimeout我代码里写的 60000 就是 60 秒。这个值要与服务器的会话超时协商两边取较小值。设太短会导致你客户端发了请求但服务器那边会话已关闭设太长可能导致服务器资源被无效会话占着不放。EndpointConfiguration里还有一个OperationTimeout它控制单次读写的等待时间。我建议把它设为 5 到 15 秒。现场最容易出问题的不是这个而是网络抖动导致会话静默死亡。OPC UA 的保活机制靠订阅的MaxKeepAliveCount来维持心跳但如果你一个订阅都不建会话就只有依赖 TCP 层一旦网线闪断客户端可能要等 10 分钟才能真正感知到断线。_session.AddSessionStatusChangedEventHandler(AddressOf OnSessionStatusChanged) Private Sub OnSessionStatusChanged(session As Session, e As SessionStatusChangedEventArgs) If e.Error IsNot Nothing Then Console.WriteLine($会话异常: {e.Error.Message}) End If End Sub会话断了之后官方库并不内置自动重连逻辑你需要自己实现。常见做法是在SessionStatusChangedEventHandler里判断状态当会话从Connected变成Reconnecting或Closed时重新走一遍Session.Create流程并且要把所有订阅和监视项重建一遍。这里注意如果订阅还在但会话已经重建旧订阅对象是无效的必须先把旧的Subscription从旧会话移除再在新会话上创建。5. OPC UA 客户端避坑指南五个反复踩到的连接与数据问题5.1 连接时报 BadSecurityChecksFailed但证书明明安装好了现象Session.Create抛出异常错误码是BadSecurityChecksFailed。你检查了服务器证书已经导入到客户端的信任列表又把客户端证书导到了服务器的信任列表看起来天衣无缝为什么还报错原因最常见的是安全策略不匹配而不是证书内容有问题。比如服务器端点只支持Basic256Sha256签名算法但你的EndpointConfiguration或SelectEndpoint返回的端点使用旧版Basic128。双方可以握手但签名算法对不上服务器在验签阶段直接拒绝。解决在连接之前把服务器所有端点的安全策略打出来然后选一个与你本地证书匹配的。更稳妥的做法是不依赖SelectEndpoint自动选而是用GetEndpoints手动过滤Dim endpointList CoreClientUtils.GetEndpoints(config, endpointUrl) For Each ep In endpointList Console.WriteLine(${ep.EndpointUrl} | {ep.SecurityMode} | {ep.SecurityPolicyUri}) Next如果看到SecurityPolicyUri是http://opcfoundation.org/UA/SecurityPolicy#Basic256Sha256你本地证书就必须用支持 SHA256 签名算法的证书。自签证书生成时默认就支持但如果你之前手动用 OpenSSL 生成过低位数证书换一张新的即可。5.2 NodeId 写错导致 BadNodeIdUnknown问题并不在 NodeId 本身现象读操作返回BadNodeIdUnknown你反复确认 NodeId 字符串和服务器地址空间里显示的一致为什么还是找不到原因NodeId 的命名空间索引不匹配。比如服务器地址空间里节点显示为Temperature它真正在的命名空间可能是ns3而不是你在客户端写的ns2。这是我在现场踩过最频繁的坑——把 UAExpert 里复制的 NodeId 里的ns3忽略了只抄了节点名。解决先浏览服务器的根节点不要凭记忆拼 NodeId。客户端可以用Browser对象递归浏览地址空间Dim browser As New Browser(_session) browser.NodeId Objects.ObjectsFolder Dim refs browser.Browse() For Each ref In refs Console.WriteLine(${ref.NodeId} - {ref.DisplayName.Text}) Next再查一个具体节点右键在 UAExpert 里复制Read From Server会得到完整路径像ObjectsFolder/DeviceSet/Temperature这种带路径的引用如果用了NodeId的字符串格式并不总是有效你需要通过TranslateBrowsePathToNodeIds转成真正的 NodeId然后再读。别嫌麻烦一个变量写错等排查一下午的场景我见过太多次。5.3 订阅长时间不更新连接却还活着现象程序跑了一个晚上第二天订阅不再回调但 ping 服务器 IP 还是通的用_session.Good看也还是True这到底怎么回事。原因会话还在但订阅被服务器静默了。OPC UA 协议规定如果订阅的客户端在一定时间内没有处理 Publish 响应或者通道质量下降服务器会把订阅失败掉。你的程序没有构建任何Publish请求库也没有处理SessionNotification事件服务器发的数据在某个缓冲区里没人取订阅就自动进入暂停状态。解决在Session上挂一个Publish响应处理循环或者至少把Subscription的PublishingMode打开并设置合理的LifetimeCount和MaxKeepAliveCount。这两个参数有个数学关系如果LifetimeCount 100MaxKeepAliveCount 10且PublishingInterval 500那么连续LifetimeCount个发布周期都收不到有效数据时订阅会被服务器移除。因此LifetimeCount要比MaxKeepAliveCount大得多经验值是后者乘以 10 到 20。5.4 变量读出来了Value 却拿不到正确类型现象DataValue.Value返回的不是你要的双精度浮点数而是Int64或者字节数组写入Convert.ToDouble时报错。原因OPC UA 的变量类型是强类型的服务器定义的变量可能是Int32或Int64而你以为是浮点。Value的类型本身可以通过TypeInfo拿到直接强转看起来简单但服务器如果返回的是UInt64且数值大于Double能表示的范围转换后就丢了精度。解决不要盲目转Double。先看result.StatusCode然后根据TypeInfo.BuiltInType做按需转换。实际项目里我写了个辅助函数来处理常见类型核心思路是枚举BuiltInType而不是用TryCast这样能避免很多隐式转换的坑。5.5 断线重连后订阅全丢只能重启程序解决现象服务器端重启或者网络抖动恢复后程序自动重连成功但订阅数据不推送翻日志发现所有监视项都离线了。原因重连时你只重新Session.Create没有把旧的Subscription和MonitoredItem重新创建。旧对象持有的是旧会话的句柄新会话里根本不存在这些订阅。解决把订阅创建封装到一个函数里sessionStatusChanged里一收到新会话建立的消息就清空旧集合然后重新调用订阅创建函数。注意如果旧订阅还挂着事件处理器记得先RemoveHandler否则重复创建时事件会叠加一个数据变化触发十几次回调产线的人会把屏幕点烂。6. 批量读取与数据质量校验让客户端真正能上产线的两个习惯6.1 用一次 Read 调用批量取 50 个变量吞吐翻倍大部分 VB.NET 示例都是一次session.Read读一个点。实际现场一个上位机同时要看几十个参数你串行读几十次每次都有网络往返和服务端处理时间一旦变量数上百整个界面就会被卡到几秒一刷。正确做法是把所有ReadValueId装进一个集合一次Read请求全部读回来Private Function ReadBatch(nodeIds As List(Of String)) As Dictionary(Of String, Object) Dim readIds As New ReadValueIdCollection() For Each id In nodeIds readIds.Add(New ReadValueId() With { .NodeId New NodeId(id), .AttributeId Attributes.Value }) Next Dim results As DataValueCollection Nothing Dim diagnostics As DiagnosticInfoCollection Nothing _session.Read(readIds, 0, TimestampsToReturn.Neither, results, diagnostics) Dim map As New Dictionary(Of String, Object)() For i 0 To nodeIds.Count - 1 If results(i).StatusCode.Code StatusCodes.Good Then map(nodeIds(i)) results(i).Value End If Next Return map End Function注意读批量值时diagnostics参数也要传如果服务器对某个节点返回了诊断信息它不会影响其他正常节点但如果你传Nothing某些实现会直接把整个响应丢弃。这个坑我把排查过程写下来过——读 50 个变量其中 1 个节点权限不足结果整批返回BadNoMatch。6.2 数据质量位不是装饰Good、Uncertain、Bad 三态处理工业现场没有二进制世界那么黑白分明。一个模拟量可能因为它底层的传感器没校准而处于Uncertain状态设备断电后服务器会标记为Bad。如果你的客户端只看Value不管质量位那 MES 里可能攒了一堆假数据决策全部白瞎。在读回DataValue时我习惯用这行代码做网关If dataValue.StatusCode.Code StatusCodes.Good Then 只有 Good 才进历史库或展示 ElseIf dataValue.StatusCode.Code StatusCodes.Uncertain Then 标记黄色预警不中断流程但要提示 Else Bad 状态直接写入告警表触发运维通知 End IfStatusCode.Code只是状态码的数字值你还可以用dataValue.StatusCode.ToString()拿到可读字符串比如Good、BadOutOfService。写日志时建议记字符串而不是纯数字否则半夜查日志看到0x00000000还要去查表。最后一个习惯我每次写完一个客户端都会在连接前把服务器所有端点的安全模式、本地证书指纹、订阅参数全打成一条启动日志存成一个固定文件。这样上线后无论出什么问题都不用靠猜——只需要让现场工程师把那个文件发回来一分钟就能定位是证书问题还是订阅超时问题。这套做法让我少熬了好几个夜希望帮到你。本文还有配套的精品资源点击获取