1 简介

1.1 OPC UA 是什么

OPC UA（全称为 Open Platform Communications Unified Architecture）是一种用于工业和物联网（IoT）应用的开放通信协议和架构。它提供了一种统一的框架，用于在不同设备和系统之间实现数据传输、通信和集成。

OPC UA 的设计目标是建立一种通用的、独立于厂商和平台的通信标准，以实现互操作性和集成性。它提供了一套标准的服务和功能，使不同类型的设备和系统能够相互通信和交换数据，其特点包括：

特点	介绍
兼容性	OPC UA 不依赖于特定的硬件、操作系统或网络协议，可以在不同的平台上运行，并与其他通信标准集成
安全性	OPC UA 提供了强大的安全机制，包括身份验证、加密和访问控制，以确保数据和通信的机密性和完整性
可扩展	OPC UA 支持灵活的数据模型和信息建模，可以适应不同应用领域和需求的变化
信息建模	OPC UA 使用统一的信息模型，将数据和功能以标准化的方式表示和描述，使不同系统之间的数据交换更加简化和一致
可靠性	OPC UA 提供了可靠的通信机制，包括消息确认、重试和错误处理，以确保数据的可靠传输

1.2 open62541 库

open62541 [15] 是一个基于 C 语言的开源 OPC UA 框架，实现了 OPC UA 协议的核心功能和服务。它提供了一套完整的 OPC UA 通信协议栈，包括客户端和服务器端的实现，支持 OPC UA 的各种功能和服务，如数据访问、事件通知、历史数据、安全性等，RMVL 中的 OPC UA 模块提供了对 open62541 库的封装，使其更便于使用。

1.3 地址空间

在 OPC UA 中，所有的数据都被组织成一个地址空间，地址空间中的每一个元素都被称为一个节点。每个节点都有一个唯一的节点号，在 OPC UA 模块中表示为 rm::ua::NodeId 。

图 1-1 OPC UA 地址空间模型

对象类型节点 rm::ua::ObjectType

提供对象的定义，即对象的抽象，与类相当，且子类可以继承父类的特征，方便模型的扩充。该节点包括对象的各种数据类型，数据的语义，以及控制方式。OPC UA 命名空间 0 中规定了多个基础的对象类型节点。如使用最广的 BaseObjectType（在 RMVL 中表示为 rm::ua::nodeBaseObjectType），所有对象类型节点都需要继承该节点再进行扩充。在对具体设备建模的过程中，应该将设备组成的各部分分解为不同的对象分别建模，再用引用节点将各部分按照实际设备中的关系相关联，从而得到完整设备的对象类型节点。

对象节点 rm::ua::Object

将对象类型实例化即可得到对象节点，该节点是设备在数字空间的映射。所有对设备数据的访问都能在该模型中访问到对应的数据节点。所有对设备的控制都转换为方法节点的触发。设备产生的消息在节点对象中将触发对应的事件。

引用类型节点 rm::ua::ReferenceType

引用类型描述了引用的语义，而引用用于定义引用两端的节点之间的关系。最常用的引用类型如 Organizes（在 RMVL 中表示为 rm::ua::nodeOrganizes），表示节点之间的层级关系，如同文件夹与文件夹内的文件，数据层级复杂的设备，需要通过多种引用类型对设备信息节点之间的关系进行描述。

数据类型节点 rm::ua::DataType

数据类型节点描述了变量节点中变量的数据类型。在 OPC UA 信息模型在命名空间 0 中定义了多种内置的数据类型，包括整型、浮点型、字符串等多个类型，能对变量的数据进行准确的描述。也可以自定义数据类型，比如描述二维坐标的 2DPoint 等类型，获得更符合数据本身的描述。

注解: 注意：此类节点并不能提供具体的数据构成，只是提供了数据类型的一个描述，因此 RMVL 中的 OPC UA 模块仅提供内置数据类型。若计划提供数据的构成，比如包含的数据长度等信息，请使用变量类型节点 rm::ua::VariableType 。

变量类型节点 rm::ua::VariableType

该节点提供了对变量节点的定义，是设备中各种数据的抽象。常用引用中的 HasTypeDefinition 引用节点连接数据类型节点，对数据类型进行描述（在 RMVL 中表示为 rm::ua::nodeHasTypeDefinition）。用 HasProperty 引用节点对数据的语义进行描述（在 RMVL 中表示为 rm::ua::nodeHasProperty）。也可以使用自定义的数据类型节点对变量的数据进行描述，具有灵活性。

变量节点 rm::ua::Variable 及 rm::ua::DataSourceVariable

