摘要：本文深入探讨了 OPC UA 协议，详细介绍了其实现原理、优势特点，并给出了底层代码示例，同时通过实战应用展示了其在实际场景中的运用。首先阐述了 OPC UA 协议在工业自动化、物联网等领域的重要性，接着剖析其原理和特点，随后提供了从客户端到服务器的代码实现，最后通过一个完整的实战项目展示了如何将 OPC UA 协议应用到实际系统中。希望能为相关开发者和研究人员提供全面的参考。

文章目录

在这里插入图片描述

【万物互联：通讯协议应用指南】OPC UA 协议在工业自动化及物联网等领域的应用

关键词

OPC UA 协议；实现原理；优势特点；底层代码；实战应用

一、引言

在工业自动化和物联网快速发展的今天，设备之间的互联互通变得至关重要。不同厂商的设备和系统往往采用不同的通信协议，这给数据的集成和共享带来了巨大挑战。OPC UA（Open Platform Communications Unified Architecture）协议作为一种开放、统一的通信标准，应运而生并得到了广泛应用。它为不同设备和系统之间的数据交换提供了一种可靠、安全、高效的解决方案，有助于实现工业 4.0 和物联网的愿景。

二、OPC UA 协议概述

2.1 发展历程

OPC（Open Platform Communications）最初是为了解决工业自动化领域中不同厂商设备之间的通信问题而提出的。早期的 OPC 基于 COM/DCOM 技术，虽然在一定程度上实现了设备之间的互操作性，但存在一些局限性，如平台依赖性强、安全性差等。为了克服这些问题，OPC 基金会推出了 OPC UA 协议。OPC UA 采用了面向服务的架构，独立于特定的操作系统和编程语言，具有更好的跨平台性和安全性。

2.2 应用领域

OPC UA 协议广泛应用于工业自动化、能源管理、交通运输、医疗设备等领域。在工业自动化中，它可以实现 PLC、传感器、机器人等设备之间的数据通信和协同工作；在能源管理中，可用于电网监测、分布式能源系统的控制等；在交通运输领域，能实现车辆与基础设施之间的信息交互。

三、OPC UA 协议实现原理

3.1 分层架构

OPC UA 协议采用了分层架构，主要包括以下几层：

  • 应用层：定义了客户端和服务器之间的交互方式，包括服务调用、数据订阅等。
  • 会话层：负责建立、维护和终止客户端与服务器之间的会话。
  • 安全层：提供数据加密、身份验证和访问控制等安全功能，确保通信的安全性。
  • 传输层：负责数据的传输，支持多种传输协议，如 TCP、HTTP 等。

3.2 信息模型

OPC UA 协议使用信息模型来描述设备和系统的信息。信息模型由对象、变量、方法和引用组成。对象是信息模型的基本单元，代表现实世界中的实体；变量用于存储对象的属性值；方法用于执行对象的操作；引用用于建立对象之间的关系。

3.3 服务集

OPC UA 协议定义了一系列服务，包括浏览服务、读取服务、写入服务、订阅服务等。客户端通过调用这些服务来与服务器进行交互。例如，客户端可以使用读取服务来获取服务器上的变量值，使用订阅服务来实时接收变量值的变化。

四、OPC UA 协议优势特点

4.1 跨平台性

OPC UA 协议独立于特定的操作系统和编程语言，支持在多种平台上运行，如 Windows、Linux、Mac OS 等。这使得不同平台上的设备和系统可以方便地进行通信和集成。

4.2 安全性

OPC UA 协议提供了强大的安全功能，包括数据加密、身份验证和访问控制等。它采用了多种加密算法，如 AES、RSA 等，确保数据在传输和存储过程中的安全性。同时，通过身份验证和访问控制机制，可以限制只有授权的用户和设备才能访问敏感数据。

4.3 扩展性

OPC UA 协议的信息模型具有良好的扩展性，可以根据实际需求自定义对象、变量和方法。这使得它可以适应不同行业和应用场景的需求。

