如何可靠写入OPC UA服务器及获取节点DataType？

你遇到的问题很典型：浏览操作只能获取节点的基础关联信息，而DataType是Variable节点的专属属性，必须通过「读取属性」的操作才能拿到。下面给你具体的解决思路和代码修改方案：

问题根源 #

你当前用的browse方法返回的ReferenceDescription对象里，typeDefinition、typeId这些字段都是节点的类型定义（比如BaseDataVariableType），不是你要的实际数据类型（比如Int16）。DataType是Variable节点的核心属性之一，必须显式读取这个属性才能拿到。

解决方案步骤 #

1. 过滤Variable节点：只有NodeClass为Variable的节点才需要获取DataType，遍历浏览结果时先做判断；
2. 读取DataType属性：对每个Variable节点，调用客户端的readAttribute方法，读取Identifiers.DataType属性；
3. 缓存DataType信息：扩展你的节点缓存，把DataType和NodeId一起存储，方便后续写入时快速查询。

修改后的代码示例 #

// 自定义类存储节点的NodeId和DataType，也可用HashMap<String, Object[]>替代
class NodeMetadata {
    private NodeId nodeId;
    private NodeId dataTypeId;

    public NodeMetadata(NodeId nodeId, NodeId dataTypeId) {
        this.nodeId = nodeId;
        this.dataTypeId = dataTypeId;
    }

    // getter方法
    public NodeId getNodeId() { return nodeId; }
    public NodeId getDataTypeId() { return dataTypeId; }
}

@SuppressWarnings("deprecation")
private HashMap<String, NodeMetadata> browseNode(String indent, OpcUaClient client, NodeId browseRoot, HashMap<String, NodeMetadata> nodesMap) {
    BrowseDescription browse = new BrowseDescription(
        browseRoot,
        BrowseDirection.Forward,
        Identifiers.References,
        true,
        uint(NodeClass.Object.getValue() | NodeClass.Variable.getValue()),
        uint(BrowseResultMask.All.getValue()));
    try {
        BrowseResult browseResult = client.browse(browse).get();
        List<ReferenceDescription> references = toList(browseResult.getReferences());
        for (ReferenceDescription rd : references) {
            UShort namespaceIndex = rd.getNodeId().getNamespaceIndex();
            String identifier = rd.getNodeId().getIdentifier().toString();
            NodeId node = new NodeId(namespaceIndex, identifier);

            NodeMetadata metadata = null;
            // 仅处理Variable节点，获取其DataType属性
            if (rd.getNodeClass() == NodeClass.Variable) {
                // 读取DataType属性
                DataValue dataTypeValue = client.readAttribute(node, Identifiers.DataType).get();
                NodeId dataTypeId = (NodeId) dataTypeValue.getValue().getValue();
                metadata = new NodeMetadata(node, dataTypeId);
                logger.info("节点 {} 的DataType: {}", identifier, dataTypeId.getIdentifier());
            } else {
                metadata = new NodeMetadata(node, null);
            }

            nodesMap.put(identifier, metadata);
            logger.info("----------------------------------------------------------------");
            logger.info(identifier);

            // 递归浏览子节点
            rd.getNodeId().local().ifPresent(nodeId -> {
                browseNode(indent + " ", client, nodeId, nodesMap);
            });
        }
    } catch (InterruptedException | ExecutionException e) {
        logger.error("Browsing nodeId={} failed: {}", browseRoot, e.getMessage(), e);
    }
    return nodesMap;
}

额外优化建议 #

• 批量读取属性：如果服务器节点数量较多，逐个读取DataType会增加网络开销。可以收集所有Variable节点的ReadValueId，然后调用client.readValues()一次性读取，大幅提升效率；
• 映射到Java类型：拿到DataType的NodeId后，可以进一步映射到对应的Java类型（比如Identifiers.Int16对应Short.class），这样写入时可以自动转换数值类型，避免不匹配。比如你提到的TestNodeOne是Int16类型，就把3转换成Short类型再调用写入API。

写入时的类型匹配示例 #

当你要写入TestNodeOne时，从缓存中拿到它的DataType是Identifiers.Int16，就可以这样处理：

NodeMetadata metadata = nodesMap.get("TestNodeOne");
if (metadata.getDataTypeId().equals(Identifiers.Int16)) {
    // 把数值3转换成Short类型
    Short value = Short.valueOf("3");
    client.writeValue(metadata.getNodeId(), new DataValue(new Variant(value))).get();
}

内容的提问来源于stack exchange，提问作者Necrophades