该节点是变量类型节点的实例，也是使用的最多的节点。客户端访问设备数据有以下 3 种方式。

访问方式	介绍	备注
直接读写	将设备多模态数据写入对应的变量节点，然后客户端读取对应节点内保存的数值	如果客户端要获取设备最新的值，需要一直手动去触发对设备数据源的读取请求
值回调	客户端发起 IO 请求后，服务器在读取前和写入后分别调用对应的回调函数	可以利用此功能在需要访问数据的时候才让服务器更新数据
数据源变量节点	客户端的读取请求直接重定向到设备的数据源中，即客户端直接从数据源获取数据，变量节点不存储数据	缩减了数据先写入变量节点再进行读取的过程，但多个客户端连接访问同一数据时会增大服务器与设备之间的传输负载

注解: 前两种访问方式在 OPC UA 模块中通过 rm::ua::Variable 实现，第三种数据源变量节点在 OPC UA 模块中通过 rm::ua::DataSourceVariable 实现。

方法节点 rm::ua::Method

方法节点是对设备控制方法在数字模型中的映射。方法节点可以通过服务器或客户端进行调用，然后将会对设备的控制器发送指令，使得设备执行对应的操作。常见的方法节点有：触发视觉采集、电机反转、设备初始化等。

视图节点 rm::ua::View

视图节点可将地址空间中感兴趣的节点提取出来，作为一个子集，视图节点作为该子集的入口，方便客户端浏览。

2 服务器/客户端

基于服务器/客户端的方式是 OPC UA 最基本的一种通信方式，上文的地址空间在服务器/客户端通信的过程中完全展现出来。下面列举一些 opcua 模块中常用的服务器与客户端通信的内容。

2.1 初始化

2.1.1 服务器

方案一

使用 spin 作为事件循环，并提供全局变量 p_server 用于在信号处理函数中关闭服务器。

// server.cpp
#include <csignal>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
ua::Server *p_server{nullptr};
 
void onStop(int) {
    if (p_server)
        p_server->shutdown();
}
 
int main() {
    // 注册信号处理函数
    signal(SIGINT, onStop);
 
    // 创建 OPC UA 服务器，端口为 4840
    ua::Server srv(4840);
    p_server = &srv;
    // 服务器运行
    srv.spin();
}

还可以使用形如

std::thread t(&ua::Server::spin, &srv);

的方式在单独的线程中运行 spin，此处不再赘述。

方案二

使用 spinOnce 执行单次事件循环，需要自定义主循环，在某个条件下退出循环，并关闭服务器（此时可不必显式调用 shutdown）

// server.cpp
#include <csignal>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
bool stop = false;
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    ua::Server srv(4840);
    while (!stop) {
        /* other code */
        srv.spinOnce();
    }
    srv.shutdown(); // 可省略，因为在 ua::Server::~Server 析构函数中将自动调用 shutdown
                    // 但是上文的方案一中需要手动将循环标志 _running 设置为 false，这一步是在 shutdown 中完成的，因此需要显式调用 shutdown
}

2.2.2 客户端

// client.cpp
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
int main() {
    // 创建 OPC UA 客户端，连接到 127.0.0.1:4840
    ua::Client cli("opc.tcp://127.0.0.1:4840");
 
    /* other code */
}

2.2 变量

在上文 1.3 地址空间中介绍了变量的 3 种访问方式，这里使用最简单的直接读写的方式。首先在服务器中添加变量节点，后文均采用 while + spinOnce 的方式处理异步事件。

// server.cpp
#include <csignal>
#include <thread>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) {
        stop = true;
    });
 
    ua::Server srv(4840);
 
    // 定义 double 型变量，如果要强制使用 3.14 定义 float 型变量，
    // 可以使用 ua::Variable num = float(3.14);
    ua::Variable num = 3.14;
    // 浏览名 BrowseName
    num.browse_name = "number";
    // 显示名 DisplayName
    num.display_name = "Number";
    // 描述
    num.description = "数字";
    // 添加到服务器的默认位置（默认被添加至 ObjectsFolder 下）
    srv.addVariableNode(num);
 
    while (!stop) {
        srv.spinOnce();
    }
    // srv.shutdown(); 可省略，后文不再赘述
}

然后在客户端中直接读取变量节点。

// client.cpp
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
int main() {
    ua::Client cli("opc.tcp://127.0.0.1:4840");
    // 使用管道运算符 "|" 进行路径搜索，寻找待读取的变量
    auto node = ua::nodeObjectsFolder | cli.node("number");
    // 或者可以直接使用 find 方法，寻找 ua::nodeObjectsFolder 下命名空间为 1 的节点（更推荐！）
    // auto node = cli.find("number");
    // 读取变量
    ua::Variable target = cli.read(node);
    // 判断是否为空
    if (target.empty()) {
        ERROR_("Failed to read the variable.");
        return 0;
    }
    // 使用成员函数将 target 转化为目标格式，并打印
    printf("%f\n", target.cast<double>());
}

