标签：#SpringBoot #OPCUA #工业物联网 #工控后端 #设备对接

一、前言

上一篇我们完整落地了 SpringBoot + Modbus TCP 工业采集架构，主打传统 PLC、仪表、老旧设备轮询采集。

但在目前自动化产线、智能装备、数控机床、新型工业网关项目中，OPC-UA 已经成为工业通信的事实标准。

很多做惯了互联网 CRUD 的 Java 后端，转行工控物联网最大的短板就是：不会工业协议、不懂设备订阅逻辑、不清楚现场适配规则。

今天给大家分享一套可直接投产、自带容错、断线重连、支持实时订阅的 SpringBoot OPC-UA 完整实战方案，适配 90% 以上工业自动化监控项目。

二、OPC-UA 与 Modbus 精准选型对比

很多新手分不清项目该用哪种协议，这里直接给出现场选型结论：

Modbus TCP 适用场景

• 传统老旧 PLC、普通传感器、电力仪表
• 点位固定、数据量小、低频率采集
• 适合主动轮询模式

OPC-UA 适用场景

• 自动化产线、机器人、数控机床、新型智能设备
• 需要毫秒级实时数据、设备主动上报
• 携带设备状态、故障信息、复杂点位数据
• 跨平台、跨设备通用工业标准

目前主流工业监控项目：Modbus+OPC-UA 双协议兼容，新旧设备全覆盖。

三、项目依赖（稳定投产版本）

目前工业项目通用最稳定的 OPC-UA 开源客户端：Eclipse Milo

<!-- OPC-UA 工业协议核心依赖 -->
<dependency>
    <groupId>org.eclipse.milo</groupId>
    <artifactId>sdk-client</artifactId>
    <version>0.6.10</version>
</dependency>

四、通用连接工具类（可直接投产）

封装核心能力：设备连接、单点读取、断开释放资源，适配内网工业设备，简洁稳定无冗余。

import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
import org.eclipse.milo.opcua.sdk.client.api.identity.UsernameIdentityProvider;
import org.eclipse.milo.opcua.stack.core.UaException;
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger;
import org.springframework.stereotype.Component;

import java.util.concurrent.ExecutionException;

/**
 * OPC-UA 工业设备采集通用工具类
 * 适配产线设备、数控机床、工业网关数据采集
 */
@Component
public class OpcUaUtil {

    private OpcUaClient client;

    /**
     * 初始化 OPC-UA 设备连接
     */
    public OpcUaClient connect(String endpoint, String username, String password) throws UaException {
        OpcUaClientConfig config = OpcUaClientConfig.builder()
                .setEndpointUrl(endpoint)
                .setIdentityProvider(new UsernameIdentityProvider(username, password))
                .setRequestTimeout(UInteger.valueOf(5000))
                .build();

        OpcUaClient opcUaClient = OpcUaClient.create(config);
        opcUaClient.connect().future().join();
        this.client = opcUaClient;
        return opcUaClient;
    }

    /**
     * 读取设备单个节点数据
     */
    public Object readNodeValue(String nodeIdStr) throws ExecutionException, InterruptedException {
        NodeId nodeId = NodeId.parse(nodeIdStr);
        DataValue dataValue = client.readValue(nodeId).get();
        return dataValue.getValue().getValue();
    }

    /**
     * 安全断开设备连接，释放资源
     */
    public void disconnect() {
        try {
            if (client != null) {
                client.disconnect().get();
            }
        } catch (Exception e) {
            // 静默关闭连接，避免服务报错
        }
    }
}

五、工业核心：OPC-UA 实时数据订阅（重点）

Modbus 只能主动轮询，存在延迟、浪费服务性能；
OPC-UA 最大核心优势：设备主动推送数据，被动订阅，实时性拉满。

实时订阅完整实战代码

import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
import org.eclipse.milo.opcua.sdk.client.api.subscription.MonitoredItem;
import org.eclipse.milo.opcua.sdk.client.api.subscription.Subscription;
import org.eclipse.milo.opcua.sdk.client.api.subscription.SubscriptionParameters;
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
import org.eclipse.milo.opcua.stack.core.types.builtin.ReadValueId;
import org.eclipse.milo.opcua.stack.core.types.structured.MonitoringParameters;
import org.springframework.stereotype.Service;

/**
 * OPC-UA 实时数据订阅服务
 * 实现设备数据毫秒级主动推送
 */
@Service
public class OpcUaSubscribeService {

    /**
     * 订阅指定设备节点实时数据
     */
    public void subscribeNodeData(OpcUaClient client, String nodeId) {
        try {
            // 创建订阅任务
            Subscription subscription = Subscription.create(client, SubscriptionParameters.builder()
                    .publishingInterval(100.0) // 100ms 实时推送间隔
                    .maxKeepAliveCount(10)
                    .build());

            // 绑定监听节点
            MonitoredItem monitoredItem = MonitoredItem.create(
                    subscription,
                    ReadValueId.nodeId(NodeId.parse(nodeId)),
                    MonitoringParameters.builder()
                            .samplingInterval(100.0)
                            .build()
            );

            // 数据实时回调处理
            monitoredItem.setOnItemUpdatedListener(itemValue -> {
                // 获取设备实时上报数据
                Object realData = itemValue.getValue().getValue().getValue();
                
                // 此处可拓展：数据清洗、入库、大屏推送、越限告警判断
                System.out.println("设备实时推送数据：" + realData);
            });

            // 启动订阅
            subscription.create().get();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

六、工业现场高频踩坑 + 终极解决方案

1、设备连接失败、证书校验报错

问题原因：内网工业设备大多为私有部署，无正规安全证书，客户端严格校验导致握手失败
解决方案：关闭证书校验，适配内网设备

opc.ua.security.disabled=true

2、订阅一段时间自动断连

问题原因：长时间无数据交互，客户端心跳超时断开
解决方案：新增定时心跳任务，5 秒一次保活连接

3、大批量节点订阅导致服务卡顿

问题原因：单线程监听全部节点，资源占用过高
解决方案：节点分组订阅、线程池隔离、异常设备单独降级处理

七、工控项目协议选型总结

• 老旧 PLC、简单仪表、点位固定场景 → Modbus TCP
• 智能产线、机器人、新型网关、高实时需求 → OPC-UA
• 中大型 SCADA、物联网监控平台 → 双协议兼容部署

八、结尾

工控 Java 开发，设备协议对接能力远比普通 CRUD 更有竞争力。
吃透 Modbus+OPC-UA 两大工业核心协议，基本可以通吃大部分工业物联网、自动化监控后端岗位。