简介本资源是一个面向Java开发者与工业自动化初学者的OPC UA实践工具包聚焦于使用Eclipse Milo 0.6.11库在Java环境中构建OPC UA客户端与服务器解决跨平台设备数据安全互通的开发入门难题。压缩包共46个文件96KB含30个核心Java源码涵盖UaServer启动、UaClient连接、节点读写、MonitoredItem订阅等完整流程、9个XML配置及Maven构建文件如pom.xml、2个.gitignore及2个说明性txt文件结构清晰便于快速理解Milo项目组织规范。已有1778人学习下载适合具备基础Java能力、希望切入工业通信协议开发的工程师。读者可直接运行Demo掌握OPC UA服务端模拟、证书安全配置、变量实时读写及数据变更监听等关键能力并通过源码级调试理解Session建立、Subscription管理及OPC UA信息模型映射逻辑。1. Java 实现 OPC UA 连接及操作的代码工具包 Demo不是写个 Socket 就叫工业互联而是用标准协议打通 PLC、SCADA 和 MES 的第一道门很多刚接触工业自动化集成的 Java 开发者看到“OPC UA”第一反应是这不就是个通信协议写个 TCP 客户端连上去发点二进制数据不就完了——错。OPC UAOpen Platform Communications Unified Architecture不是 HTTP 那种裸协议它是一套带安全模型、信息建模、服务发现、会话管理、节点浏览、属性读写、订阅通知的完整工业语义层。Java 实现 OPC UA核心不是“连上”而是用标准方式理解设备模型、安全握手、结构化读写、实时响应变化。本 Demo 不是玩具级 Hello World而是一个可嵌入生产环境的轻量级工具包雏形它基于开源 OPC UA 栈如 Eclipse Milo封装了连接复用、异常重连、节点路径解析、批量读写、数据变更监听等高频操作屏蔽底层 ASN.1 编码、X.509 证书校验、UA Binary 序列化等细节。适合 Java 后端工程师快速对接西门子 S7-1500、罗克韦尔 ControlLogix、倍福 CX 系列等支持 OPC UA Server 的控制器也适合作为 MES/SCADA 系统中与现场设备交互的统一接入模块。你不需要懂 UA 地址空间AddressSpace的 XML Schema但必须知道NodeId怎么构造、ReadRequest里timestampsToReturn为什么不能设成NEITHER、Subscription的publishingInterval如何避免心跳风暴——这些Demo 里全有实操答案。2. 选型与初始化为什么用 Eclipse Milo 而非自研 UA 栈以及如何在 Spring Boot 中安全加载 OPC UA 客户端2.1 工业级 OPC UA Java 栈的三大现实约束与 Milo 的不可替代性工业现场对通信栈的要求远超通用网络库必须支持 UA 安全策略Basic256Sha256、Aes128_Sha256_RsaOaep、必须兼容 OPC Foundation 认证的 Server如 Prosys OPC UA Simulation Server、Unified Automation UaCPPServer且需通过 IEC 62541 兼容性测试。自研 UA 栈在 2024 年已无必要——Eclipse Milov1.4.x是目前唯一成熟、活跃、文档完备、被 Siemens、Rockwell 官方推荐的 Java 原生实现。它不是简单封装而是严格遵循 Part 4Services、Part 6Mappings规范其UaTcpStackClient内置了 Session 管理、Channel 复用、故障转移Failover机制。对比其他方案Apache Camel OPC UA 组件仅提供路由封装底层仍依赖 MiloSpring Integration OPC UA功能较旧不支持 UA 1.04 新特性如 JSON Encoding纯 Netty 手写 UA需自行实现 CertificateManager、EndpointDescription 解析、SecureChannel 握手状态机——一个CreateSessionRequest的序列化错误就足以让调试耗掉三天。Milo 的client-sdk模块提供了OpcUaClient构建器这是所有操作的起点。2.2 构建最小可运行客户端从 Maven 依赖到证书信任链配置提示OPC UA 默认启用安全通道SecurityMode.SignAndEncrypt跳过证书校验等于放弃工业场景基本准入门槛。以下配置强制启用证书验证禁用Insecure模式。!-- pom.xml -- dependency groupIdorg.eclipse.milo/groupId artifactIdmilosdk-client/artifactId version1.4.3/version /dependency dependency groupIdorg.bouncycastle/groupId artifactIdbcprov-jdk18on/artifactId version1.70/version /dependency// OpcUaClientBuilder.java public class OpcUaClientBuilder { private final String endpointUrl; private final KeyStore keyStore; // 存放客户端私钥和证书 private final TrustManager[] trustManagers; // 服务端证书信任链 public OpcUaClient build() throws Exception { // 1. 创建 SecurityPolicy必须与 Server 端协商一致 SecurityPolicy securityPolicy SecurityPolicy.Basic256Sha256; // 2. 加载客户端证书PKCS#12 格式含私钥 X509Certificate clientCert loadCertificateFromKeyStore(keyStore, client-alias); PrivateKey clientKey loadPrivateKeyFromKeyStore(keyStore, client-alias, password); // 3. 构建 EndpointDescription关键必须匹配 Server 的 Endpoint EndpointDescription endpoint new EndpointDescription( endpointUrl, null, null, null, new ApplicationDescription(JavaClient, urn:java:client, 1.0), new UserTokenPolicy[] { new UserTokenPolicy(anonymous, UserTokenType.Anonymous) }, new TransportProfile[] { TransportProfile.TCP_UA_BINARY }, securityPolicy.getSecurityPolicyUri(), securityPolicy.getSecurityMode() ); // 4. 初始化 ClientConfiguration OpcUaClientConfig config OpcUaClientConfig.builder() .setApplicationName(new LocalizedText(Java OPC UA Client)) .setApplicationUri(urn:java:client) .setCertificate(clientCert) .setKeyPair(new KeyPair(clientCert.getPublicKey(), clientKey)) .setIdentityProvider(new AnonymousIdentityProvider()) // 生产环境应替换为 UsernamePassword .setEndpoint(endpoint) .setTrustManager(trustManagers) .setRequestTimeout(5000) .build(); return new OpcUaClient(config); } }2.2.1 证书生成与信任链配置的关键参数说明参数必填说明常见错误endpointUrl是格式为opc.tcp://192.168.1.100:4840不能省略opc.tcp://前缀写成http://或tcp://导致Unknown protocol异常securityPolicy是必须与 Server 的 Endpoint 列表中某一项完全匹配查看 Prosys Browser 的 Endpoint 对话框Server 仅支持Basic256Sha256客户端设为None会直接拒绝连接trustManagers是生产环境用于验证 Server 证书签名链通常由 Server 提供的ca.der文件构建直接使用new X509TrustManager[]{}会导致SSLHandshakeException: PKIX path building failedrequestTimeout推荐设UA 协议要求所有请求必须在超时内完成否则 Session 自动关闭设为0无限等待将导致线程阻塞影响高并发读写2.3 在 Spring Boot 中管理客户端生命周期避免连接泄漏与 Session 复用失效// OpcUaClientAutoConfiguration.java Configuration EnableConfigurationProperties(OpcUaProperties.class) public class OpcUaClientAutoConfiguration { Bean(destroyMethod disconnect) Scope(ConfigurableBeanFactory.SCOPE_SINGLETON) public OpcUaClient opcUaClient(OpcUaProperties props) throws Exception { OpcUaClient client new OpcUaClientBuilder() .setEndpointUrl(props.getEndpointUrl()) .setKeyStore(loadKeyStore(props.getKeyStorePath(), props.getKeyStorePassword())) .setTrustManagers(buildTrustManagers(props.getTrustStorePath())) .build(); // 注册连接状态监听器关键用于自动重连 client.addLifecycleListener(new OpcUaClientLifecycleListener() { Override public void onConnect(OpcUaClient client) { log.info(OPC UA client connected to {}, props.getEndpointUrl()); } Override public void onDisconnect(OpcUaClient client, Throwable cause) { log.warn(OPC UA client disconnected: {}, cause.getMessage()); // 触发重连逻辑见 3.3 节 } }); return client; } }注意Scope(SINGLETON)destroyMethod disconnect确保 Spring 容器关闭时优雅断开addLifecycleListener是实现断线重连的基础不能仅靠try-catch包裹读写操作。3. 核心操作封装如何用 3 行代码读取 PLC 变量、用 5 行代码监听温度传感器变化3.1 节点地址解析与批量读取告别硬编码 NodeId用路径字符串定位变量OPC UA 的NodeId是ns2;sPLC1.Temperature这类字符串但直接拼接极易出错分号转义、命名空间索引错位。Milo 提供NodeId工具类但更实用的是封装NodePathResolver// NodePathResolver.java public class NodePathResolver { private final OpcUaClient client; public DataValue readByPath(String nodePath) throws UaException, InterruptedException { // 解析路径ns2;sPLC1.Temperature → NamespaceIndex2, BrowseNamePLC1.Temperature int nsIndex extractNamespaceIndex(nodePath); // 提取 ns2 中的 2 String browseName extractBrowseName(nodePath); // 提取 sPLC1.Temperature 中的 PLC1.Temperature // 1. 获取 Root 对象Objects Folder NodeId objectsFolder Identifiers.ObjectsFolder; ReadValueId[] readIds new ReadValueId[] { new ReadValueId( new NodeId(nsIndex, browseName), // 动态构造 NodeId AttributeId.Value.uid(), null, null ) }; // 2. 执行读取注意必须先 connect()否则抛异常 ReadResponse response client.read( 0, // maxAge毫秒0 表示不缓存 TimestampsToReturn.Neither, // 关键设为 Neither 避免时间戳解析开销 readIds ); // 3. 提取结果检查 StatusCode 是否 Good DataValue value response.getResults()[0]; if (!value.getStatusCode().isGood()) { throw new UaException(value.getStatusCode(), Read failed: value.getStatusCode().getDescription()); } return value; } private int extractNamespaceIndex(String path) { return Integer.parseInt(path.split(;)[0].split()[1]); } private String extractBrowseName(String path) { return path.split(;)[1].split()[1]; } }3.1.1 批量读取的性能优化一次请求读取 20 个变量而非 20 次单点请求// BatchReadUtil.java public ListDataValue batchRead(ListString nodePaths) throws UaException, InterruptedException { ReadValueId[] readIds nodePaths.stream() .map(this::pathToReadValueId) .toArray(ReadValueId[]::new); ReadResponse response client.read( 0, TimestampsToReturn.Neither, readIds ); return Arrays.asList(response.getResults()); } private ReadValueId pathToReadValueId(String path) { int ns extractNamespaceIndex(path); String name extractBrowseName(path); return new ReadValueId(new NodeId(ns, name), AttributeId.Value.uid(), null, null); }提示TimestampsToReturn.Neither是工业场景最佳实践——PLC 数据本身不含时间戳Server 返回ServerTimestamp或SourceTimestamp会增加序列化开销且多数 SCADA 系统按自身时钟打时间戳。3.2 订阅数据变更用 Subscription 实现实时温度告警而非轮询轮询Polling在工业场景是反模式每秒查一次温度网络负载翻倍且存在最大 1 秒延迟。OPC UA Subscription 提供真正的事件驱动// TemperatureMonitor.java public class TemperatureMonitor { private final OpcUaClient client; private final Subscription subscription; public TemperatureMonitor(OpcUaClient client) { this.client client; this.subscription client.getSubscriptionManager().createSubscription(1000); // 发布间隔 1000ms } public void startMonitoring(String temperatureNodePath) throws Exception { // 1. 解析 NodeId NodeId nodeId parseNodeId(temperatureNodePath); // 2. 创建 MonitoredItem监控项 MonitoredItemCreateRequest request new MonitoredItemCreateRequest( nodeId, AttributeId.Value.uid(), new ReadValueId(nodeId, AttributeId.Value.uid(), null, null), MonitoringMode.Reporting, new MonitoringParameters( 1L, // clientHandle自定义 ID用于回调区分 1000.0, // samplingInterval毫秒Server 可能调整 null, // filter空表示默认值 10, // queueSize缓冲区大小 true // discardOldest队列满时丢弃旧数据 ) ); // 3. 提交监控请求 MonitoredItemCreateResult result subscription.createMonitoredItems( TimestampsToReturn.Both, Collections.singletonList(request) ).get(5, TimeUnit.SECONDS).get(0); // 4. 注册数据变更监听器 subscription.addNotificationListener(new NotificationListener() { Override public void onDataChange(MonitoredItem item, DataValue value) { double temp ((Double) value.getValue().getValue()).doubleValue(); if (temp 80.0) { alertOverTemperature(temp); } } }); } private NodeId parseNodeId(String path) { String[] parts path.split(;); int ns Integer.parseInt(parts[0].split()[1]); String id parts[1].split()[1]; return new NodeId(ns, id); } }3.2.1 Subscription 关键参数调优表参数推荐值说明影响publishingInterval1000 msServer 向客户端推送更新的周期设太小如 100ms易触发 Server 流控设太大如 5000ms延迟高samplingInterval500 msServer 采样底层变量的频率必须 ≤publishingInterval否则无效queueSize10客户端接收队列长度设为 1 表示只保留最新值设为 100 可能内存溢出discardOldesttrue队列满时是否丢弃旧数据false会导致BadWaitingForInitialData错误4. 故障诊断与生产级加固当连接中断、证书过期、节点不存在时你的 Demo 还能跑吗4.1 连接中断的自动恢复基于 Session 状态机的重连策略OPC UA Session 并非 TCP 连接断网后 Session 可能保持ACTIVATED状态数分钟取决于 Server 的maxKeepAliveCount。单纯捕获UaServiceFaultException不够必须监听SessionState// ReconnectableOpcUaClient.java public class ReconnectableOpcUaClient extends OpcUaClient { private final ScheduledExecutorService scheduler Executors.newSingleThreadScheduledExecutor(); private volatile boolean reconnecting false; public ReconnectableOpcUaClient(OpcUaClientConfig config) { super(config); addLifecycleListener(new OpcUaClientLifecycleListener() { Override public void onSessionInactive(OpcUaClient client) { if (!reconnecting) { scheduleReconnect(); } } }); } private void scheduleReconnect() { reconnecting true; scheduler.schedule(() - { try { connect().get(30, TimeUnit.SECONDS); // 最多重试 30 秒 reconnecting false; log.info(Reconnected successfully); } catch (Exception e) { log.warn(Reconnect failed, retry in 5s: {}, e.getMessage()); scheduleReconnect(); // 指数退避可在此处增强 } }, 5, TimeUnit.SECONDS); } }提示onSessionInactive是 Milo 提供的精准钩子比监听IOException更可靠——TCP 断开后 Session 可能仍处于CREATING状态此时connect()会立即失败。4.2 节点不存在的优雅降级用 BrowseService 定位真实 NodeId硬编码ns2;sPLC1.Temperature风险极高PLC 固件升级后路径可能变为ns2;sMain.Temperature。应先用Browse服务遍历地址空间// NodeBrowser.java public ListReferenceDescription browseChildren(NodeId parentNodeId) throws UaException, InterruptedException { BrowseDescription browseDesc new BrowseDescription( parentNodeId, BrowseDirection.Forward, Identifiers.References, true, // includeSubtypes EnumSet.of(NodeClass.Variable, NodeClass.Object), 0 // maxReferencesPerNode ); BrowseRequest request new BrowseRequest( null, 0, Collections.singletonList(browseDesc), 0 ); BrowseResponse response client.browse(request).get(); return Arrays.asList(response.getResults()[0].getReferences()); } // 使用示例查找所有包含 Temperature 的变量 ListReferenceDescription children browser.browseChildren(Identifiers.ObjectsFolder); children.stream() .filter(r - r.getBrowseName().getName().contains(Temperature)) .forEach(r - System.out.println(Found: r.getBrowseName()));4.2.1 常见 StatusCode 错误码速查表StatusCode含义典型原因解决方案BadNodeIdInvalidNodeId 格式错误或不存在ns1;sxxx中命名空间索引超出 Server 范围用browseChildren()获取合法命名空间列表BadNotReadable节点属性不可读Server 端配置了AccessLevel为CurrentWrite检查 Server 的 UA 节点权限设置BadWaitingForInitialData订阅队列为空queueSize1且首次推送未到达增加queueSize或等待publishingInterval后再读BadCertificateUseNotAllowed客户端证书未授权Server 的 Certificate Trust ListCTL未导入客户端证书将客户端证书 DER 文件添加到 Server 的 CTL4.3 生产环境日志与指标埋点让运维一眼看出是网络问题还是 PLC 故障// OpcUaMetrics.java Component public class OpcUaMetrics { private final MeterRegistry meterRegistry; private final Counter readErrorCounter; private final Timer readLatencyTimer; public OpcUaMetrics(MeterRegistry registry) { this.meterRegistry registry; this.readErrorCounter Counter.builder(opcua.read.error) .description(Count of failed read operations) .register(registry); this.readLatencyTimer Timer.builder(opcua.read.latency) .description(Latency of read operations) .register(registry); } public void recordReadFailure(String nodePath, StatusCode statusCode) { readErrorCounter.tag(node, nodePath) .tag(status, statusCode.name()) .increment(); } public void recordReadLatency(String nodePath, Duration duration) { readLatencyTimer.tag(node, nodePath) .record(duration); } }注意将readLatencyTimer.record(duration)放在readByPath()方法末尾recordReadFailure()放在catch (UaException e)块中——这样 Prometheus 可直接抓取opcua_read_latency_seconds_bucket指标结合opcua_read_error_total{statusBadNodeIdInvalid}快速定位问题根因。5. 实战技巧用 Prosys OPC UA Browser 验证你的 Java 客户端行为是否符合规范5.1 三步验证法确认你的 Demo 不是“伪连接”很多开发者以为client.connect().get()返回即代表成功但实际可能只是 TCP 握手成功UA Session 未建立。必须用 Prosys Browser免费版足够交叉验证步骤一用 Browser 连接到同一 Endpoint启动 Prosys OPC UA Browser →File→Connect...→ 输入opc.tcp://192.168.1.100:4840选择Security Policy: Basic256Sha256User Identity: Anonymous成功后左侧树形视图应展开Objects→PLC1→Temperature步骤二比对 NodeId 和 Attributes在 Browser 中右键Temperature→View Node→ 查看NodeId如ns2;i1001对比 Java 代码中new NodeId(2, PLC1.Temperature)是否与 Browser 显示的BrowseName一致查看Attributes页签确认Value的DataType是DoubleAccessLevel包含CurrentRead步骤三同步执行读写观察行为一致性在 Browser 中双击Temperature→Read记录返回值如25.3运行 Java Demo 的readByPath(ns2;sPLC1.Temperature)比对值是否相同在 Browser 中修改值 → Java 订阅回调是否在 1 秒内触发验证publishingInterval5.2 证书调试技巧当 Browser 连接成功但 Java 报BadCertificateInvalid时Prosys Browser 默认信任所有证书开发模式而 Java 客户端严格校验。此时需导出 Server 证书并导入 Java TrustStore# 1. 用 Browser 连接 Server 后导出 Server 证书File → Export → Certificate # 2. 将导出的 server.cer 转为 PEM 格式若为 DER openssl x509 -inform DER -in server.cer -out server.pem # 3. 导入到 Java TrustStore假设使用 $JAVA_HOME/jre/lib/security/cacerts keytool -import -alias opcua-server -file server.pem -keystore $JAVA_HOME/jre/lib/security/cacerts -storepass changeit提示keytool -list -v -keystore $JAVA_HOME/jre/lib/security/cacerts | grep -A 1 opcua-server可验证证书是否导入成功。Java 客户端的trustManagers必须指向此 keystore。5.3 性能压测关键命令用 JMeter 模拟 100 个客户端并发读取# 1. 编写 JMeter BeanShell Sampler模拟 Milo 客户端 import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId; import org.eclipse.milo.opcua.stack.core.types.enumerated.AttributeId; import org.eclipse.milo.opcua.sdk.client.OpcUaClient; import org.eclipse.milo.opcua.sdk.client.api.nodes.VariableNode; OpcUaClient client (OpcUaClient) props.get(opcua.client); VariableNode node client.getAddressSpace().getVariableNode(new NodeId(2, PLC1.Temperature)); DataValue value node.readValue().get(); vars.put(temperature, value.getValue().getValue().toString()); # 2. 设置 Thread Group100 线程Ramp-up 10 秒Loop Count 100 # 3. 添加 Response Assertion检查 ${temperature} 是否为数字运行后观察opcua_read_latency_seconds_max指标——若 P99 200ms需检查 Server 的MaxRequestSize是否过小或客户端requestTimeout是否需调大。本文还有配套的精品资源点击获取