2.3 方法

在服务器中添加两数之和的方法节点，供客户端调用。

// server.cpp
#include <csignal>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    ua::Server srv(4840);
 
    // 定义方法，初始化或设置 ua::Method::func 成员必须使用以下兼容形式的可调用对象
    // std::function<pair<bool, ua::Variables>(const ua::NodeId &, const ua::Variables &)>
    // 其中 ua::Variables 是 std::vector<ua::Variable> 的别名
    ua::Method method = [](const ua::NodeId &, const ua::Variables &iargs) {
        int num1 = iargs[0], num2 = iargs[1];
        ua::Variables oargs = {num1 + num2};
        return std::make_pair(true, oargs);
    };
    method.browse_name = "add";
    method.display_name = "Add";
    method.description = "两数之和";
    // 定义函数传入参数 iargs 的类型说明
    method.iargs = {{"Number 1", ua::tpInt32},
                    {"Number 2", ua::tpInt32}};
    // 也可以使用 create 工厂函数创建参数，后文不再赘述
    // method.iargs = {ua::Argument::create("Number 1", ua::tpInt32),
    //                 ua::Argument::create("Number 2", ua::tpInt32)};
 
    // 定义函数返回值 oargs 的类型说明
    method.oargs = {{"Sum", ua::tpInt32}};
 
    /*
        1. 数据类型也可使用在 open62541 中定义的 UA_TYPES_ 作为前缀的宏，如 ua::tpInt32 可使用 UA_TYPES_INT32 宏
        2. {"Number 1", ua::tpInt32} 的部分是 ua::Argument 的聚合类，表示方法的参数
        3. 允许有多个返回值，即 oargs 的长度允许 > 1
    */
 
    // 方法节点添加至服务器
    srv.addMethodNode(method);
 
    while (!stop) {
        srv.spinOnce();
    }
}

在客户端调用指定方法。

// client.cpp
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
int main() {
    ua::Client cli("opc.tcp://127.0.0.1:4840");
 
    // 设置输入参数，1 和 2 是 Int32 类型的，因此可以直接隐式构造
    ua::Variables iargs = {1, 2};
    // 调用方法，判断调用是否成功，并存储结果
    auto [res, oargs] = cli.call("add", iargs);
    if (!res)
        ERROR_("Failed to call the method");
    else
        printf("retval = %d\n", oargs.front().cast<int>());
}

此外，还可以使用 Client::callx 方法的变参模板直接从底层数据进行调用，例如

// client.cpp
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
int main() {
    ua::Client cli("opc.tcp://127.0.0.1:4840");
 
    auto [res, oargs] = cli.callx("add", 1, 2);
    if (!res)
        ERROR_("Failed to call the method");
    else
        printf("retval = %d\n", oargs.front().cast<int>());
}

2.4 对象

在服务器中添加对象节点：

A
├── B1
│   ├── C1: 3.14
│   └── C2: 666
└── B2
    └── C3: "xyz"

// server.cpp
#include <csignal>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    ua::Server srv(4840);
    // 准备对象节点数据 A
    ua::Object a;
    a.browse_name = a.description = a.display_name = "A";
    // 添加对象节点 A 至服务器
    auto node_a = srv.addObjectNode(a);
    // 准备对象节点数据 B1
    ua::Object b1;
    b1.browse_name = b1.description = b1.display_name = "B1";
    // 准备 B1 的变量节点 C1
    ua::Variable c1 = 3.14;
    c1.browse_name = c1.description = c1.display_name = "C1";
    b1.add(c1);
    // 准备 B1 的变量节点 C2
    ua::Variable c2 = 666;
    c2.browse_name = c2.description = c2.display_name = "C2";
    b1.add(c2);
    // 添加对象节点 B1 至服务器
    srv.addObjectNode(b1, node_a);
    // 准备对象节点数据 B2
    ua::Object b2;
    b2.browse_name = b2.description = b2.display_name = "B2";
    // 准备 B2 的变量节点 C3
    ua::Variable c3 = "xyz";
    c3.browse_name = c3.description = c3.display_name = "C3";
    b2.add(c3);
    // 添加对象节点 B2 至服务器
    srv.addObjectNode(b2, node_a);
 
    while (!stop)
        srv.spinOnce();
}

在客户端寻找 C2 和 C3 并打印。

