Qt編寫安防視頻監控系統34-onvif事件訂閱

一、前言

事件訂閱是近期增加的功能，主要是因為遇到越來越多的一個應用場景，能夠接收攝像機的報警事件，比如幾乎所有的攝像機后面會增加報警輸入輸出接口，如果用戶外接了報警輸入，則當觸發報警以后，對應的事件也會通過onvif傳出去，這樣就相當於兼容了所有onvif攝像機廠家的報警事件接收，在一些應用系統中，這個功能也是很常見的。

事件訂閱流程

1. 發送getEvent（CreatePullPointSubscription）訂閱事件服務。
2. 訂閱服務成功以后，發送PullMessages訂閱事件。
3. 如果有事件，會立即回復數據，在處理完數據以后，要重新發送PullMessages訂閱事件。
4. 如此往復，一旦有事件會在請求后回復數據，該請求默認是長連接。
5. 發送PullMessages的時候帶有超時時間，一旦到了超時時間，也需要重新發送PullMessages。

onvif主要的功能

1. 搜索設備，獲取設備的信息比如廠家、型號等。
2. 獲取設備的多個配置文件信息profile。
3. 獲取對應配置文件的視頻流地址rtsp，以及分辨率等參數。
4. 雲台控制，上下左右移動，焦距放大縮小，相對和絕對移動。
5. 獲取預置位信息，觸發預置位。
6. 訂閱事件，接收設備的各種消息尤其是報警事件比如IO口的報警。
7. 抓圖，獲取設備當前的圖片。
8. 獲取、創建、刪除用戶信息。
9. 獲取和設備網絡配置信息比如IP地址等。
10. 獲取和設置NTP時間同步。
11. 獲取和設置設備時間。
12. 重啟設備。

onvif的處理流程

1. 綁定組播IP（239.255.255.250）和端口（3702），發送固定的xml格式的數據搜索設備。
2. 接收到的xml格式的數據解析，得到設備的Onvif地址。
3. 對Onvif地址發送對應的數據，收到數據取出對應的節點數據。
4. 請求Onvif地址獲取Media地址和Ptz地址，Media地址用來獲取詳細的配置文件，Ptz地址用來雲台控制。
5. ptz控制是對Ptz地址發送對應的數據即可。
6. 設置了用戶認證的需要組織用戶token信息一塊發送，每次都需要作鑒權處理。
7. 接收到的數據不是標准的xml數據，沒法按照正常的節點解析來處理，只能用QXmlQuery來做。
8. 每個廠家設備返回的數據未必完全一致，基本上都不一致，需要進行模糊查找節點值。
9. 特意采用底層協議解析，因為soap太臃腫函數名稱太另類，特意做的輕量級的。
10. 兩個必備工具，Onvif Device Manager 和 Onvif Device Test Tool。

二、功能特點

1. 支持多畫面切換，全屏切換等，包括1+4+6+8+9+13+16+25+36+64畫面切換。
2. 支持alt+enter全屏，esc退出全屏。
3. 自定義信息框+錯誤框+詢問框+右下角提示框（包含多種格式）。
4. 17套皮膚樣式隨意更換，所有樣式全部統一，包括菜單等。
5. 雲台儀表盤鼠標移上去高亮，八個方位精准識別。
6. 底部畫面工具欄（畫面分割切換+截圖聲音等設置）移上去高亮。
7. 可在配置文件更改左上角logo+中文軟件名稱+英文軟件名稱。
8. 封裝了百度地圖，視圖切換，運動軌跡，設備點位，鼠標按下獲取經緯度等。
9. 支持圖片地圖，設備按鈕可以在圖片地圖上自由拖動自動保存位置信息。
10. 在百度地圖和圖片地圖上，雙擊視頻可以預覽攝像頭實時視頻。
11. 堆棧窗體，每個窗體都是個單獨的qwidget，方便編寫自己的代碼。
12. 頂部鼠標右鍵菜單，可動態控制時間CPU+左上角面板+左下角面板+右上角面板+右下角面板的顯示和隱藏，支持恢復默認布局。
13. 工具欄可以放置多個小圖標和關閉圖標。
14. 左側右側可拖動拉伸，並自動記憶寬高位置，重啟后恢復。
15. 雙擊攝像機節點自動播放視頻，雙擊節點自動依次添加視頻，會自動跳到下一個，雙擊父節點自動添加該節點下的所有視頻。
16. 攝像機節點拖曳到對應窗體播放視頻，同時支持拖曳本地文件直接播放。
17. 視頻畫面窗體支持拖曳交換，瞬間響應。
18. 雙擊節點+拖曳節點+拖曳窗體交換位置，均自動更新url.txt。
19. 支持從url.txt中加載通道視頻播放，自動記憶最后通道對應的視頻，軟件啟動后自動打開播放。
20. 右下角音量條控件，失去焦點自動隱藏，音量條帶靜音圖標。
21. 集成百度在線地圖和離線地圖，可以添加設備對應位置，自動生成地圖，支持縮放和添加覆蓋物等。
22. 視頻拖動到通道窗體外自動刪除視頻。
23. 鼠標右鍵可刪除當前+所有視頻，截圖當前+所有視頻。
24. 錄像機管理、攝像機管理，可添加刪除修改導入導出打印信息，立即應用新的設備信息生成樹狀列表，不需重啟。
25. 在pro文件中可以自由開啟是否加載地圖。
26. 視頻播放可選2種內核自由切換，vlc+ffmpeg，均可在pro中設置。
27. 可設置1+4+9+16畫面輪詢，可設置輪詢間隔以及輪詢碼流類型等，直接在主界面底部工具欄右側單擊啟動輪詢按鈕即可，再次單擊停止輪詢。
28. 默認超過10秒鍾未操作自動隱藏鼠標指針。
29. 支持onvif搜素設備，支持任意onvif攝像機，包括但不限於海康大華宇視天地偉業華為等。
30. 支持onvif雲台控制，可上下左右移動雲台攝像機，包括復位和焦距調整等。
31. 同時支持sqlite、mysql、postsql等數據庫。
32. 可保存視頻，可選定時存儲或者單文件存儲，可選存儲間隔時間。
33. 可設置視頻流通信方式tcp+udp，可設置視頻解碼是速度優先、質量優先、均衡等。
34. 可設置硬解碼類型，支持qsv、dxva2、d3d11va等。
35. 默認采用opengl繪制視頻，超低的CPU資源占用，支持yuyv和nv12兩種格式繪制，很牛逼。
36. 高度可定制化，用戶可以很方便的在此基礎上衍生自己的功能，支持linux和mac系統。

三、效果圖

四、核心代碼

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;
}