?？当O(jiān)控設(shè)備在國(guó)內(nèi)相關(guān)領(lǐng)域占有很大的份額，至少目前我接觸到的項(xiàng)目或公司都是使用?？翟O(shè)備進(jìn)行監(jiān)控的。所以本文主要針對(duì)?？翟O(shè)備來(lái)進(jìn)行視頻流的獲取。

視頻流

1 概念說(shuō)明

硬盤(pán)錄像機(jī)：海康產(chǎn)品的硬盤(pán)錄像機(jī)分為DVR、NVR和CVR三種，DVR是模擬機(jī)和同軸纜信號(hào)的硬盤(pán)錄像機(jī)，不需要配置IP；NVR是網(wǎng)絡(luò)型錄像機(jī)，必須配置IP；CVR是更高級(jí)的NVR或者DVR，數(shù)據(jù)集中存儲(chǔ)的NVR（預(yù)研用硬盤(pán)錄像機(jī)為CVR）。

2 技術(shù)實(shí)現(xiàn)

技術(shù)實(shí)現(xiàn)

?？当O(jiān)控設(shè)備視頻流獲取技術(shù)以上技術(shù)路線圖所示，首先初始化SDK，其次設(shè)置連接超時(shí)時(shí)間、重連時(shí)間與異常消息回調(diào)函數(shù)；接著通過(guò)提供硬盤(pán)錄像機(jī)IP、賬號(hào)、密碼、端口號(hào)等信息進(jìn)行登錄；然后通過(guò)設(shè)置播放句柄、通道、流類(lèi)型、連接方式、是否阻塞等播放信息來(lái)進(jìn)行播放，同時(shí)通過(guò)設(shè)置播放回調(diào)函數(shù)來(lái)獲取實(shí)時(shí)視頻流；之后通過(guò)軟解碼技術(shù)將視頻流逐幀解碼為YU12格式，然后編寫(xiě)算法將YU12格式數(shù)據(jù)轉(zhuǎn)換為RGBA數(shù)據(jù)，從而完成整個(gè)過(guò)程的操作。

3 示例代碼

該技術(shù)用到的?？礢DK包括HCNetSDK.lib、HCNetSDK.dll、PlayCtrl.lib、PlayCtr.dll，并使用opencv進(jìn)行視頻的試試顯示。具體示例代碼如下所示：

#include "Windows.h"
#include "HCNetSDK.h"
#include <stdio.h>
#include <time.h>
#include "plaympeg4.h"
#include "opencv/cv.h"
#include "opencv2/photo.hpp"
#include "opencv2/imgproc.hpp"
#include "opencv2/highgui.hpp"




void CALLBACK g_ExceptionCallBack(DWORD dwType, LONG IUserID, LONG IHandle, void *pUser)
{
    char tempbuf[256] = {};
    switch (dwType)
    {

    case EXCEPTION_RECONNECT:
        printf("--------reconnect-------%d\n", time(NULL));
        break;
    default:
        break;
    }
}