4.4 可靠性

OPC UA 协议采用了可靠的传输协议和错误处理机制，确保数据的可靠传输。在网络不稳定的情况下，它可以自动进行重传和恢复，保证通信的连续性。

五、OPC UA 底层代码实现

5.1 环境准备

在开始编写 OPC UA 代码之前，需要准备好开发环境。可以选择使用开源的 OPC UA 库，如 open62541。以下是在 Ubuntu 系统上安装 open62541 的步骤：

# 克隆 open62541 仓库
git clone https://github.com/open62541/open62541.git
cd open62541
# 创建构建目录
mkdir build
cd build
# 配置和编译
cmake -DUA_BUILD_EXAMPLES=ON ..
make
# 安装
sudo make install

5.2 服务器端代码实现

以下是一个简单的 OPC UA 服务器端代码示例：

#include <open62541/server.h>
#include <open62541/server_config_default.h>
#include <signal.h>

static volatile UA_Boolean running = true;
static void stopHandler(int sign) {
    UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_SERVER, "received ctrl-c");
    running = false;
}

int main(void) {
    signal(SIGINT, stopHandler);
    signal(SIGTERM, stopHandler);

    UA_Server *server = UA_Server_new();
    UA_ServerConfig_setDefault(UA_Server_getConfig(server));

    // 创建一个变量节点
    UA_VariableAttributes attr = UA_VariableAttributes_default;
    UA_Int32 myInteger = 42;
    UA_Variant_setScalar(&attr.value, &myInteger, &UA_TYPES[UA_TYPES_INT32]);
    attr.description = UA_LOCALIZEDTEXT("en-US", "A sample integer variable");
    attr.displayName = UA_LOCALIZEDTEXT("en-US", "MyInteger");
    attr.dataType = UA_TYPES[UA_TYPES_INT32].typeId;
    attr.accessLevel = UA_ACCESSLEVELMASK_READ | UA_ACCESSLEVELMASK_WRITE;

    UA_NodeId myIntegerNodeId = UA_NODEID_STRING(1, "the.answer");
    UA_QualifiedName myIntegerName = UA_QUALIFIEDNAME(1, "the answer");
    UA_NodeId parentNodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
    UA_NodeId parentReferenceNodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES);
    UA_Server_addVariableNode(server, myIntegerNodeId, parentNodeId,
                              parentReferenceNodeId, myIntegerName,
                              UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE),
                              attr, NULL, NULL);

    UA_StatusCode retval = UA_Server_run(server, &running);

    UA_Server_delete(server);
    return retval == UA_STATUSCODE_GOOD ? EXIT_SUCCESS : EXIT_FAILURE;
}

代码解释：

  • 引入必要的头文件，包括 open62541/server.h 和 open62541/server_config_default.h。
  • 定义一个信号处理函数 stopHandler，用于处理用户的中断信号（如 Ctrl+C）。
  • 创建一个 OPC UA 服务器实例，并设置默认配置。
  • 创建一个变量节点，设置其属性和初始值。
  • 将变量节点添加到服务器的信息模型中。
  • 启动服务器并运行，直到接收到中断信号。
  • 最后，删除服务器实例。

5.3 客户端代码实现

以下是一个简单的 OPC UA 客户端代码示例：

#include <open62541/client.h>
#include <open62541/client_config_default.h>
#include <open62541/client_highlevel.h>
#include <stdio.h>

int main(void) {
    UA_Client *client = UA_Client_new();
    UA_ClientConfig_setDefault(UA_Client_getConfig(client));

    UA_StatusCode retval = UA_Client_connect(client, "opc.tcp://localhost:4840");
    if(retval != UA_STATUSCODE_GOOD) {
        UA_Client_delete(client);
        printf("Connection failed: %s\n", UA_StatusCode_name(retval));
        return (int)retval;
    }

    // 读取变量值
    UA_Variant value; /* 用于存储读取的值 */
    UA_Variant_init(&value);
    retval = UA_Client_readValueAttribute(client, UA_NODEID_STRING(1, "the.answer"), &value);

    if(retval == UA_STATUSCODE_GOOD &&
       UA_Variant_hasScalarType(&value, &UA_TYPES[UA_TYPES_INT32])) {
        printf("the answer is: %i\n", *(UA_Int32*)value.data);
    }

    UA_Variant_clear(&value);
    UA_Client_disconnect(client);
    UA_Client_delete(client);
    return (int)retval;
}