// client.cpp
#include <iostream>
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
int main() {
    ua::Client cli("opc.tcp://127.0.0.1:4840");
 
    // 路径搜索寻找 C2
    auto node_c2 = ua::nodeObjectsFolder | cli.node("A") | cli.node("B1") | cli.node("C2");
    // 也可以直接使用 find 方法，寻找 ua::nodeObjectsFolder 下的节点（更推荐！）
    // auto node_c2 = cli.find("A/B1/C2");
    ua::Variable c2 = cli.read(node_c2);
    std::cout << c2.cast<int>() << std::endl;
    // 路径搜索寻找 C3
    auto node_c3 = cli.find("A/B2/C3");
    ua::Variable c3 = cli.read(node_c3);
    std::cout << c3.cast<std::string>() << std::endl;
}

2.5 视图

在 nodeObjectsFolder 中先添加 A/num1、num2 2 个变量节点，并将 num1 和 num2 加入视图，下面的示例演示在 服务器 中创建并添加视图节点。若要在客户端中进行此操作，创建并添加视图节点的步骤基本一致，这里不做展示。需要注意的是，在客户端中创建并添加视图节点，需要提前在服务器中加入对应的（变量、方法、对象……）节点

// server.cpp
#include <csignal>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    ua::Server srv(4840);
    // 准备对象节点数据 A
    ua::Object a;
    a.browse_name = a.description = a.display_name = "A";
    // 创建 num1 变量节点
    ua::Variable num1 = 1;
    num1.browse_name = "num1";
    num1.display_name = "num1";
    num1.description = "num1";
    a.add(num1);
    auto node_a = srv.addObjectNode(a);
    auto node_num1 = srv.find("A/num1");
    // 这里稍微展示一下，使用宏来创建 num2，这里也可以使用上文的方式创建 :)
    uaCreateVariable(num2, 2);
    auto node_num2 = srv.addVariableNode(num2);
 
    // 创建视图
    ua::View num_view;
    // 添加节点至视图（这里使用的是变量节点的 NodeId，实际上其他节点也是允许的）
    num_view.add(node_num1, node_num2);
    // 添加至服务器
    srv.addViewNode(num_view);
 
    while (!stop)
        srv.spinOnce();
}

2.6 监视

OPC UA 支持变量节点和事件的监视，下面分别以变量节点和事件的监视为例。

2.6.1 变量监视

首先在服务器中添加待监视的变量节点

// server.cpp
#include <csignal>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    ua::Server srv(4840);
 
    // 定义 int 型变量
    ua::Variable num = 100;
    num.browse_name = "number";
    num.display_name = "Number";
    num.description = "数字";
    // 添加到服务器的默认位置
    srv.addVariableNode(num);
 
    while (!stop)
        srv.spinOnce();
}

在客户端 1 中修改变量节点的数据

// client_1.cpp
#include <thread>
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
using namespace std::chrono_literals;
 
int main() {
    ua::Client cli("opc.tcp://127.0.0.1:4840");
    auto node = cli.find("number");
    for (int i = 0; i < 100; ++i) {
        std::this_thread::sleep_for(1s);
        // 写入数据，i + 200 隐式构造成了 ua::Variable
        bool success = cli.write(node, i + 200);
        if (!success)
            ERROR_("Failed to write data to the variable.");
    }
}

然后，在客户端 2 中监视变量节点

// client_2.cpp
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
int main() {
    ua::Client cli("opc.tcp://127.0.0.1:4840");
    auto node = cli.find("number");
 
    // 监视变量
    auto on_change = [](ua::ClientView, const ua::Variable &value) {
        int receive_data = value;
        printf("Data (n=number) was changed to: %d\n", receive_data);
    };
    cli.monitor(node, on_change, 5);
 
    // 线程阻塞
    cli.spin();
}

2.6.2 事件监视

事件需要服务器自主触发，在实际应用中，事件的触发可以是设备状态的变化、设备的报警等，例如客户端通过调用方法节点，服务端修改自身状态机状态，任务执行完毕，状态再次发生改变后将触发事件，可以实现同步非阻塞向同步阻塞的转换。例如服务器用于 异步的控制设备启动、关闭 ，客户端通过调用方法节点控制设备启动。

首先在服务器中添加

对应的方法节点用于发出启动、关闭指令；
实际发出启动、关闭指令的伪代码。

如下所示。

// server.cpp
#include <csignal>
#include <thread>
 
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
using namespace std::chrono_literals;
 
static bool stop = false;
 
// OPC UA 状态
enum class OPCUAState {
    NONE,  // 无状态
    START, // 设备启动中...
    STOP,  // 设备关闭中...
};
 
