milo：Eclipse Milo:trade_mark:-OPC UA的开源实现（IEC 62541）

/* * Copyright (c) 2019 the Eclipse Milo Authors * * This program and the accompanying materials are made * available under the terms of the Eclipse Public License 2.0 * which is available at https://www.eclipse.org/legal/epl-2.0/ * * SPDX-License-Identifier: EPL-2.0 */ package org.eclipse.milo.opcua.sdk.server.namespaces.loader; import java.io.IOException; import java.io.StringReader; import org.eclipse.milo.opcua.sdk.core.Reference; import org.eclipse.milo.opcua.sdk.server.api.NodeManager; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.BaseDataVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.BuildInfoTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.ConditionVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.DataTypeDescriptionTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.DataTypeDictionaryTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.FiniteStateVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.FiniteTransitionVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.ProgramDiagnosticTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.PropertyTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SamplingIntervalDiagnosticsArrayTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SamplingIntervalDiagnosticsTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.ServerDiagnosticsSummaryTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.ServerStatusTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.ServerVendorCapabilityTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SessionDiagnosticsArrayTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SessionDiagnosticsVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SessionSecurityDiagnosticsArrayTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SessionSecurityDiagnosticsTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.StateVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SubscriptionDiagnosticsArrayTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.SubscriptionDiagnosticsTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.TransitionVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.model.nodes.variables.TwoStateVariableTypeNode; import org.eclipse.milo.opcua.sdk.server.nodes.UaNode; import org.eclipse.milo.opcua.sdk.server.nodes.UaNodeContext; import org.eclipse.milo.opcua.stack.core.Identifiers; import org.eclipse.milo.opcua.stack.core.serialization.OpcUaXmlStreamDecoder; import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue; import org.eclipse.milo.opcua.stack.core.types.builtin.LocalizedText; import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId; import org.eclipse.milo.opcua.stack.core.types.builtin.QualifiedName; import org.eclipse.milo.opcua.stack.core.types.builtin.Variant; import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte; import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger; import org.xml.sax.SAXException; class VariableNodeLoader { private final UaNodeContext context; private final NodeManager<UaNode> nodeManager; VariableNodeLoader(UaNodeContext context, NodeManager<UaNode> nodeManager) { this.context = context; this.nodeManager = nodeManager; } private void loadNode0() throws IOException, SAXException { DataTypeDescriptionTypeNode node = new DataTypeDescriptionTypeNode(this.context, Identifiers.OpcUa_BinarySchema_RedundantServerDataType, new QualifiedName(0, "RedundantServerDataType"), new LocalizedText("en", "RedundantServerDataType"), LocalizedText.NULL_VALUE, UInteger.valueOf(0), UInteger.valueOf(0), new DataValue(Variant.NULL_VALUE), Identifiers.String, -1, new UInteger[]{}, UByte.valueOf(1), UByte.valueOf(1), 0.0, false); node.addReference(new Reference(Identifiers.OpcUa_BinarySchema_RedundantServerDataType, Identifiers.HasTypeDefinition, Identifiers.DataTypeDescriptionType.expanded(), true)); node.addReference(new Reference(Identifiers.OpcUa_BinarySchema_RedundantServerDataType, Identifiers.HasComponent, Identifiers.OpcUa_BinarySchema.expanded(), false)); StringBuilder sb = new StringBuilder(); sb.append("<String xmlns=\"http://opcfoundation.org/UA/2008/02/Types.xsd\">RedundantServerDataType</String>"); String xml = sb.toString(); OpcUaXmlStreamDecoder decoder = new OpcUaXmlStreamDecoder(context.getServer().getSerializationContext()).setInput(new StringReader(xml)); Object o = decoder.readVariantValue(); DataValue value = new DataValue(new Variant(o)); node.setValue(value); this.nodeManager.addNode(node); } private void loadNode1() throws IOException, SAXException { DataTypeDescriptionTypeNode node = new DataTypeDescriptionTypeNode(this.context, Identifiers.OpcUa_BinarySchema_SamplingIntervalDiagnosticsDataType, new QualifiedName(0, "SamplingIntervalDiagnosticsDataType"), new LocalizedText("en", "SamplingIntervalDiagnosticsDataType"), LocalizedText.NULL_VALUE, UInteger.valueOf(0), UInteger.valueOf(0), new DataValue(Variant.NULL_VALUE), Identifiers.String, -1, new UInteger[]{}, UByte.valueOf(1), UByte.valueOf(1), 0.0, false); node.addReference(new Reference(Identifiers.OpcUa_BinarySchema_SamplingIntervalDiagnosticsDataType, Identifiers.HasTypeDefinition, Identifiers.DataTypeDescriptionType.expanded(), true)); node.addReference(new Reference(Identifiers.OpcUa_BinarySchema_SamplingIntervalDiagnosticsDataType, Identifiers.HasComponent, Identifiers.OpcUa_BinarySchema.expanded(), false)); StringBuilder sb = new StringBuilder(); sb.append("<String xmlns=\"http://opcfoundation.org/UA/2008/02/Types.xsd\">SamplingIntervalDiagnosticsDataType</String>"); String xml = sb.toString(); OpcUaXmlStreamDecoder decoder = new OpcUaXmlStreamDecoder(context.getServer().getSerializationContext()).setInput(new StringReader(xml)); Object o = decoder.readVariantValue(); DataValue value = new DataValue(new Variant(o)); node.setValue(value); this.nodeManager.addNode(node); } private void loadNode2() throws IOException, SAXException { DataTypeDescriptionTypeNode node = new DataTypeDescriptionTypeNode(this.context, Identifiers.OpcUa_BinarySchema_ServerDiagnosticsSummaryDataType, new QualifiedName(0, "ServerDiagnosticsSummaryDataType"), new LocalizedText("en", "ServerDiagnosticsSummaryDataType"), LocalizedText.NULL_VALUE, UInteger.valueOf(0), UInteger.valueOf(0), new DataValue(Variant.NULL_VALUE), Identifiers.String, -1, new UInteger[]{}, UByte.valueOf(1), UByte.valueOf(1), 0.0, false); node.addReference(new Reference(Identifiers.OpcUa_BinarySchema_ServerDiagnosticsSummaryDataType, Identifiers.HasTypeDefinition, Identifiers.DataTypeDescriptionType.expanded(), true)); node.addReference(new Reference(Identifiers.OpcUa_BinarySchema_ServerDiagnosticsSummaryDataType, Identifiers.HasComponent, Identifiers.OpcUa_BinarySchema.expanded(), false)); StringBuilder sb = new StringBuilder(); sb.append("<String xmlns=\"http://opcfoundation.org/UA/2008/02/Types.xsd\">ServerDiagnosticsSummaryDataType</String>"); String xml = sb.toString(); OpcUaXmlStreamDecoder decoder = new OpcUaXmlStreamDecoder(context.getServer().getSerializationContext()).setInput(new StringReader(xml)); Object o = decoder.readVariantValue(); DataValue value = new DataValue(new Variant(o)); node.setValue(value); this.nodeManager.addNode(node); } p