事件订阅是近期增加的功能,主要是因为遇到越来越多的一个应用场景,能够接收摄像机的报警事件,比如几乎所有的摄像机后面会增加报警输入输出接口,如果用户外接了报警输入,则当触发报警以后,对应的事件也会通过onvif传出去,这样就相当于兼容了所有onvif摄像机厂家的报警事件接收,在一些应用系统中,这个功能也是很常见的。
事件订阅流程
onvif主要的功能
onvif的处理流程
QString OnvifDevice::getEvent(const QString &timeout)
{
QString file = OnvifHelper::getFile(":/send/getEvent.xml");
file = file.arg(request->getUserToken()).arg(timeout);
QByteArray dataSend = file.toUtf8();
QNetworkReply *reply = request->post(deviceUrl, dataSend);
emit sendData(dataSend, deviceUrl);
QByteArray dataReceive;
bool ok = checkData(reply, dataReceive, "订阅事件服务");
if (ok) {
OnvifQuery query;
query.setData(dataReceive);
eventUrl = query.getEventUrl();
//启动定时器去请求事件内容
if (!timerPullMessage->isActive()) {
timerPullMessage->start();
QTimer::singleShot(100, this, SLOT(pullMessage()));
}
}
return eventUrl;
}
QString OnvifDevice::pullMessage(const QString &timeout)
{
QString message;
if (eventUrl.isEmpty()) {
return message;
}
emit receiveInfo("请求事件内容");
//有两种类型的消息,挨个发
QString file;
if (messageIndex == 0) {
//messageIndex = 1;
file = OnvifHelper::getFile(":/send/pullMessage.xml");
} else if (messageIndex == 1) {
messageIndex = 0;
file = OnvifHelper::getFile(":/send/pullMessage2.xml");
}
QString uuid = OnvifHelper::getUuid();
file = file.arg(request->getUserToken()).arg(uuid).arg(eventUrl).arg(timeout);
QByteArray dataSend = file.toUtf8();
QNetworkReply *reply = request->post(eventUrl, dataSend);
emit sendData(dataSend, eventUrl);
QByteArray dataReceive;
bool ok = checkData(reply, dataReceive, "请求事件内容");
if (ok) {
OnvifQuery query;
query.setData(dataReceive);
message = query.getEventMessage();
if (!message.isEmpty()) {
emit receiveInfo(message);
//收到事件数据回复了继续请求,因为有可能还要事件数据,直到拿完
pullMessage();
}
}
return message;
}
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。