int main() {
    // OPC UA 状态
    OPCUAState mode{};
 
    // 完成事件类型
    ua::EventType finish_type_info;
    finish_type_info.browse_name = "finish_type";
    finish_type_info.display_name = "FinishType";
    finish_type_info.description = "任务执行完成时触发的事件";
    finish_type_info.add("Result", 0);
    auto finish_info = ua::Event::makeFrom(finish_type_info);
 
    // 启动设备
    ua::Method start_info = [&](const ua::NodeId &, const ua::Variables &) -> std::pair<bool, ua::Variables> {
        if (mode != OPCUAState::NONE)
            return {false, {}};
        mode = OPCUAState::START;
        return {true, {}};
    };
    start_info.browse_name = "start";
    start_info.display_name = "Start";
    start_info.description = "启动设备";
 
    // 关闭设备
    ua::Method stop_info = [&](const ua::NodeId &, const ua::Variables &) -> std::pair<bool, ua::Variables> {
        if (mode != OPCUAState::NONE)
            return {false, {}};
        mode = OPCUAState::STOP;
        return {true, {}};
    };
    stop_info.browse_name = "stop";
    stop_info.display_name = "Stop";
    stop_info.description = "关闭设备";
 
    // 服务器
    signal(SIGINT, [](int) { stop = true; });
    ua::Server srv(4840);
    srv.addEventTypeNode(msg_type_info);
    srv.addMethodNode(start_info);
 
    while (!stop) {
        srv.spinOnce();
        if (mode == OPCUAState::START) {
            // 实际发出 Start 指令
 
            /* code */
 
            // 'true' 应改为状态确定发生变更的判断条件
            if (true) {
                finish_info.message = "Start";
                finish_info["Result"] = 0;
                srv.triggerEvent(finish_info);
                mode = OPCUAState::NONE; // 恢复 OPC UA 状态
            }
        } else if (mode == OPCUAState::STOP) {
            // 实际发出 Stop 指令
 
            /* code */
 
            // 'true' 应改为状态确定发生变更的判断条件
            if (true) {
                finish_info.message = "Stop";
                finish_info["Result"] = 0;
                srv.triggerEvent(finish_info);
                mode = OPCUAState::NONE; // 恢复 OPC UA 状态
            }
        }
    }
}

正常情况下，客户端调用方法节点会立刻返回，如以下代码

// client_old.cpp
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
int main() {
    ua::Client cli("opc.tcp://127.0.0.1:4840");
    auto node = cli.find("start");
    auto [res, oargs] = cli.callx(node);
    if (!res) // res 只表示方法节点是否调用成功，而非任务执行结果
        ERROR_("Failed to call the method");
}

此时返回的结果表示该方法节点是否调用成功，并非任务执行结果，而真实的执行结果在多个事件循环后才能得到。不过服务器在任务执行完成后会触发事件，客户端可以通过监视事件来获取任务执行结果，如以下代码。

// client_new.cpp
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
class OpcUaController {
public:
    OpcUaController(std::string_view addr) : _cli(addr) {
        // 监视事件
        _cli.monitor({"Message", "Result"}, [this](ua::ClientView, const ua::Variables &vals) {
            if (vals[0] == "Start")
                _start_res = (vals[1] == 0);
            else if (vals[0] == "Stop")
                _stop_res = (vals[1] == 0);
        });
    }
 
    // 同步阻塞的 start 函数
    bool start() {
        _start_res.reset();
        auto [res, oargs] = _cli.callx("start");
        if (!res) {
            printf("Failed to call start\n");
            return false;
        }
        while (!_start_res.has_value())
            _cli.spinOnce();
        return _start_res.value();
    }
 
    // 同步阻塞的 stop 函数
    bool stop() {
        _stop_res.reset();
        auto [res, oargs] = _cli.callx("stop");
        if (!res) {
            printf("Failed to call stop\n");
            return false;
        }
        while (!_stop_res.has_value())
            _cli.spinOnce();
        return _stop_res.value();
    }
 
private:
    ua::Client _cli;
 
    std::optional<bool> _start_res{};
    std::optional<bool> _stop_res{};
};
 
int main() {
    OpcUaController uactl("opc.tcp://127.0.0.1:4840");
    // 启动设备
    bool val = uactl.start();
    printf("Start result: %d\n", val);
 
    /* code */
 
    // 关闭设备
    val = uactl.stop();
    printf("Stop result: %d\n", val);
}

2.7 定时

OPC UA 模块为服务器和客户端均提供了循环定时器，用于周期性执行任务。

2.7.1 服务器定时