代码解释：

  • 引入必要的头文件，包括 open62541/client.h 和 open62541/client_config_default.h。
  • 创建一个 OPC UA 客户端实例，并设置默认配置。
  • 连接到服务器。
  • 读取服务器上的变量值。
  • 输出读取到的变量值。
  • 断开与服务器的连接，并删除客户端实例。

六、OPC UA 实战应用

6.1 项目背景

假设我们有一个工业自动化系统，其中包含多个 PLC 和传感器。我们希望通过 OPC UA 协议实现这些设备之间的数据通信和监控。具体来说，我们要实现以下功能：

  • 从 PLC 读取传感器数据。
  • 将读取到的数据存储到数据库中。
  • 实时显示传感器数据。

6.2 系统架构设计

系统架构主要包括以下几个部分：

  • OPC UA 服务器：负责与 PLC 和传感器进行通信，采集数据并提供 OPC UA 服务。
  • OPC UA 客户端：从 OPC UA 服务器读取数据，并将数据存储到数据库中。
  • 数据库：用于存储传感器数据。
  • Web 服务器：提供 Web 界面，实时显示传感器数据。

6.3 代码实现

6.3.1 OPC UA 服务器代码（Python）
import opcua
from opcua import Server
import time

# 创建服务器实例
server = Server()
server.set_endpoint("opc.tcp://0.0.0.0:4840/freeopcua/server/")

# 创建命名空间
uri = "http://examples.freeopcua.github.io"
idx = server.register_namespace(uri)

# 创建对象节点
objects = server.get_objects_node()
myobj = objects.add_object(idx, "MyObject")

# 创建变量节点
myvar = myobj.add_variable(idx, "MyVariable", 0)
myvar.set_writable()    # 允许变量可写

# 启动服务器
server.start()

try:
    count = 0
    while True:
        time.sleep(1)
        count += 0.1
        myvar.set_value(count)
finally:
    # 停止服务器
    server.stop()
代码解释：
  • 引入 opcua 库。
  • 创建一个 OPC UA 服务器实例，并设置端点。
  • 注册命名空间和对象节点。
  • 创建一个变量节点，并设置为可写。
  • 启动服务器，并在循环中不断更新变量的值。
  • 最后，在程序结束时停止服务器。
6.3.2 OPC UA 客户端代码（Python）
import opcua
import sqlite3

# 连接到 OPC UA 服务器
client = opcua.Client("opc.tcp://localhost:4840/freeopcua/server/")
client.connect()

# 连接到数据库
conn = sqlite3.connect('sensor_data.db')
c = conn.cursor()

# 创建表（如果不存在）
c.execute('''CREATE TABLE IF NOT EXISTS sensor_data
             (timestamp REAL, value REAL)''')

try:
    # 获取变量节点
    root = client.get_root_node()
    myobj = root.get_child(["0:Objects", "2:MyObject"])
    myvar = myobj.get_child(["2:MyVariable"])

    while True:
        # 读取变量值
        value = myvar.get_value()
        timestamp = opcua.utils.now()

        # 插入数据到数据库
        c.execute("INSERT INTO sensor_data VALUES (?,?)", (timestamp.timestamp(), value))
        conn.commit()

        print(f"Timestamp: {timestamp}, Value: {value}")
finally:
    # 断开连接
    client.disconnect()
    conn.close()
代码解释：
  • 引入 opcua 和 sqlite3 库。
  • 连接到 OPC UA 服务器和 SQLite 数据库。
  • 创建一个表用于存储传感器数据。
  • 获取变量节点，并在循环中不断读取变量的值。
  • 将读取到的数据插入到数据库中。
  • 最后，断开与服务器的连接并关闭数据库连接。
