当前位置：首页 > news >正文

opcua批量读取变量

news 来源：原创 2025/4/22 5:42:21

之前通过订阅的方式监听PLC变量的变化，但是在使用的过程中，不知道是PLC的opcua服务器的问题还是别的问题，在某些情况、某些时候，会出现订阅不活跃的情况。

[2025-04-16 09:03:17.144 (UTC+0800)] error/client	Inactivity for Subscription 9.

出现这种情况后，就接收不到变量的变化了。但是此时还是可以读写的。
一番折腾后，这个情况还是会出现，解决不了。
最后没办法，只能自己实现“订阅”：周期性地读取变量值，然后与上一次读取的值进行对比，假如不一致就发出changed信号。
读取时，使用批量读取函数UA_Client_Service_read:

QStringList tmpList; // 要读取的变量UA_ReadRequest request;
UA_ReadRequest_init(&request);
// 定义要读取的节点列表
int idsCount = tmpList.length();
UA_ReadValueId *ids = new UA_ReadValueId[idsCount];
for(int i = 0; i < idsCount; i++)
{UA_ReadValueId_init(&ids[i]);QString nodeString = tmpList.at(i);UA_NodeId nodeId = UA_NODEID_STRING_ALLOC(4, nodeString.toStdString().data());ids[i].nodeId = nodeId;ids[i].attributeId = UA_ATTRIBUTEID_VALUE;
}
request.nodesToRead     = ids;
request.nodesToReadSize = idsCount;
// 执行批量读取
UA_ReadResponse response = UA_Client_Service_read(mClient, request);
if (response.responseHeader.serviceResult == UA_STATUSCODE_GOOD) {for (size_t i = 0; i < response.resultsSize; i++) {// 处理每个节点的值QString varPath = tmpList.at(i);QVariant var = convertUAVariantToQVariant(response.results[i].value);// qDebug() << varPath << var;if(mMonList[varPath] != var){mMonList[varPath] = var;emit valueChanged(varPath, var);}}
}
else
{qDebug() << "multi read error:"<< QString::number(response.responseHeader.serviceResult, 16).toUpper();
}
UA_ReadResponse_clear(&response);
// qDebug() << "multi read values:" << response.responseHeader.serviceResult;
delete[] ids;

但是交付给同事测试时，发现会报错，返回的错误码为0x80100000，也就是

/* "The request could not be processed because it specified too many operations." */
#define UA_STATUSCODE_BADTOOMANYOPERATIONS 0x80100000

经过查看源码，发现大概率是这个地方返回的
在这里插入图片描述
也就是单次读取时，节点个数超过了服务器的承载值。
那服务器的这个参数在哪里呢？

这个值是只读的，不允许客户端修改的

那么，在我们的程序中，可以先读取这个限制值，然后再把我们的变量分成若干批去读。
读取这个值：

 // 获取服务器的OperationLimits-MaxNodesPerReadUA_NodeId nodeId = UA_NODEID_NUMERIC(0,UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERREAD);UA_Variant var;UA_Variant_init(&var);UA_StatusCode ret = UA_Client_readValueAttribute(mClient,nodeId,&var);if(UA_StatusCode_isGood(ret)){QVariant value = convertUAVariantToQVariant(var);mMaxNodesPerRead = value.toInt();}qDebug() << "++++++++++++mMaxNodesPerRead:"<< UA_StatusCode_name(ret)<< mMaxNodesPerRead;

然后按照这个值去分批

    QStringList varPathList; //所有需要读取的变量列表......// 根据MaxNodesPerRead，来分批读取QList<QStringList> batchReadList;int curIdx = 0;do{batchReadList << varPathList.mid(curIdx, mMaxNodesPerRead);curIdx += mMaxNodesPerRead;}while(curIdx < varPathList.length());