4. OPC UA 与工业通信：架构、模型与安全机制

OPC UA（OPC Unified Architecture，统一架构）是工业 4.0 时代最核心的通信标准，它解决了传统 OPC Classic（如 OPC DA、OPC HDA）对 Windows 平台和 DCOM 协议的强依赖问题。本章将深入剖析 OPC UA 的层次化架构、信息模型、客户端/服务器交互模式以及纵深安全机制，为后续的厂务数据采集实战打下坚实的理论基础。

4.1 OPC UA 架构分层与核心组件

OPC UA 采用面向服务的架构（SOA），将通信栈、信息模型与应用层解耦。其核心架构分为传输层、通信层、服务接口层和信息模型层。

4.2 数据模型与地址空间

OPC UA 的核心创新在于其面向对象的信息模型。地址空间（AddressSpace）是 OPC UA 服务器的“数据字典”，所有可访问的数据和结构都以节点（Node）的形式组织在地址空间中。

4.2.1 节点与引用

• 节点（Node）： 地址空间的基本单元。每个节点有唯一的 NodeId 和属性集合。
• 引用（Reference）： 节点之间的有向连接，用于构建层次结构（如对象包含变量）或非层次关系（如类型继承）。

4.2.2 核心节点类型

4.3 客户端/服务器模式

OPC UA 采用经典的 C/S 架构。服务器负责维护地址空间并提供数据；客户端负责发起连接、浏览节点、读写数据或订阅事件。

4.3.1 会话建立流程

1. 发现（Discovery）： 客户端通过 Discovery Endpoint 获取服务器支持的协议列表。
2. 创建安全通道（Secure Channel）： 基于 TLS 或 UA Binary 协议协商加密算法和密钥。
3. 创建会话（Session）： 客户端提供身份认证信息（如用户名/密码、证书），服务器验证后建立会话。
4. 数据交互： 客户端通过服务接口（Read/Write/Subscribe）与服务器交互。
5. 关闭会话： 客户端主动关闭或超时断开。

4.3.2 订阅机制

订阅（Subscription）是 OPC UA 实现高效数据采集的关键。客户端创建订阅后，服务器按设定的采样间隔（Sampling Interval）检测变量变化，并在发布间隔（Publishing Interval）内将变化的数据打包发送给客户端，极大减少了网络开销。

4.4 安全机制

OPC UA 将安全内建于协议栈，而非依赖外部网络环境。其安全模型涵盖三个核心层面：

4.4.1 安全策略（Security Policy）

OPC UA 定义了多种安全策略，用于协商加密算法和密钥长度。常见策略包括：

• None： 无加密，仅用于测试或隔离网络。
• Basic128Rsa15： 使用 128 位 AES 加密，RSA 密钥长度为 1024 位。
• Basic256： 使用 256 位 AES 加密，安全性更高。
• Aes128_Sha256_RsaOaep： 现代推荐策略，结合 AES-128 和 SHA-256 签名。

4.4.2 证书管理

OPC UA 使用证书进行双向认证。服务器和客户端各自持有证书，并在建立安全通道时交换。常见的证书管理流程包括：

1. 生成自签名证书或由企业 CA 签发证书。
2. 将服务器证书导入客户端的信任列表（Trust List）。
3. 将客户端证书导入服务器的信任列表。
4. 配置证书吊销列表（CRL）以管理过期或泄露的证书。

4.5 实战代码示例：使用 Python 连接 OPC UA 服务器

以下示例使用 opcua-asyncio 库（推荐用于异步编程）连接一个本地 OPC UA 服务器，并读取一个变量的值。

import asyncio
from opcua import Client, ua

async def read_opcua_variable():
    # 1. 创建客户端实例，指定服务器端点URL
    #    安全模式选择 SignAndEncrypt，策略 Basic256
    client = Client(
        url="opc.tcp://localhost:4840/freeopcua/server/",
        security_mode=ua.SecurityMode.SignAndEncrypt,
        security_policy=ua.SecurityPolicy.Basic256
    )

    # 2. 加载客户端证书（用于安全连接）
    client.load_client_certificate("client_cert.der")
    client.load_private_key("client_key.pem")

    try:
        # 3. 连接到服务器
        await client.connect()
        print("连接成功！")

        # 4. 获取根节点并浏览地址空间
        root = client.get_root_node()
        print(f"根节点: {root}")

        # 5. 读取指定变量（NodeId 为 "ns=2;i=1234"）
        var_node = client.get_node("ns=2;i=1234")
        data_value = await var_node.read_value()
        print(f"变量值: {data_value}")

        # 6. 创建订阅，每100ms采样一次
        subscription = await client.create_subscription(100, handler)
        handle = await subscription.subscribe_data_change(var_node)

        # 保持连接一段时间以接收数据
        await asyncio.sleep(10)

        # 7. 清理
        await subscription.delete()
        await client.disconnect()
        print("断开连接。")

    except Exception as e:
        print(f"发生错误: {e}")

# 定义数据变化回调处理器
class SubHandler:
    async def datachange_notification(self, node, val, data):
        print(f"数据变化: {node} -> {val}")

handler = SubHandler()

# 运行异步主函数
asyncio.run(read_opcua_variable())