Qt音视频开发27-Onvif设备搜索

void OnvifSearch::sendData()
{
    //依次发送数据,如果到了最后一个则停止
    //根据onvif device test工具抓包分析,只要发送前面两个就行,后面两个是ONVIF Device Manager抓包的
    //在收到结果的地方要对重复的进行过滤,因为部分设备两种协议请求都会返回
    //可以自行调整 timerSearch->stop(); 的位置来提高速度,比如很多情况下只要发送一次就可以
    writeData("239.255.255.250");
    if (currentFile == ":/send/searchDevice1.xml") {
        currentFile = ":/send/searchDevice2.xml";
    } else if (currentFile == ":/send/searchDevice2.xml") {
        currentFile = ":/send/searchDevice3.xml";
    } else if (currentFile == ":/send/searchDevice3.xml") {
        currentFile = ":/send/searchDevice4.xml";
    } else if (currentFile == ":/send/searchDevice4.xml") {
        timerSearch->stop();
    }
}

void OnvifSearch::writeData(const QString &ip)
{
    QByteArray data = OnvifHelper::getFile(currentFile);
    if (!data.isEmpty()) {
        data = QString(data).arg(OnvifHelper::getUuid()).toUtf8();
        udpSocket->writeDatagram(data, QHostAddress(ip), 3702);
        emit sendData(data);
    }
}

void OnvifSearch::readData()
{
    QByteArray data;
    QHostAddress host;
    quint16 port = 0;
    while (udpSocket->hasPendingDatagrams()) {
        data.resize(udpSocket->pendingDatagramSize());
        udpSocket->readDatagram(data.data(), data.size(), &host, &port);
        QString ip = host.toString();
        checkData(data, ip);
        emit receiveData(data);
        //qDebug() << TIMEMS << ip << port << data.size();
    }
}

void OnvifSearch::readData(const QString &file)
{
    //从文件读取数据解析,主要方便用来测试各种摄像机返回的数据
    QFile f(file);
    if (f.open(QFile::ReadOnly)) {
        QByteArray data = f.readAll();
        data = data.replace("\\\"", "\"");
        checkData(data, "");
    }
}

void OnvifSearch::checkData(const QByteArray &data, const QString &ip)
{
    OnvifQuery query;
    query.setData(data);

    QString discovery = query.getDiscovery();
    QString addr_path = QString("//%1:ProbeMatches/%1:ProbeMatch/%1:XAddrs").arg(discovery);
    QString scopes_path = QString("//%1:ProbeMatches/%1:ProbeMatch/%1:Scopes").arg(discovery);
    QString addr = query.getValue(addr_path);
    QString scopes = query.getValue(scopes_path);

    if (!addr.isEmpty()) {
        //过滤下IPV6地址 http://192.168.1.64/onvif/device_service http://[fe80::9a8b:aff:fe6e:867c]/onvif/device_service
        //发现还有串数据的要过滤 http://192.168.10.152/onvif/device_service http://192.168.10.172/onvif/device_service http://[fe80::9a8b:aff:fe4a:ad]/onvif/device_service
        QStringList list = addr.split(" ");
        if (ip.isEmpty()) {
            addr = list.first();
        } else {
            foreach (QString str, list) {
                if (str.contains(ip)) {
                    addr = str;
                    break;
                }
            }
        }

        //已经存在的地址不用继续
        if (checkExist(addr)) {
            return;
        }

        //按照过滤条件过滤设备 适用于设备很多而且设备类型很多的情况
        if (searchFilter != "none") {
            //默认80端口的不会带 :80  前面有 http: https: 所以要取后面的 : 索引位置来判断
            if (searchFilter == ":80") {
                if (addr.indexOf(":", 8) >= 8) {
                    return;
                }
            } else {
                if (!addr.contains(searchFilter)) {
                    return;
                }
            }
        }

        //定义结构体存储设备信息
        DeviceInfo deviceInfo;
        deviceInfo.addr = addr;
        deviceInfo.ip = OnvifHelper::getIP(addr);

        //取出其他信息 onvif://www.onvif.org/type/NetworkVideoTransmitter onvif://www.onvif.org/name/NVR onvif://www.onvif.org/hardware/hisi onvif://www.onvif.org/location/shanghai
        //这里的信息是通过广播搜索返回的无需密码,这里还可以根据打印出来的 scopes 自行增加设备信息
        list = scopes.split(" ");
        foreach (QString str, list) {
            QStringList l = str.split("/");
            if (l.contains("name")) {
                deviceInfo.name = l.last();
            } else if (l.contains("location")) {
                deviceInfo.location = l.last();
            } else if (l.contains("hardware")) {
                deviceInfo.hardware = l.last();
            }
        }

        deviceInfos << deviceInfo;
        emit receiveDevice(deviceInfo);
        emit receiveInfo(QString("发现设备-> %1").arg(addr));
    }
}

<?xml version="1.0" encoding="utf-8"?>
<Envelope xmlns:tds="http://www.onvif.org/ver10/device/wsdl" xmlns="http://www.w3.org/2003/05/soap-envelope">
  <Header>
    <wsa:MessageID xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/08/addressing">uuid:%1</wsa:MessageID>
    <wsa:To xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/08/addressing">urn:schemas-xmlsoap-org:ws:2005:04:discovery</wsa:To>
    <wsa:Action xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/08/addressing">http://schemas.xmlsoap.org/ws/2005/04/discovery/Probe</wsa:Action>
  </Header>
  <Body>
    <Probe xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns="http://schemas.xmlsoap.org/ws/2005/04/discovery">
      <Types>tds:Device</Types>
      <Scopes />
    </Probe>
  </Body>
</Envelope>