6.3.3 Web 服务器代码（Python + Flask）
from flask import Flask, render_template
import sqlite3

app = Flask(__name__)

@app.route('/')
def index():
    # 连接到数据库
    conn = sqlite3.connect('sensor_data.db')
    c = conn.cursor()

    # 查询最新的 10 条数据
    c.execute("SELECT * FROM sensor_data ORDER BY timestamp DESC LIMIT 10")
    rows = c.fetchall()

    # 关闭数据库连接
    conn.close()

    return render_template('index.html', rows=rows)

if __name__ == '__main__':
    app.run(debug=True)
代码解释：
  • 引入 Flask 和 sqlite3 库。
  • 创建一个 Flask 应用实例。
  • 定义一个路由 /，用于显示最新的 10 条传感器数据。
  • 连接到数据库，查询最新的 10 条数据。
  • 关闭数据库连接，并将数据传递给 HTML 模板进行渲染。
  • 最后，启动 Flask 应用。
6.3.4 HTML 模板（index.html）
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Sensor Data</title>
</head>
<body>
    <h1>Sensor Data</h1>
    <table>
        <thead>
            <tr>
                <th>Timestamp</th>
                <th>Value</th>
            </tr>
        </thead>
        <tbody>
            {% for row in rows %}
            <tr>
                <td>{{ row[0] }}</td>
                <td>{{ row[1] }}</td>
            </tr>
            {% endfor %}
        </tbody>
    </table>
</body>
</html>
代码解释：
  • 定义一个 HTML 表格，用于显示传感器数据。
  • 使用 Flask 的模板引擎，循环遍历传递过来的数据，并将其显示在表格中。

6.4 部署和测试

  • 部署：将上述代码分别部署到相应的服务器上。确保 OPC UA 服务器、OPC UA 客户端和 Web 服务器都能正常运行。
  • 测试：启动 OPC UA 服务器，观察变量值是否正常更新。启动 OPC UA 客户端，检查数据是否正确存储到数据库中。最后，访问 Web 服务器的地址，查看是否能实时显示传感器数据。

七、OPC UA 协议的安全性考虑

7.1 身份验证

OPC UA 协议支持多种身份验证方式，如用户名/密码、证书等。在实际应用中，应根据安全需求选择合适的身份验证方式。例如，对于敏感数据的访问，建议使用证书进行身份验证，以确保用户和设备的身份真实可靠。

7.2 数据加密

OPC UA 协议使用加密算法对数据进行加密，确保数据在传输和存储过程中的安全性。常用的加密算法包括 AES、RSA 等。在配置 OPC UA 服务器和客户端时，应启用加密功能，并选择合适的加密算法和密钥长度。

7.3 访问控制

OPC UA 协议提供了访问控制机制，用于限制用户和设备对数据的访问权限。可以根据用户的角色和权限，设置不同的访问级别，如只读、读写等。在设计系统时，应合理规划访问控制策略，确保只有授权的用户和设备才能访问敏感数据。

八、OPC UA 协议的发展趋势

8.1 与物联网的融合

随着物联网的发展，OPC UA 协议将与物联网技术更加紧密地融合。它将为物联网设备之间的数据通信和互操作性提供更好的支持，促进物联网的广泛应用。

8.2 人工智能和大数据分析

OPC UA 协议采集到的数据可以为人工智能和大数据分析提供丰富的数据源。通过对这些数据的分析和挖掘，可以实现设备的预测性维护、生产过程的优化等功能。

8.3 跨行业应用

OPC UA 协议的开放性和跨平台性使其在不同行业的应用越来越广泛。未来，它将在更多的领域发挥重要作用，如智能建筑、交通运输、医疗保健等。

九、总结