bool YV12_to_RGB32(unsigned char* pYV12, unsigned char* pRGB32, int iWidth, int iHeight)
{
    if (!pYV12 || !pRGB32)
        return false;

    const long nYLen = long(iHeight * iWidth);
    const int nHfWidth = (iWidth >> 1);

    if (nYLen < 1 || nHfWidth < 1)
        return false;

    unsigned char* yData = pYV12;
    unsigned char* vData = pYV12 + iWidth*iHeight + (iHeight / 2)*(iWidth / 2);//&vData[nYLen >> 2];  
    unsigned char* uData = pYV12 + iWidth*iHeight;// &yData[nYLen];  
    if (!uData || !vData)
        return false;

    int rgb[4];
    int jCol, iRow;
    for (iRow = 0; iRow < iHeight; iRow++)
    {
        for (jCol = 0; jCol < iWidth; jCol++)
        {
            rgb[3] = 1;

            int Y = yData[iRow*iWidth + jCol];
            int U = uData[(iRow / 2)*(iWidth / 2) + (jCol / 2)];
            int V = vData[(iRow / 2)*(iWidth / 2) + (jCol / 2)];
            int R = Y + (U - 128) + (((U - 128) * 103) >> 8);
            int G = Y - (((V - 128) * 88) >> 8) - (((U - 128) * 183) >> 8);
            int B = Y + (V - 128) + (((V - 128) * 198) >> 8);

            // r分量值   
            R = R < 0 ? 0 : R;
            rgb[2] = R > 255 ? 255 : R;
            // g分量值  
            G = G < 0 ? 0 : G;
            rgb[1] = G > 255 ? 255 : G;
            // b分量值   
            B = B < 0 ? 0 : B;
            rgb[0] = B > 255 ? 255 : B;
            pRGB32[4 * (iRow*iWidth + jCol) + 0] = rgb[0];
            pRGB32[4 * (iRow*iWidth + jCol) + 1] = rgb[1];
            pRGB32[4 * (iRow*iWidth + jCol) + 2] = rgb[2];
            pRGB32[4 * (iRow*iWidth + jCol) + 3] = rgb[3];
        }
    }

    return true;
}

void CALLBACK g_DecCBFun(long nPort, char* pBuf, long nSize, FRAME_INFO* pFrameInfo, long nReserved1, long nReserved2)
{
    long lFrameType = pFrameInfo->nType;
    if (lFrameType == T_AUDIO16)
    {
        //printf("Audio nStap:%d\n", pFrameInfo->nStamp);
    }
    else if (lFrameType == T_YV12)
    {
    
    
        char* rgba = new char[pFrameInfo->nHeight * pFrameInfo->nWidth * 4];

        //  YV12_to_RGB24((unsigned char*)pBuf, (unsigned char*)rgb, pFrameInfo->nWidth, pFrameInfo->nHeight);
        YV12_to_RGB32((unsigned char*)pBuf, (unsigned char*)rgba, pFrameInfo->nWidth, pFrameInfo->nHeight);

        cv::Mat img(pFrameInfo->nHeight,pFrameInfo->nWidth,CV_8UC4,rgba);
        cv::resize(img, img, cv::Size(img.size().width*0.5, img.size().height*0.5));
        cv::imshow("video", img);
        cv::waitKey(1);
    
    }
}

LONG nPort = -1;

void CALLBACK g_RealDataCallBack(LONG IRealHandle, DWORD dwDataType, BYTE *pBuffer, DWORD dwBufSize, void* pUser)
{
    DWORD dRet = 0;
    BOOL inData = FALSE;

    switch (dwDataType)
    {
    case NET_DVR_SYSHEAD:
        if (!PlayM4_GetPort(&nPort))
        {
            break;
        }

        if (!PlayM4_OpenStream(nPort,pBuffer,dwBufSize,1024*1024))
        {
            dRet = PlayM4_GetLastError(nPort);
            break;
        }

        if (!PlayM4_SetDecCallBack(nPort,g_DecCBFun))
        {
            dRet = PlayM4_GetLastError(nPort);
            break;
        }

        if (!PlayM4_Play(nPort,NULL))
        {
            dRet = PlayM4_GetLastError(nPort);
            break;
        }
    case NET_DVR_STREAMDATA:
        if (dwBufSize > 0 && nPort != -1)
        {
            inData = PlayM4_InputData(nPort, pBuffer, dwBufSize);
            while (!inData)
            {
                Sleep(10);
                inData = PlayM4_InputData(nPort, pBuffer, dwBufSize);
                printf("PlayM4_InputData faild %d\n",PlayM4_GetLastError(nPort));

            }
        }
        break;
    default:
        inData = PlayM4_InputData(nPort, pBuffer, dwBufSize);
        while (!inData)
        {
            Sleep(10);
            inData = PlayM4_InputData(nPort, pBuffer, dwBufSize);
            OutputDebugString("PlayM4_InputData failed 2\n");
        }
        break;
    }
}

