正文

Java轻松对接OPC，实现数据交互全攻略

/0 浏览量
0709

在工业自动化领域，OPC（OLE for Process Control）是一个非常重要的标准，它允许不同的控制系统和应用程序之间进行数据交换。Java作为一种跨平台、功能强大的编程语言，非常适合用于开发与OPC服务器交互的应用程序。本文将详细介绍如何使用Java轻松对接OPC，实现数据交互。

OPC简介

OPC是一种开放的标准，旨在实现不同厂商的自动化设备之间的数据交换。它定义了一套通信协议和接口，使得各种控制系统和应用程序可以无缝地交换数据。

Java与OPC

Java本身并不直接支持OPC协议，但我们可以通过以下几种方式实现Java与OPC的对接：

1. OPC Java API

OPC Java API是由OPC基金会提供的一个Java库，它提供了对OPC协议的支持。要使用OPC Java API，首先需要将其添加到项目的依赖中。

<!-- 在pom.xml中添加依赖 -->
<dependency>
    <groupId>com.opcua</groupId>
    <artifactId>opc-ua-java</artifactId>
    <version>1.0.0</version>
</dependency>

2. OPC UA

OPC UA是OPC协议的下一个版本，它提供了更高级的功能和安全性。Java社区也提供了一些OPC UA的Java库，如opc-ua-java。

实现数据读取

以下是一个简单的示例，演示如何使用Java读取OPC服务器上的数据。

import com.opcua.sdk.client.OpcUaClient;
import com.opcua.sdk.client.api.UaClient;
import com.opcua.sdk.client.api.nodes.UaNode;
import com.opcua.sdk.client.api.nodes.UaVariableNode;
import com.opcua.stack.core.AttributeId;
import com.opcua.stack.core.types.builtin.StatusCode;
import com.opcua.stack.core.types.builtin.StatusCode.StatusCodeResult;
import com.opcua.stack.core.types.builtin.StatusCode.StatusCodeResultBuilder;
import com.opcua.stack.core.types.builtin.StatusCodes;
import com.opcua.stack.core.types.builtin.Variant;
import com.opcua.stack.core.types.structured.ReadValueId;

import java.util.concurrent.CompletableFuture;

public class OpcUaClientExample {

    public static void main(String[] args) {
        String endpointUrl = "opc.tcp://localhost:4840";
        ReadValueId readValueId = new ReadValueId(null, "ns=2;s=Demo.Static.Scalar.Double", AttributeId.Value.getValue());

        try (OpcUaClient client = OpcUaClient.create()) {
            CompletableFuture<UaClient> connectFuture = client.connect(endpointUrl);
            UaClient connectedClient = connectFuture.get();

            CompletableFuture<StatusCodeResult<Variant>> readFuture = connectedClient.readValue(readValueId);
            StatusCodeResult<Variant> readResult = readFuture.get();

            if (readResult.getStatusCode().equals(StatusCodes.Good)) {
                System.out.println("Value: " + readResult.getValue().getValue());
            } else {
                System.out.println("Error reading value: " + readResult.getStatusCode());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

实现数据写入

以下是一个简单的示例，演示如何使用Java写入OPC服务器上的数据。

import com.opcua.sdk.client.OpcUaClient;
import com.opcua.sdk.client.api.UaClient;
import com.opcua.sdk.client.api.nodes.UaNode;
import com.opcua.sdk.client.api.nodes.UaVariableNode;
import com.opcua.stack.core.AttributeId;
import com.opcua.stack.core.types.builtin.StatusCode;
import com.opcua.stack.core.types.builtin.Variant;
import com.opcua.stack.core.types.structured.WriteValue;

import java.util.concurrent.CompletableFuture;

public class OpcUaClientExample {

    public static void main(String[] args) {
        String endpointUrl = "opc.tcp://localhost:4840";
        ReadValueId readValueId = new ReadValueId(null, "ns=2;s=Demo.Static.Scalar.Double", AttributeId.Value.getValue());
        WriteValue writeValue = new WriteValue(readValueId, new Variant(123.456));

        try (OpcUaClient client = OpcUaClient.create()) {
            CompletableFuture<UaClient> connectFuture = client.connect(endpointUrl);
            UaClient connectedClient = connectFuture.get();

            CompletableFuture<StatusCode> writeFuture = connectedClient.writeValue(writeValue);
            StatusCode writeResult = writeFuture.get();

            if (writeResult.equals(StatusCodes.Good)) {
                System.out.println("Value written successfully.");
            } else {
                System.out.println("Error writing value: " + writeResult);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

总结

使用Java对接OPC服务器实现数据交互是一个相对简单的过程。通过使用OPC Java API或OPC UA库，我们可以轻松地读取和写入OPC服务器上的数据。希望本文能帮助您更好地了解Java与OPC的对接过程。

-- 展开阅读全文 --