快捷導(dǎo)航

Java 使用 OPC UA的步驟詳解

更新時(shí)間：2026年01月29日 10:19:12 作者：夜行容忍

使用Java與OPC UA (OPC Unified Architecture) 進(jìn)行通信,可以使用開源的Eclipse Milo庫,下面給大家介紹使用Eclipse Milo庫與OPC UA服務(wù)器進(jìn)行交互的步驟,感興趣的朋友跟隨小編一起看看吧

步驟一：引入Eclipse Milo庫

你需要在項(xiàng)目中引入Eclipse Milo庫?？梢允褂肕aven或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'

步驟二：創(chuàng)建并配置OPC UA客戶端

下面是一個(gè)簡單的示例代碼，展示如何創(chuàng)建并配置一個(gè)OPC UA客戶端，以及如何連接到OPC UA服務(wù)器。

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服務(wù)器地址
        // 找到服務(wù)器的端點(diǎn)
        EndpointDescription[] endpoints = OpcUaClient.getEndpoints(endpointUrl).get();
        // 選擇合適的端點(diǎn)
        EndpointDescription endpoint = EndpointUtil.select(endpoints, "None", "None").orElseThrow(() ->
                new Exception("沒有找到合適的端點(diǎn)"));
        // 創(chuàng)建客戶端
        OpcUaClient client = OpcUaClient.create(endpoint);
        // 連接到服務(wù)器
        CompletableFuture<Void> future = client.connect();
        future.whenComplete((result, ex) -> {
            if (ex != null) {
                ex.printStackTrace();
            } else {
                System.out.println("連接成功!");
                // 在此添加你的業(yè)務(wù)邏輯
            }
        });
        future.get(); // 等待連接完成
    }
}

步驟三：讀取和寫入變量

下面是如何讀取和寫入OPC UA服務(wù)器上的變量的示例。

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("值已寫入");
    }
}