void main()
{
    //init sdk
    NET_DVR_Init();

    //set reconnect time
    NET_DVR_SetConnectTime(2000, 1);
    NET_DVR_SetReconnect(10000, true);



    //set recall func
    NET_DVR_SetExceptionCallBack_V30(0, NULL, g_ExceptionCallBack, NULL);

    //get console handler


    //register device
    LONG IUserID;
    NET_DVR_USER_LOGIN_INFO struLoginInfo = { 0 };
    NET_DVR_DEVICEINFO_V40 struDeviceInfo = { 0 };

    strcpy_s((char*)struLoginInfo.sDeviceAddress, sizeof(struLoginInfo.sDeviceAddress), "192.168.3.62");
    strcpy_s((char*)struLoginInfo.sUserName,sizeof(struLoginInfo.sUserName), "admin");
    strcpy_s((char*)struLoginInfo.sPassword,sizeof(struLoginInfo.sPassword), "abcd-1234");
    struLoginInfo.wPort = 8000;
    struLoginInfo.bUseAsynLogin = 0;

    IUserID = NET_DVR_Login_V40(&struLoginInfo, &struDeviceInfo);
    if (IUserID < 0)
    {
        printf("login failed, error code:%d\n", NET_DVR_GetLastError());
        NET_DVR_Cleanup();
        return;
    }

//  printf("channel num:%d\n", struDeviceInfo.struDeviceV30.byChanNum);
//  printf("start channel:%d\n", struDeviceInfo.struDeviceV30.byStartChan);
    NET_DVR_IPPARACFG_V40 IpAccessCfg;
    memset(&IpAccessCfg, 0, sizeof(IpAccessCfg));
    DWORD  dwReturned;

    if (!NET_DVR_GetDVRConfig(IUserID, NET_DVR_GET_IPPARACFG_V40, 0, &IpAccessCfg, sizeof(NET_DVR_IPPARACFG_V40), &dwReturned))
    {
        return;
    }
    LONG channel;
    for (int i = 0; i < MAX_IP_CHANNEL; ++i)
    {
        if (IpAccessCfg.struStreamMode[i].uGetStream.struChanInfo.byEnable)
        {
            channel = i + IpAccessCfg.dwStartDChan;
            break;
        }
    }



    //display
    LONG IRealPlayHandle;

    NET_DVR_PREVIEWINFO struPlayInfo = { 0 };
    struPlayInfo.hPlayWnd = NULL;
    struPlayInfo.lChannel = channel;
    struPlayInfo.dwStreamType = 0;
    struPlayInfo.dwLinkMode = 0;
    struPlayInfo.bBlocked = 1;


    //
//  NET_DVR_CLIENTINFO ClientInfo;
//  ClientInfo.hPlayWnd = hWnd;
//  ClientInfo.lChannel = 0;
//  ClientInfo.lLinkMode = 0;
//  ClientInfo.sMultiCastIP = NULL;
//  //TRACE("Channel number:%d\n", ClientInfo.lChannel);
//  IRealPlayHandle = NET_DVR_RealPlay_V30(IUserID, &ClientInfo, NULL, NULL, TRUE);

    IRealPlayHandle = NET_DVR_RealPlay_V40(IUserID, &struPlayInfo, g_RealDataCallBack, NULL);
    if (IRealPlayHandle<0)
    {
        printf("play failed, error code:%d\n", NET_DVR_GetLastError());
        NET_DVR_Logout(IUserID);
        NET_DVR_Cleanup();
        return;
    }

    Sleep(10000000000000000);

    //close display
    NET_DVR_StopRealPlay(IRealPlayHandle);
    //logout
    NET_DVR_Logout(IUserID);
    //release
    NET_DVR_Cleanup();
    return;

}