下面的示例在服务器中添加了一个数据源变量节点 num，并且创建了一个每 1s 执行一次的定时任务，每次执行时将 num 的值加 1。

// server.cpp
#include <csignal>
 
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
bool stop = false;
 
int main() {
    signal(SIGINT, [](int) {
        stop = true;
    });
 
    ua::Server srv(4840);
 
    int num{};
    ua::DataSourceVariable num_info;
    num_info.browse_name = "num";
    num_info.display_name = "Num";
    num_info.description = "数字";
    num_info.access_level = ua::VARIABLE_READ | ua::VARIABLE_WRITE;
    num_info.on_read = [&](const ua::NodeId &) -> ua::Variable {
        return num;
    };
    num_info.on_write = [&](const ua::NodeId &, const ua::Variable &val) {
        num = val;
    };
 
    auto num_nd = srv.addDataSourceVariableNode(num_info);
 
    // 创建定时器，每 1s 执行一次
    ua::ServerTimer timer(srv, 1000, [&](ua::ServerView sv) {
        sv.write(num_nd, ++num);
    });
 
    while (!stop) {
        srv.spinOnce();
    }
}

2.7.2 客户端定时

客户端定时器的使用方式与服务器定时器类似，但定时器的回调函数无传入参数，因为回调函数的触发是通过运行 ua::Client::spinOnce() 来实现的，在回调函数中对客户端进行路径搜索、变量读写、方法调用等操作会造成嵌套处理异步事件的错误，例如出现以下提示

error/eventloop Cannot run EventLoop from the run method itself

因此，RMVL 的客户端定时器的回调函数不接受参数，从一定程度上避免了这种错误。

下面提供了一个客户端定时器的示例，首先提供了一个 OPC UA 服务器，端口为 4840，在其中添加了一个变量节点 num，此时客户端定时器每 1s 读取一次 num 的值，并打印。

// client.cpp
#include <csignal>
 
#include <rmvl/opcua/client.hpp>
 
using namespace rm;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) {
        stop = true;
    });
 
    ua::Client cli("opc.tcp://127.0.0.1:4840");
    auto num_nd = cli.find("num");
 
    // 创建定时器，每 1s 执行一次
    bool can_read{};
    ua::ClientTimer timer(cli, 1000, [&] { can_read = true; });
    auto real_on_timer = [&] {
        auto num = cli.read(num_nd);
        printf("num = %d\n", num.cast<int>());
        can_read = false;
    };
 
    while (!stop) {
        cli.spinOnce();
        // 保证在 spinOnce() 之后再读取 num 的值
        if (can_read)
            real_on_timer();
    }
}

可以根据自己的需求对服务器的 num 变量节点进行其余操作，例如可以同时运行带有定时器的服务器和客户端，服务器每 1s 将 num 的值加 1，客户端每 1s 读取 num 的值并打印，有兴趣的读者可以自行尝试。

3 发布/订阅

这是一段来自 open62541 手册中有关 PubSub 的介绍。

在 PubSub 中，参与的 OPC UA 应用程序扮演发布者和订阅者的角色。发布者是数据的来源，而订阅者则使用该数据。PubSub 中的通信是基于消息的。发布者将消息发送到面向消息的中间件，而不知道可能有哪些订阅者（如果有）。同样，订阅者表达对特定类型数据的兴趣，并处理包含此数据的消息，而不知道有哪些发布者。

面向消息的中间件是支持在分布式系统之间发送和接收消息的软件或硬件基础设施。OPC UA PubSub 支持两种不同的面向消息的中间件变体，即 无代理形式 和 基于代理的形式 。在无代理形式中，面向消息的中间件是能够路由基于数据报的消息的网络基础设施。订阅者和发布者使用 UDP 等数据报协议。在基于代理的形式中，消息中间件的核心组件是消息代理。订阅者和发布者使用 AMQP 或 MQTT 等标准消息传递协议与代理进行通信。

这使得 PubSub 适合需要位置独立性和（或）可扩展性的应用程序。

OPC UA 的发布/订阅（PubSub）扩展可实现快速高效的通信。PubSub 扩展与协议无关，可与基于代理的协议（如 MQTT 和 AMQP）或无代理实现（如 UDP 多播）一起使用。

PubSub 的配置模型使用以下组件
typedef enum {

UA_PUBSUB_COMPONENT_CONNECTION,

UA_PUBSUB_COMPONENT_WRITERGROUP,

UA_PUBSUB_COMPONENT_DATASETWRITER,

UA_PUBSUB_COMPONENT_READERGROUP,

UA_PUBSUB_COMPONENT_DATASETREADER

} UA_PubSubComponentEnumType;