本文详细介绍了 OPC UA 协议的实现原理、优势特点，并给出了底层代码示例和实战应用。OPC UA 协议作为一种开放、统一的通信标准，为不同设备和系统之间的数据交换提供了可靠的解决方案。通过实际项目的演示，展示了如何使用 OPC UA 协议实现数据的采集、存储和实时显示。同时，也讨论了 OPC UA 协议的安全性考虑和发展趋势。希望本文能为相关开发者和研究人员提供有价值的参考，推动 OPC UA 协议在更多领域的应用。

十、参考文献

[1] OPC Foundation. OPC UA Specification.
[2] open62541 Documentation.
[3] Python OPC UA Library Documentation.
[4] Flask Documentation.

十一、附录

11.1 常见问题解答

11.1.1 如何解决 OPC UA 服务器连接失败的问题？
  • 检查服务器的端点地址是否正确。
  • 确保服务器正在运行，并且监听的端口没有被占用。
  • 检查防火墙设置，确保允许 OPC UA 通信的端口通过。
11.1.2 如何提高 OPC UA 通信的性能？
  • 优化服务器和客户端的配置，如调整缓冲区大小、线程池大小等。
  • 减少不必要的数据订阅和传输，避免网络拥塞。
  • 使用高效的传输协议，如 TCP。
11.1.3 如何进行 OPC UA 协议的安全配置？
  • 启用身份验证功能，选择合适的身份验证方式，如用户名/密码、证书等。
  • 启用数据加密功能，选择合适的加密算法和密钥长度。
  • 配置访问控制策略，限制用户和设备的访问权限。

11.2 代码示例的编译和运行说明

11.2.1 C 语言代码
  • 编译：使用 gcc 编译器进行编译，例如：
gcc -o server server.c -lopen62541
gcc -o client client.c -lopen62541
  • 运行：先运行服务器，再运行客户端，例如：
./server
./client
11.2.2 Python 代码
  • 安装依赖库：使用 pip 安装所需的库，例如：
pip install opcua flask
  • 运行代码：分别运行 OPC UA 服务器、客户端和 Web 服务器的代码，例如：
python server.py
python client.py
python web_server.py

通过以上内容，读者可以全面了解 OPC UA 协议的相关知识，并掌握其实际应用的方法。在实际开发中，可以根据具体需求对代码进行修改和扩展，以满足不同的业务场景。

# 自动化 # 物联网 # struts
Logo
天工造物局

北京人形旗下天工造物具身智能开源社区，聚焦具身天工与慧思开物两大平台

更多推荐

deck.gl TripsLayer 出租车轨迹动画示例实战：从示例运行到着色器原理

TripsLayer 是 deck.gl 中用于渲染**随时间流动的轨迹动画**（如出租车行程、物流路径、迁徙路线）的核心图层。本文以仓库中的最小独立示例 [examples/website/trips](https://link.gitcode.com/i/1442af8f442f4cff39ff546e050fceb5) 为骨架，带你完成从安装依赖、启动应用、理解曼哈顿出租车数据格式，到深入

avatar 天工造物局

Foundry Anvil 中 eth_simulateV1 的 Blob 交易与 Blob Gas 字段规范化：原理、实现与测试验证

本篇技术指南以 [anvil-simulate-blob-transactions.md](https://link.gitcode.com/i/3d2ebe227262de169335eb290af80da8) 这条 changelog 条目为起点，深入剖析 Foundry Anvil 对 `eth_simulateV1` RPC 返回结果中 blob（EIP-4844）交易与 blob gas

avatar 天工造物局

LMCache CLI 实战：用 `lmcache kvcache clear` 管理运行中服务的 KV Cache 状态

本文是一份针对 LMCache 官方 CLI 命令 `lmcache kvcache` 的完整技术指南。该命令用于在**运行中的 LMCache 服务（MP HTTP server）**上管理 KV cache 状态，当前提供 `clear` 子命令，用于清空 L1（CPU 内存）层中缓存的全部 KV 数据。读完本文，你将掌握该命令的完整参数体系、退出码语义、终端/JSON/静默三种输出模式，并能

avatar 天工造物局