open62541服务器向客户端发送内存变量及OPC-UA/MODBUS桥接问题

阿华AIGC实验室

2026-5-29

解决Open62541 OPC-UA服务器接收请求与MODBUS数据回传的问题

我刚好做过类似的OPC-UA与MODBUS桥接项目，针对你遇到的找不到请求接收点、不知道如何回传数据的问题，分两部分给你拆解清楚：

一、找到Open62541接收客户端请求的核心入口

open62541是通过节点回调函数来响应客户端的读写请求的——你需要给对应的OPC-UA变量节点注册read（或write）回调，当客户端发起读取该节点的请求时，服务器就会触发你定义的回调逻辑，这就是接收请求的位置。

给你贴一段核心代码示例，一看就懂：

// 定义读取回调函数：客户端读取节点时，服务器会进入这个函数
static UA_StatusCode modbusReadCallback(UA_Server *server,
                                        const UA_NodeId *sessionId, void *sessionContext,
                                        const UA_NodeId *nodeId, void *nodeContext,
                                        UA_Boolean sourceTimeStamp, const UA_NumericRange *range,
                                        UA_DataValue *dataValue) {
    // 这里就是你接收客户端读取请求的地方！
    // 后续的MODBUS请求、数据回传逻辑都在这里实现

    return UA_STATUSCODE_GOOD;
}

// 服务器初始化时，注册带回调的OPC-UA节点
static void registerModbridgedNode(UA_Server *server) {
    UA_VariableAttributes attr = UA_VariableAttributes_default;
    UA_UInt16 initialVal = 0;
    UA_Variant_setScalar(&attr.value, &initialVal, &UA_TYPES[UA_TYPES_UINT16]);
    attr.description = UA_LOCALIZEDTEXT("en-US", "MODBUS Holding Register 40001");
    attr.displayName = UA_LOCALIZEDTEXT("en-US", "HoldingReg40001");
    attr.accessLevel = UA_ACCESSLEVELMASK_READ; // 只读，因为数据来自MODBUS

    // 关键：注册节点时绑定读取回调
    UA_NodeId nodeId = UA_NODEID_STRING(1, "modbus.reg.40001");
    UA_Server_addVariableNode(server, nodeId,
                              UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER),
                              UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES),
                              UA_QUALIFIEDNAME(1, "HoldingReg40001"),
                              UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE),
                              attr, modbusReadCallback, NULL);
}

关键点：

modbusReadCallback就是请求接收的入口，客户端每读一次这个节点，就会触发一次这个函数。
你需要在回调里完成「解析请求的变量→调用MODBUS读取→把结果返回给客户端」的完整流程。

二、将MODBUS获取的变量回传给客户端

在回调函数里，核心是把MODBUS读取到的值填充到UA_DataValue结构体中，open62541会自动把这个结构体的数据返回给客户端。结合libmodbus库的话，完整逻辑如下：

static UA_StatusCode modbusReadCallback(UA_Server *server,
                                        const UA_NodeId *sessionId, void *sessionContext,
                                        const UA_NodeId *nodeId, void *nodeContext,
                                        UA_Boolean sourceTimeStamp, const UA_NumericRange *range,
                                        UA_DataValue *dataValue) {
    // 1. 根据OPC-UA节点ID，匹配对应的MODBUS地址
    char *nodeStr = UA_NodeId_getString(nodeId, server);
    uint16_t modbusAddr = 0;
    if(strcmp(nodeStr, "modbus.reg.40001") == 0) {
        modbusAddr = 0; // libmodbus里保持寄存器40001对应起始地址0
    }
    UA_free(nodeStr);

    // 2. 连接MODBUS服务器（建议提前建立全局长连接，不要每次回调都连，影响性能）
    modbus_t *ctx = modbus_new_tcp("192.168.1.100", 502);
    if(ctx == NULL || modbus_connect(ctx) == -1) {
        UA_LOG_ERROR(server->logger, UA_LOGCATEGORY_USERLAND,
                     "MODBUS连接失败: %s", modbus_strerror(errno));
        modbus_free(ctx);
        return UA_STATUSCODE_BADCOMMUNICATIONERROR;
    }

    // 3. 读取MODBUS寄存器的值
    uint16_t regValue;
    int rc = modbus_read_registers(ctx, modbusAddr, 1, &regValue);
    if(rc == -1) {
        UA_LOG_ERROR(server->logger, UA_LOGCATEGORY_USERLAND,
                     "读取MODBUS寄存器失败: %s", modbus_strerror(errno));
        modbus_close(ctx);
        modbus_free(ctx);
        return UA_STATUSCODE_BADUNEXPECTEDERROR;
    }

    // 4. 将MODBUS值赋值给OPC-UA的DataValue，回传给客户端
    UA_UInt16 opcValue = regValue;
    UA_Variant_setScalarCopy(&dataValue->value, &opcValue, &UA_TYPES[UA_TYPES_UINT16]);
    dataValue->hasValue = true;
    dataValue->sourceTimestamp = UA_DateTime_now(); // 带上时间戳更规范

    // 5. 关闭连接（如果是全局长连接就跳过这步）
    modbus_close(ctx);
    modbus_free(ctx);

    return UA_STATUSCODE_GOOD;
}

注意事项：