open62541 PubSub API 使用以下方案

为所需的 PubSub 元素创建配置

调用 add[element] 函数并传入配置

add[element] 函数返回内部创建的元素的唯一 UA_NodeId

有关 API 使用的更多详细信息，请查看 PubSub 教程。

3.1 无代理 Pub/Sub

RMVL 提供了基于 UDP 传输协议的 Broker-less 即无代理的发布订阅机制，目前支持 UADP 的消息映射方式。

需要留意的是，OPC UA 的发布订阅模型仍然是建立在 2 服务器/客户端模型之上的，此外 OPC UA 模块的 PubSub 在实现上是继承于 rm::ua::Server 的，因此，RMVL 的发布订阅模型在使用时具备服务器的所有功能，初始化、释放资源等操作与服务器完全一致。

创建发布者

// publisher.cpp
#include <csignal>
#include <rmvl/opcua/publisher.hpp>
 
using namespace rm;
using namespace std::chrono_literals;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    // 创建 OPC UA 发布者，端口为 4840
    ua::Publisher pub("DemoNumberPub", "opc.udp://224.0.0.22:4840");
 
    // 添加变量节点至发布者自身的服务器中
    ua::Variable num = 3.14;
    num.browse_name = "number";
    num.display_name = "Number";
    num.description = "数字";
    auto num_node = pub.addVariableNode(num);
    // 准备待发布的数据
    std::vector<ua::PublishedDataSet> pds_list;
    pds_list.emplace_back("Number 1", num_node);
 
    // 发布数据
    pub.publish(pds_list, 50);
 
    while (!stop) {
        /* other code */
 
        /* 例如 num_node 所对应的值可以直接在这里修改 */
 
        pub.spinOnce();
    }
}

创建订阅者

// subscriber.cpp
#include <csignal>
#include <rmvl/opcua/subscriber.hpp>
 
using namespace rm;
using namespace std::chrono_literals;
 
static bool stop = false;
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    // 创建 OPC UA 订阅者
    ua::Subscriber sub("DemoNumberSub", "opc.udp://224.0.0.22:4840", 4841);
 
    // 准备需要订阅的数据
    ua::FieldMetaData meta_data{"Number 1", ua::tpDouble, -1};
 
    /* 也可以通过创建变量对 meta_data 进行初始化，例如以下代码
    ua::Variable num = 1.0; // 这个 1.0 只是代表是个 Double 类型的数据
    num.browse_name = "Number 1";
    auto meta_data = ua::FieldMetaData::makeFrom(num);
    */
 
    // 订阅数据，第 2 个参数传入的是 std::vector 类型的数据，单个数据请使用初始化列表
    auto nodes = sub.subscribe("DemoNumberPub", {meta_data});
    // 订阅接收的数据均存放在订阅者自身的服务器中，请使用服务器端变量的写操作进行访问
    // 订阅返回值是一个 NodeId 列表，存放订阅接收的数据的 NodeId
 
    while (!stop) {
        // 读取订阅的已更新的数据
        auto sub_val = sub.read(nodes.front());
        std::printf("Sub value [1] = %f\n", sub_val.cast<double>());
 
        /* other code */
 
        sub.spinOnce();
    }
}

3.2 有代理 Pub/Sub

警告: RMVL 目前暂不支持有代理的发布订阅机制。

4 使用技巧

以下是 OPC UA 模块的使用技巧。

4.1 参数加载

OPC UA 模块中提供了以下几个运行时可调节参数

类型	参数名	默认值	注释
bool	SERVER_WAIT	false	单次处理网络事件时，允许服务器等待最多 50ms
uint32_t	CONNECT_TIMEOUT	30000	请求连接时，判定为超时的时间，单位 (ms)
uint32_t	CLIENT_WAIT_TIMEOUT	10	服务器超时响应的时间，单位 (ms)
double	SAMPLING_INTERVAL	2	服务器监视变量的采样速度，单位 (ms)
double	PUBLISHING_INTERVAL	2	服务器尝试发布数据变更的期望时间间隔，若数据未变更则不会发布，单位 (ms)
uint32_t	LIFETIME_COUNT	100	在没有发布任何消息的情况下，订阅请求所期望的能够保持活动状态的最大发布周期数
uint32_t	MAX_KEEPALIVE_COUNT	50	在没有任何通知的情况下，订阅请求所期望的服务器应该发送的最大 “保活” 消息数
uint32_t	MAX_NOTIFICATIONS	100	服务器应该发送的期望的最大通知数（通知是服务器向客户端报告订阅的变化的方式）
uint8_t	PRIORITY	0	订阅请求的优先级

