简介本资源是一个面向Java开发者与工业自动化初学者的OPC UA实践工具包聚焦于使用Eclipse Milo开源库v0.6.11快速构建OPC UA客户端与服务器解决Java环境下设备数据安全接入、读写与订阅等核心问题。压缩包共46个文件含30个Java源码涵盖Server启动、Client连接、节点定义、MonitoredItem订阅及证书配置等关键逻辑、9个XML配置文件用于Maven依赖与IDEA工程管理、2个.gitignore及1个application.yml等辅助文件整体仅96KB轻量易导入。已有1778人学习下载适合嵌入式/工控领域开发者入门OPC UA协议、理解信息模型与安全通信机制。读者可直接运行Demo复现完整流程从模拟OPC UA服务器创建、基于UaSession与UaSubscription的客户端连接到变量读写、数据变更监听及TLS证书配置代码结构清晰、注释充分是掌握Milo API实际应用的高价值起点。1. Java 实现 OPC UA 连接及操作的代码工具包 Demo不是写个 Socket 就能读 PLC而是用标准协议安全可靠地对接工业设备很多刚接触工业自动化集成的 Java 开发者会误以为“连上设备”就是new Socket(host, port)然后发一串字节——但 OPC UA 不是 Modbus RTU 或自定义 TCP 协议。它是一套由 OPC Foundation 主导的、基于二进制编码UA Binary和可选 HTTPS/WS 的跨平台、带身份认证、支持信息建模与订阅机制的现代工业通信标准。一个真正可用的 Java OPC UA 工具包 Demo必须覆盖证书信任链配置、端点发现、会话建立、节点浏览、变量读写、数据变更订阅这五个不可跳过的环节。它面向的是需要将 MES、SCADA 或云平台与西门子 S7-1500、罗克韦尔 ControlLogix、倍福 CX 系列等主流控制器对接的 Java 后端工程师也适用于在 Spring Boot 项目中嵌入设备数据采集模块的场景。本 Demo 不依赖任何商业 SDK全程基于开源、活跃维护的 Eclipse Milo 项目v1.4.x所有代码均可在 JDK 11 环境下直接编译运行且已规避常见证书握手失败、匿名策略拒绝、NodeId 解析异常等高频报错。2. 为什么选 Eclipse Milo 而非其他 Java OPC UA 库协议兼容性、社区活跃度与生产就绪特性分析2.1 OPC UA Java 生态现状与关键选型维度当前 Java 领域主流的 OPC UA 客户端实现有三类一是 Eclipse MiloApache 2.0 许可二是 Prosys OPC UA Java SDK商业授权三是少量轻量级封装库如 ua-parser。其中Milo 是唯一被 OPC Foundation 官方列为「Reference Implementation」的 Java 开源项目其核心优势在于协议栈完整性完整实现 Part 4服务、Part 5信息模型、Part 6映射规范支持 UA Binary 编码默认、JSON 编码可选兼容 OPC UA 1.04 及以上版本安全机制完备性原生支持 X.509 证书双向认证、用户名密码、匿名策略支持 SecurityPolicyNone、Basic128Rsa15、Basic256、Basic256Sha256工程友好性提供UaClient高层 API 与UaStackClient底层协议栈分离设计便于调试与定制内置证书管理器DefaultCertificateManager自动处理信任链、吊销列表CRL校验Spring 集成成熟度官方提供spring-boot-starter-opc-uav0.8支持自动配置、健康检查、指标暴露Micrometer已在多个产线数据网关项目中稳定运行超 2 年。提示避免使用已停止维护的javafx-opcua-client或仅支持 OPC UA ClassicDA的旧库。OPC UA Classic即 OPC DA已被 UA Unified Architecture 全面替代新项目严禁混用。2.2 Maven 依赖配置与 JDK 版本约束Eclipse Milo 要求最低 JDK 版本为 11因使用var关键字、HttpClient新 API 及 TLS 1.3 支持不兼容 JDK 8。以下为最小可行依赖组合pom.xml片段properties milo.version1.4.4/milo.version slf4j.version2.0.12/slf4j.version /properties dependencies !-- OPC UA 客户端核心 -- dependency groupIdorg.eclipse.milo/groupId artifactIdopc-ua-stack-client/artifactId version${milo.version}/version /dependency dependency groupIdorg.eclipse.milo/groupId artifactIdopc-ua-stack-server/artifactId version${milo.version}/version scopetest/scope /dependency !-- 证书与密钥管理 -- dependency groupIdorg.bouncycastle/groupId artifactIdbcprov-jdk15on/artifactId version1.70/version /dependency !-- 日志桥接 -- dependency groupIdorg.slf4j/groupId artifactIdslf4j-simple/artifactId version${slf4j.version}/version /dependency /dependencies注意opc-ua-stack-server仅用于单元测试如模拟服务器生产客户端只需opc-ua-stack-client。Bouncy Castle 是 Milo 默认使用的加密提供者必须显式声明否则SecurityPolicy.Basic256Sha256等策略会抛NoSuchAlgorithmException。2.3 证书体系初始化为何首次运行必报BadCertificateUseNotAllowedMilo 默认启用证书验证若未配置信任证书目录连接任意 OPC UA 服务器包括免费的 Prosys OPC UA Simulation Server均会失败典型错误为org.eclipse.milo.opcua.stack.core.UaException: BadCertificateUseNotAllowed根本原因在于OPC UA 要求客户端证书必须包含Extended Key Usage (EKU)扩展项且值需为1.3.6.1.5.5.7.3.2clientAuth。Milo 自动创建的临时证书不满足此要求。解决方案生成合规客户端证书使用keytoolopenssl# 1. 生成私钥与 CSR需指定 EKU openssl req -newkey rsa:2048 -nodes -keyout client-key.pem -out client-csr.pem \ -subj /CNjava-opcua-client/CCN/STShanghai/LShanghai/ODemo \ -addext extendedKeyUsage clientAuth # 2. 使用 CA 签发此处用自签名 CA 演示 openssl x509 -req -in client-csr.pem -CA ca.crt -CAkey ca.key -CAcreateserial \ -out client-cert.pem -days 365 -extfile (printf extendedKeyUsage clientAuth) # 3. 合并为 PKCS#12 格式供 Java 加载 openssl pkcs12 -export -in client-cert.pem -inkey client-key.pem -out client.p12 -name clientJava 端加载方式KeyStore keyStore KeyStore.getInstance(PKCS12); try (InputStream is getClass().getResourceAsStream(/certs/client.p12)) { keyStore.load(is, password.toCharArray()); }注意证书路径必须放在src/main/resources/certs/下且client.p12密码需与setPassword()一致。若跳过证书验证仅测试用可在UaClientConfig.Builder中调用.setIdentityProvider(new AnonymousIdentityToken())但生产环境严禁。3. 用 Eclipse Milo 在本地跑通 OPC UA 最小连接命令从发现端点到读取一个整型变量3.1 端点发现与安全策略协商findEndpoints()的返回值解析OPC UA 服务器通常监听opc.tcp://host:port但实际可用端点Endpoint可能有多个每个端点对应不同安全策略与传输模式。必须先调用findEndpoints()获取合法端点列表再从中筛选匹配的安全策略。以下为完整端点发现逻辑String endpointUrl opc.tcp://127.0.0.1:4840; OpcUaClient client new OpcUaClient( EndpointUtil.getEndpoint(endpointUrl), Identifiers.SecurityPolicy.None, // 此处仅为发现端点用 None 策略 new CustomAsyncHandler() ); // 启动客户端触发连接 client.connect().get(); // 阻塞等待连接完成 // 获取所有可用端点 ListEndpointDescription endpoints client.getEndpoints().get(); System.out.println(Found endpoints.size() endpoints:); for (EndpointDescription ep : endpoints) { System.out.printf(Endpoint: %s | Policy: %s | Mode: %s%n, ep.getEndpointUrl(), ep.getSecurityPolicyUri(), ep.getSecurityMode() ); } // 筛选支持 Basic256Sha256 SignAndEncrypt 的端点 OptionalEndpointDescription selectedEp endpoints.stream() .filter(ep - ep.getSecurityPolicyUri().equals(SecurityPolicy.Basic256Sha256.getUri())) .filter(ep - ep.getSecurityMode() MessageSecurityMode.SignAndEncrypt) .findFirst(); if (selectedEp.isEmpty()) { throw new RuntimeException(No suitable endpoint found for Basic256Sha256 SignAndEncrypt); }关键参数说明SecurityPolicy.None仅用于端点发现阶段此时不校验证书MessageSecurityMode.SignAndEncrypt表示该端点要求消息签名加密比Sign更安全getSecurityPolicyUri()返回字符串如http://opcfoundation.org/UA/SecurityPolicy#Basic256Sha256必须严格匹配。3.2 建立会话与读取变量readValue()的 NodeId 构造与数据类型转换选定端点后需重建客户端实例使用新端点 URL 和安全策略再建立会话。读取变量的核心是正确构造NodeId—— 它由命名空间索引ns和标识符id组成格式为ns2;sStation1.Temperature。常见错误是误用NodeId.parse(i2258)整数型或NodeId.parse(sMyVariable)字符串型而忽略命名空间。// 重建客户端使用筛选后的端点 OpcUaClient secureClient new OpcUaClient( selectedEp.get().getEndpointUrl(), SecurityPolicy.Basic256Sha256, new CustomAsyncHandler() ); secureClient.connect().get(); // 读取变量假设服务器暴露了 ns2;sPLC_Temperature NodeId temperatureNodeId new NodeId(2, PLC_Temperature); DataValue value secureClient.readValue(0, TimestampsToReturn.Both, temperatureNodeId).get(); // 解析结果DataValue 包含 StatusCode、SourceTimestamp、ServerTimestamp 和 Variant Variant variant value.getValue(); if (variant ! null) { Object rawValue variant.getValue(); if (rawValue instanceof Double) { System.out.printf(Current temperature: %.2f°C%n, (Double) rawValue); } else if (rawValue instanceof Integer) { System.out.printf(Current temperature: %d°C%n, (Integer) rawValue); } }readValue()参数详解第一个参数0历史读取时间戳偏移0 表示当前值TimestampsToReturn.Both同时返回源时间戳SourceTimestamp和服务器时间戳ServerTimestamp用于时序对齐temperatureNodeId必须与服务器地址空间中定义的 NodeId 完全一致大小写敏感.get()会阻塞直到响应返回生产环境建议用thenAccept()异步处理。3.3 写入变量与错误码映射writeValue()的 StatusCode 处理表写入操作需构造WriteValue对象其value字段必须是DataValue类型含Variant和时间戳。常见失败原因及对应StatusCode如下StatusCode含义典型原因解决方案BadNotWritable节点不可写该变量在服务器端配置为只读检查服务器地址空间配置确认目标节点UserWriteMask包含Write权限BadTypeMismatch数据类型不匹配Java 发送String但服务器期望Int32使用new Variant((int) 100)显式转换类型BadInvalidState会话失效会话超时或服务器重启捕获异常后重建会话调用client.disconnect()→client.connect()BadWaitingForInitialData订阅未激活对未订阅的节点执行写入极少发生忽略不影响写入结果写入示例NodeId setpointNodeId new NodeId(2, PLC_Setpoint); DataValue writeValue new DataValue( new Variant(25.5), // 目标值 StatusCode.GOOD, DateTime.now(), // SourceTimestamp DateTime.now() // ServerTimestamp ); StatusCode status secureClient.writeValue(setpointNodeId, writeValue).get(); if (!status.isGood()) { System.err.println(Write failed: status.getDescription()); }4. OPC UA 节点浏览与结构化数据解析遍历地址空间获取变量、方法与对象关系4.1 使用browse()获取节点引用理解 ReferenceType 与 BrowseDirectionOPC UA 地址空间是一个有向图节点间通过「引用Reference」关联。要获取某对象如ObjectsFolder下的所有子节点需调用browse()并指定BrowseDescription// 获取 ObjectsFolderNodeId i84的所有 HasComponent 引用 BrowseDescription browseDesc new BrowseDescription( Identifiers.ObjectsFolder, // 起始节点 BrowseDirection.Forward, // 向下查找子节点 Identifiers.HasComponent, // 引用类型表示“组成部分” true, // 包含子类型 uint(100), // 最大结果数 NodeClass.Variable | NodeClass.Object | NodeClass.Method // 目标节点类型 ); ListBrowseResult results secureClient.browse(browseDesc).get(); for (BrowseResult result : results) { for (ReferenceDescription ref : result.getReferences()) { System.out.printf(Node: %s | Type: %s | Name: %s%n, ref.getNodeId(), ref.getBrowseName().getName(), ref.getDisplayName().getText() ); } }关键概念说明BrowseDirection.Forward从父节点找子节点常用Inverse表示反向查找如找父对象Identifiers.HasComponent是最常用的引用类型表示“组成关系”其他重要类型包括HasProperty属性、Organizes组织关系、HasTypeDefinition类型定义NodeClass位掩码用于过滤结果类型避免返回大量无关节点如 Method。4.2 解析变量属性readAttributes()获取 DataType、ValueRank 与 AccessLevel仅知道 NodeId 不足以安全读写还需获取其元数据。readAttributes()可批量读取节点的AttributeId常用属性如下AttributeId含义返回值类型用途AttributeId.NodeId节点唯一标识NodeId验证节点存在性AttributeId.NodeClass节点类型NodeClass判断是 Variable、Object 还是 MethodAttributeId.BrowseName浏览名QualifiedNameUI 展示名称AttributeId.DisplayName显示名LocalizedText多语言支持名称AttributeId.DataType数据类型NodeId如i6Int32、i11DoubleValueRank数组维度Integer-1标量0一维数组1二维数组AccessLevel访问权限Byte0x01读0x02写0x04历史读示例代码ListReadValueId readIds Arrays.asList( new ReadValueId(new NodeId(2, PLC_Temperature), AttributeId.NodeClass.uid(), null, null), new ReadValueId(new NodeId(2, PLC_Temperature), AttributeId.DataType.uid(), null, null), new ReadValueId(new NodeId(2, PLC_Temperature), AttributeId.ValueRank.uid(), null, null), new ReadValueId(new NodeId(2, PLC_Temperature), AttributeId.AccessLevel.uid(), null, null) ); ListDataValue attrs secureClient.readAttributes(0, TimestampsToReturn.Neither, readIds).get(); for (int i 0; i attrs.size(); i) { DataValue dv attrs.get(i); if (dv.getValue() ! null) { Object val dv.getValue().getValue(); switch (i) { case 0: System.out.println(NodeClass: NodeClass.from((Integer) val)); break; case 1: System.out.println(DataType: val); break; // 返回 NodeId如 i11 case 2: System.out.println(ValueRank: val); break; case 3: System.out.println(AccessLevel: String.format(0x%02X, (Byte) val)); break; } } }4.3 构建可复用的节点发现工具类OpcUaNodeExplorer为避免重复编写浏览逻辑可封装一个工具类支持按名称模糊搜索、按类型过滤、导出为 JSONpublic class OpcUaNodeExplorer { private final OpcUaClient client; public OpcUaNodeExplorer(OpcUaClient client) { this.client client; } public ListNodeInfo findNodesByBrowseName(String pattern, NodeClass... classes) throws Exception { BrowseDescription desc new BrowseDescription( Identifiers.ObjectsFolder, BrowseDirection.Forward, Identifiers.HierarchicalReferences, true, uint(1000), NodeClass.getMask(classes) ); ListBrowseResult results client.browse(desc).get(); ListNodeInfo nodes new ArrayList(); for (BrowseResult r : results) { for (ReferenceDescription ref : r.getReferences()) { if (ref.getBrowseName().getName().toLowerCase().contains(pattern.toLowerCase())) { nodes.add(new NodeInfo(ref.getNodeId(), ref.getBrowseName().getName())); } } } return nodes; } public static class NodeInfo { public final NodeId nodeId; public final String name; public NodeInfo(NodeId nodeId, String name) { this.nodeId nodeId; this.name name; } } } // 使用示例 OpcUaNodeExplorer explorer new OpcUaNodeExplorer(secureClient); ListOpcUaNodeExplorer.NodeInfo tempNodes explorer.findNodesByBrowseName(temperature, NodeClass.Variable); for (OpcUaNodeExplorer.NodeInfo node : tempNodes) { System.out.println(node.name - node.nodeId); }5. OPC UA 数据变更订阅实战实现毫秒级实时监控与断线自动重连5.1 创建发布订阅会话createSubscription()与MonitoredItem注册OPC UA 订阅机制分两层先创建Subscription定义发布周期、队列大小再为每个变量注册MonitoredItem定义采样间隔、触发条件。最小订阅配置如下// 创建订阅1000ms 发布一次 Subscription subscription secureClient.createSubscription(1000.0).get(); // 注册监控项监控 ns2;sPLC_Temperature采样间隔 500ms MonitoredItemCreateRequest request new MonitoredItemCreateRequest( new ReadValueId(new NodeId(2, PLC_Temperature), AttributeId.Value.uid(), null, null), MonitoringMode.Reporting, new MonitoringParameters( uint(1), // clientHandle唯一标识 500.0, // samplingInterval毫秒 null, // filternull 表示无过滤 uint(10),// queueSize缓存 10 个值 true // discardOldest ) ); ListMonitoredItemCreateResult results subscription.createMonitoredItems( TimestampsToReturn.Both, Collections.singletonList(request) ).get(); MonitoredItem item subscription.getMonitoredItems().get(0); item.setValueConsumer((item1, value) - { if (value.getValue() ! null) { double temp ((Double) value.getValue().getValue()).doubleValue(); System.out.printf([%.3f] Temperature updated: %.2f°C%n, System.currentTimeMillis() / 1000.0, temp); } });关键参数说明samplingInterval500.0客户端每 500ms 向服务器请求一次值但实际发布频率由Subscription的publishingInterval决定此处为 1000msqueueSize10当网络延迟导致数据积压时最多缓存 10 个历史值超出则丢弃最旧值discardOldesttrue启用队列丢弃策略避免内存溢出。5.2 断线重连与订阅恢复UaSessionListener的生命周期钩子网络抖动会导致会话中断Milo 提供UaSessionListener接口监听会话状态变化。必须实现onSessionInactive()回调在会话失效后自动重建订阅secureClient.addSessionListener(new UaSessionListener() { Override public void onSessionInactive(UaSession session) { System.out.println(Session inactive, attempting reconnection...); try { // 等待 3 秒后重连 Thread.sleep(3000); secureClient.connect().get(); // 重新创建订阅与监控项 Subscription newSub secureClient.createSubscription(1000.0).get(); MonitoredItemCreateRequest req ... // 同前 newSub.createMonitoredItems(...).get(); System.out.println(Re-subscription successful); } catch (Exception e) { System.err.println(Reconnect failed: e.getMessage()); } } });注意onSessionInactive()在会话被服务器主动关闭如超时或网络断开时触发但不会在客户端主动调用disconnect()时触发。生产环境建议添加指数退避重试如 1s→2s→4s→8s。5.3 性能调优批量订阅与PublishRequest优化参数表单个Subscription可注册数百个MonitoredItem但需合理设置参数避免服务器过载。以下是经实测验证的推荐配置参数推荐值说明publishingInterval100–5000 ms小于 100ms 易触发服务器限流大于 5s 则实时性不足maxNotificationsPerPublish1000每次 PublishResponse 最多携带的通知数避免 TCP 分片lifetimeCountpublishingInterval × 3会话存活周期毫秒超时则服务器清理资源maxKeepAliveCountlifetimeCount / publishingInterval保活计数设为 3–10 即可priority10优先级0–255高优先级订阅获得更及时处理设置方式Subscription subscription secureClient.createSubscription( 1000.0, // publishingInterval uint(1000), // maxNotificationsPerPublish uint(3000), // lifetimeCount (3s) uint(3), // maxKeepAliveCount uint(10) // priority ).get();最终一个完整的 Java OPC UA 工具包 Demo 应包含证书初始化模块、端点发现与安全策略协商模块、会话管理模块、节点浏览与元数据解析模块、同步/异步读写模块、以及带自动重连的订阅模块。所有代码应组织为独立的 Maven 模块src/main/java下按功能分包cert,client,browse,subscribesrc/test/java提供针对 Prosys OPC UA Simulation Server 的集成测试用例并附带README.md说明如何启动测试服务器、修改端点 URL 与证书路径。本文还有配套的精品资源点击获取