OPC UA 在 MFC 中：open62541 集成

MFC 应用中的 OPC UA：在 Windows 上集成 open62541 实现工业 SCADA

工业自动化系统正日益摆脱单体、专有的 SCADA 解决方案，转而采用灵活、安全且跨平台的 OPC UA 基础架构。在此背景下，基于 Microsoft Foundation Classes（MFC）并集成 open62541 的轻量级 SCADA 系统，成为中型企业技术上明智的选择——尤其是在需要兼容传统 Windows 基础设施、同时对与 Siemens S7-1200/S7-1500 控制器的通信有严格延迟要求的情况下。

架构转型：从专有 SCADA 到 OPC UA 驱动的集成

传统的 SCADA 平台（如 WinCC、InTouch、EcoStruxure）均基于封闭协议和供应商锁定构建。其部署不仅需要许可证授权、复杂的配置，还常常导致软件安装臃肿——即便实际仅使用了 15%–20% 的功能，安装包也可能高达 20 GB。对于中小企业而言，这种做法在经济上并不合理。

OPC UA 解决了三大系统性挑战：

• 互操作性：统一的地址空间（NodeId）、类型化变量以及单一订阅机制，使不同厂商设备的数据无需中间网关即可直接汇聚。
• 开箱即用的安全性：支持 X.509 证书、多种安全策略（None、Basic128Rsa15、Basic256Sha256），以及协议层加密与认证。
• 部署灵活性：客户端可以是原生 Windows 应用程序（MFC/Win32）、Web 服务或运行在 Linux 上的微服务——且无需修改服务器端逻辑。

在工业实践中，这意味着可以用定制解决方案替代昂贵的 SCADA 系统，这些方案通过 OPC UA 直接连接控制器，集成 SQL Server 存储配方与历史数据，并借助图表与设备状态显示实现远程监控。

将 open62541 集成到 MFC：技术特性与局限

open62541 是一款符合 C99 标准、零依赖的开源库，专为嵌入式与桌面系统设计。将其用于 MFC 项目时，需满足若干条件：

• 项目必须以 /MD 模式编译（动态链接 CRT），因为 open62541 依赖标准 C 库。
• 使用安全策略时，必须显式初始化 TLS/SSL 栈——在 Windows 中，这涉及 Wincrypt.h 和 CryptInitialize()。
• 所有对象，如 UA_Client、UA_CreateSubscriptionRequest 和 UA_MonitoredItemCreateRequest，都必须手动管理：内存分配、调用 UA_Client_disconnect() 以及通过 UA_Client_delete() 释放。

一个关键限制是缺乏内置线程池。在带有 GUI 线程的 MFC 应用中，所有对 UA_Client_* 的调用都必须在独立的工作线程中执行（AfxBeginThread）或通过 PostMessage/WM_USER 实现，以免阻塞界面。若直接在 CMainFrame::OnInitialUpdate() 中调用 UA_Client_connect()，窗口将立即冻结。

在 C++/MFC 中实现连接与订阅

函数 CMainFrame::ConnectCPUOnline() 展示了一个连接 OPC UA 服务器的最小可行场景。它负责初始化客户端、配置参数并建立连接。关键点包括：

• 使用 UA_String_fromChars() 将 CT2A 字符串转换为 UA_String——这是 open62541 API 的强制要求。
• 设置 cc->securityMode = UA_MESSAGESECURITYMODE_NONE 仅适用于隔离网络；在实际项目中，应选择 UA_MESSAGESECURITYMODE_SIGNANDENCRYPT，并通过 UA_ClientConfig_setDefaultEncryption() 加载证书。
• 在生产环境中，将日志级别设为 UA_LOGLEVEL_ERROR 可在诊断与性能之间取得最佳平衡。

连接完成后，创建订阅并配置监控项。以下是创建订阅并添加第一个标签的代码片段：

// 创建订阅
UA_CreateSubscriptionRequest request = UA_CreateSubscriptionRequest_default();
request.requestedPublishingInterval = 500.0; // ms
request.requestedMaxKeepAliveCount = 10;
request.requestedLifetimeCount = 30;

UA_CreateSubscriptionResponse response = UA_Client_Subscriptions_create(
    StrCPUADR[iAdr].g_clientOnline, request, NULL, NULL, NULL);

if (response.responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
    return false;
}
StrCPUADR[iAdr].g_subscriptionId = response.subscriptionId;

// 配置标签的监控
UA_MonitoredItemCreateRequest monRequest = UA_MonitoredItemCreateRequest_default();
monRequest.itemToMonitor.nodeId = UA_NODEID_NUMERIC(0, StrDBINI[i].iIDUA);
monRequest.itemToMonitor.attributeId = UA_ATTRIBUTEID_VALUE;
monRequest.monitoringMode = UA_MONITORINGMODE_REPORTING;

UA_MonitoredItemCreateResult monResponse = UA_Client_MonitoredItems_createSingle(
    StrCPUADR[iAdr].g_clientOnline,
    StrCPUADR[iAdr].g_subscriptionId,
    &monRequest);

注意，iIDUA 是从数据库获取的控制器 NodeId（例如 ns=2;s=Channel1.Device1.Tag1）。它必须与服务器的地址空间完全匹配。NodeId 错误会导致 UA_STATUSCODE_BADNODEIDUNKNOWN，但不会引发崩溃——务必检查 monResponse.statusCode。

数据处理：从读取到存储至 SQL Server

系统使用三种关键结构来管理数据：

• StrDBCP——控制器连接配置：IP 地址、在线/离线状态、指向 UA_Client* 的指针、订阅 ID 以及用于接收数值的 arrayValue 缓冲区。
• StrDBINI——标签元数据：iIDUA（NodeId）、iTYPEID（数据类型：UA_TYPES_INT32、UA_TYPES_DOUBLE、UA_TYPES_BOOLEAN）以及用于记录的日志标志 bSaveDb。
• StrDBVAL——历史值表，包含时间戳、CTime、iNOMEQ、iItem 和 iVal。

更新数值的逻辑由回调函数 UA_Client_DataChangeNotification 实现。当收到新值时：

• 检查 iTYPEID，并使用 UA_Variant_getScalarCopy() 安全地进行类型转换。
• 写入 arrayValue[i]，同时考虑 sizearray。
• 若 bSaveDb == true，则通过 CDatabase::ExecuteSQL() 在 SQL Server 中生成参数化 INSERT 语句。

重要提示：所有对 arrayValue 的操作都必须由临界区保护（CCriticalSection），因为数据来自后台线程，而 GUI 线程可能同时请求用于图表渲染。

关键要点

• 在 MFC 应用中使用 OPC UA 时，需手动管理 UA_Client 的生命周期：初始化 → 连接 → 订阅 → 读取 → 取消订阅 → 断开 → 删除。
• 安全性不容忽视：SECURITYPOLICY_NONE 仅适用于测试环境；在工业网络中，X.509 证书与 SIGNANDENCRYPT 是强制要求。
• open62541 不提供针对 Windows GUI 的异步 API——所有网络操作都必须在独立线程中完成，随后通过 PostMessage 同步。
• StrDBCP、StrDBINI 和 StrDBVAL 结构构成了 OPC UA 的抽象层，允许在不改变数据处理逻辑的前提下切换不同控制器。
• 支持 Siemens S7-1200/S7-1500 需要在控制器固件中启用 OPC UA 服务器，并在 TIA Portal 中正确配置用户访问控制（UAC）。

— Editorial Team