Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
First draft for DataTypeDefinition-based dynamic datatypes and codecs
- Loading branch information
1 parent
9525f0c
commit 35231e9
Showing
14 changed files
with
1,279 additions
and
184 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
127 changes: 127 additions & 0 deletions
127
...in/java/org/eclipse/milo/examples/client/UnifiedAutomationReadCustomDataTypeExample2.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,127 @@ | ||
| /* | ||
| * Copyright (c) 2022 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.examples.client; | ||
|
|
||
| import java.util.Random; | ||
| import java.util.UUID; | ||
| import java.util.concurrent.CompletableFuture; | ||
|
|
||
| import org.eclipse.milo.opcua.sdk.client.DataTypeTreeSessionInitializer; | ||
| import org.eclipse.milo.opcua.sdk.client.OpcUaClient; | ||
| import org.eclipse.milo.opcua.sdk.core.types.DynamicEnum; | ||
| import org.eclipse.milo.opcua.sdk.core.types.DynamicStruct; | ||
| import org.eclipse.milo.opcua.stack.core.security.SecurityPolicy; | ||
| import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue; | ||
| import org.eclipse.milo.opcua.stack.core.types.builtin.ExtensionObject; | ||
| import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId; | ||
| import org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode; | ||
| import org.eclipse.milo.opcua.stack.core.types.builtin.Variant; | ||
| import org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| /** | ||
| * An example that shows reading the value of a node whose DataType is a custom structure type. | ||
| * <p> | ||
| * Requires the Unified Automation CPP Demo server be running and the endpoint URL be pointing to it. | ||
| */ | ||
| public class UnifiedAutomationReadCustomDataTypeExample2 implements ClientExample { | ||
|
|
||
| public static void main(String[] args) throws Exception { | ||
| UnifiedAutomationReadCustomDataTypeExample2 example = | ||
| new UnifiedAutomationReadCustomDataTypeExample2(); | ||
|
|
||
| new ClientExampleRunner(example, false).run(); | ||
| } | ||
|
|
||
| private final Logger logger = LoggerFactory.getLogger(getClass()); | ||
|
|
||
| @Override | ||
| public void run(OpcUaClient client, CompletableFuture<OpcUaClient> future) throws Exception { | ||
| // DataTypeTree reads DataTypeDefinition attributes while traversing the type hierarchy | ||
| // and, by default, registers codecs with the client's dynamic DataTypeManager. | ||
| client.addSessionInitializer(new DataTypeTreeSessionInitializer()); | ||
|
|
||
| client.connect().get(); | ||
|
|
||
| readWriteReadPerson(client); | ||
| readWriteReadWorkOrder(client); | ||
|
|
||
| future.complete(client); | ||
| } | ||
|
|
||
| private void readWriteReadPerson(OpcUaClient client) throws Exception { | ||
| NodeId nodeId = NodeId.parse("ns=2;s=Person1"); | ||
|
|
||
| DynamicStruct value = readValue(client, nodeId); | ||
| logger.info("Person1: {}", value); | ||
|
|
||
| Random r = new Random(); | ||
| DynamicEnum gender = (DynamicEnum) value.getMembers().get("Gender"); | ||
| value.getMembers().put("Name", "Fat Boy" + r.nextInt(100)); | ||
| value.getMembers().put("Gender", new DynamicEnum(gender.getDataType(), r.nextInt(2))); | ||
|
|
||
| StatusCode status = writeValue(client, nodeId, value); | ||
| System.out.println("write status: " + status); | ||
|
|
||
| value = readValue(client, nodeId); | ||
| logger.info("Person1': {}", value); | ||
| } | ||
|
|
||
| private void readWriteReadWorkOrder(OpcUaClient client) throws Exception { | ||
| NodeId nodeId = NodeId.parse("ns=2;s=Demo.Static.Scalar.WorkOrder"); | ||
|
|
||
| DynamicStruct value = readValue(client, nodeId); | ||
| logger.info("WorkOrder: {}", value); | ||
|
|
||
| value.getMembers().put("ID", UUID.randomUUID()); | ||
|
|
||
| StatusCode status = writeValue(client, nodeId, value); | ||
| System.out.println("write status: " + status); | ||
|
|
||
| value = readValue(client, nodeId); | ||
| logger.info("WorkOrder': {}", value); | ||
| } | ||
|
|
||
| private static DynamicStruct readValue(OpcUaClient client, NodeId nodeId) throws Exception { | ||
| DataValue dataValue = client.readValue( | ||
| 0.0, | ||
| TimestampsToReturn.Neither, | ||
| nodeId | ||
| ).get(); | ||
|
|
||
| ExtensionObject xo = (ExtensionObject) dataValue.getValue().getValue(); | ||
|
|
||
| return (DynamicStruct) xo.decode(client.getDynamicSerializationContext()); | ||
| } | ||
|
|
||
| private static StatusCode writeValue(OpcUaClient client, NodeId nodeId, DynamicStruct value) throws Exception { | ||
| ExtensionObject xo = ExtensionObject.encodeDefaultBinary( | ||
| client.getDynamicSerializationContext(), | ||
| value, | ||
| value.getDataType().getBinaryEncodingId() | ||
| ); | ||
|
|
||
| return client.writeValue(nodeId, DataValue.valueOnly(new Variant(xo))).get(); | ||
| } | ||
|
|
||
| @Override | ||
| public String getEndpointUrl() { | ||
| // Change this if UaCPPServer is running somewhere other than localhost. | ||
| return "opc.tcp://localhost:48010"; | ||
| } | ||
|
|
||
| @Override | ||
| public SecurityPolicy getSecurityPolicy() { | ||
| return SecurityPolicy.None; | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.