Java 使用 OPC UA

使用Java与OPC UA (OPC Unified Architecture) 进行通信，可以使用开源的Eclipse Milo库。以下是一个简单的指南，帮助你开始使用Eclipse Milo库与OPC UA服务器进行交互。

步骤一：引入Eclipse Milo库

你需要在项目中引入Eclipse Milo库。可以使用Maven或Gradle来管理依赖。

Maven依赖:

<dependency>     <groupId>org.eclipse.milo</groupId>     <artifactId>sdk-client</artifactId>     <version>0.6.7</version> </dependency> 

Gradle依赖:

implementation 'org.eclipse.milo:sdk-client:0.6.7' 

步骤二：创建并配置OPC UA客户端

下面是一个简单的示例代码，展示如何创建并配置一个OPC UA客户端，以及如何连接到OPC UA服务器。

import org.eclipse.milo.opcua.sdk.client.OpcUaClient; import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.Unsigned; import org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription; import org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescriptionArray; import org.eclipse.milo.opcua.stack.core.util.EndpointUtil;  import java.util.concurrent.CompletableFuture;  public class OpcUaClientExample {     public static void main(String[] args) throws Exception {         String endpointUrl = "opc.tcp://localhost:4840";  // 替换为你的OPC UA服务器地址                  // 找到服务器的端点         EndpointDescription[] endpoints = OpcUaClient.getEndpoints(endpointUrl).get();          // 选择合适的端点         EndpointDescription endpoint = EndpointUtil.select(endpoints, "None", "None").orElseThrow(() ->                 new Exception("没有找到合适的端点"));          // 创建客户端         OpcUaClient client = OpcUaClient.create(endpoint);          // 连接到服务器         CompletableFuture<Void> future = client.connect();          future.whenComplete((result, ex) -> {             if (ex != null) {                 ex.printStackTrace();             } else {                 System.out.println("连接成功!");                 // 在此添加你的业务逻辑             }         });          future.get(); // 等待连接完成     } } 

步骤三：读取和写入变量

下面是如何读取和写入OPC UA服务器上的变量的示例。

import org.eclipse.milo.opcua.sdk.client.OpcUaClient; 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.Variant;  import java.util.concurrent.CompletableFuture;  public class ReadWriteExample {     public static void main(String[] args) throws Exception {         OpcUaClient client = OpcUaClient.create("opc.tcp://localhost:4840").get();         client.connect().get();          NodeId nodeId = new NodeId(2, "MyVariable");          // 读取变量值         CompletableFuture<DataValue> readFuture = client.readValue(0, null, nodeId);         DataValue value = readFuture.get();         System.out.println("读取到的值: " + value.getValue().getValue());          // 写入变量值         Variant variant = new Variant(42); // 替换为你要写入的值         DataValue newValue = new DataValue(variant);         CompletableFuture<Void> writeFuture = client.writeValue(nodeId, newValue);         writeFuture.get();         System.out.println("值已写入");     } } 

总结

使用Eclipse Milo库可以方便地与OPC UA服务器进行通信。通过上述步骤，你可以快速开始使用Java与OPC UA进行交互。可以根据需求扩展和定制客户端的功能，如订阅数据更改、浏览节点等。