具体调节方式可参考引言中的参数管理部分。

4.2 从 XML 配置 OPC UA

4.2.1 安装 UaModeler

可使用 UaModeler 等软件进行可视化信息模型的建立，构建后可以导出为一个 *.xml 文件，首先先安装 UaModeler。

Windows EXE

Windows 下可点击此处安装官方版本的 UaModeler 软件。

Python

如果有 Python 环境，也可以使用开源的 UaModeler 库，功能与官方软件基本一致。使用之前需要安装 pip3 Python 包管理工具，安装好包管理工具后，可使用以下命令行安装 UaModeler

pip3 install opcua-modeler

# Linux 下可以执行以下命令行运行 UaModeler

opcua-modeler

具体安装细节可参考 opcua-modeler on Github 的 README。

4.2.2 可视化配置 OPC UA

对于项目创建或导出等内容，此处不做过多介绍，可参考此博客了解上述内容。

注解

一般的，定义对象、变量、方法等内容均按照在代码中的顺序进行定义即可，但需要注意的是，添加了方法节点后，还需要在代码中设置该方法节点执行的回调函数，可参见 rm::ua::Server::setMethodNodeCallBack。
NamespaceArray 的 [1] 的字符串需要更改为 urn:open62541.server.application

4.2.3 生成 .c/.h 文件

注解: 以下生成 C/C++ 文件的介绍来自 open62541 nodeset-compiler。

进入 <path-to-open62541>/tools/nodeset_compiler 文件夹，执行以下命令行

# 获取 Opc.Ua.NodeSet2.xml 文件
wget "https://files.opcfoundation.org/schemas/UA/1.05/Opc.Ua.NodeSet2.xml"
# 将刚刚生成的 XML 文件移动至当前文件夹中，并重命名为 xxx.xml
mv <path-to-xml> ./xxx.xml
# 执行 nodeset_compiler
python3 ./nodeset_compiler.py \
  –types-array=UA_TYPES \
  –existing Opc.Ua.NodeSet2.xml \
  –xml xxx.xml \
  myNodeSet # myNodeSet 是要生成的文件名，包含 myNodeSet.h 和 myNodeSet.c，请自行设置

4.3 不占有所有权的 C/S 视图

rm::ua::Server 使用 RAII 进行设计，一个对象占有了服务器的所有权和生命周期，当对象析构时，会自动停止并结束服务器。使用 rm::ua::ServerView 来获取不占有所有权的服务器视图，并进行变量读写、路径搜索的操作。

RMVL 提供了从 rm::ua::Server 到 rm::ua::ServerView 的用户定义转换函数，可在不添加额外代码的情况下直接使用。

// server.cpp
#include <csignal>
#include <rmvl/opcua/server.hpp>
 
using namespace rm;
 
void modify(ua::ServerView sv, int val) {
    auto node = sv.find("num");
    sv.write(node, val);
}
 
int main() {
    signal(SIGINT, [](int) { stop = true; });
 
    ua::Server srv(4840);
 
    // 定义 int 型变量
    ua::Variable num_info = 42;
    num_info.browse_name = "num";
    num_info.display_name = "Num";
    num_info.description = "数字";
    // 添加到服务器的默认位置
    srv.addVariableNode(num_info);
 
    /* code */
 
    // 修改变量值
    modify(srv, 100);
 
    while (!stop)
        srv.spinOnce();
}

同样的，客户端也可以使用 ua::ClientView 来获取不占有所有权的客户端视图，进行变量读写、路径搜索的操作，此处不再赘述。

RMVL 也提供了从 ua::Client 到 ua::ClientView 的用户定义转换函数。

4.4 实际使用时的取舍

OPC UA 适合用于设备复杂的场景，复杂的设备通过 OPC UA 通信中间件提供的语义建模能力可以最大程度降低使用门槛。同样，OPC UA 也适用于发送控制指令等交互频率较低的场景，例如设备启动、停止、参数设置等操作，该操作需要严格保证可靠性，但不适合用于对实时性要求较高的场景，例如高速数据采集、运动控制等操作。OPC UA 协议本身提供的发布订阅功能，其服务发现机制也依赖服务端与客户端的方式，即使在 UDP 多播的无代理模式下，以及获取订阅者的数据也需要通过客户端读取服务器的变量节点来实现，这个过程本身就存在一定的延时，因此不适合用于对实时性要求较高的场景。需要实时性较高但可靠性要求不高的场景，请参考轻量发布订阅服务及其相关组件的通信中间件。

5 参考内容

[5] UaModeler · FreeOpcUa/opcua-modeler · Github

目录