海康威视多线程读取多通道摄像头

海康威视提供的SDK中包含了多线程读取多通道摄像头的接口。你可以使用该SDK提供的函数来实现该功能。

首先，你需要初始化SDK和设备。然后，创建多个线程，每个线程读取一个通道的数据。在每个线程中，你需要使用SDK提供的函数来打开相应的通道，设置视频参数，开始取流等操作。当需要停止取流时，你需要使用SDK提供的函数来停止取流，关闭通道等操作。

在编写多线程程序时，需要注意线程之间的同步和互斥问题。你可以使用互斥锁来保护共享资源的访问，使用条件变量来实现线程间的同步。

以下是一个简单的示例代码，用于演示如何使用海康威视SDK实现多线程读取多通道摄像头。

#include <iostream>
#include <vector>
#include <thread>
#include <mutex>
#include "HCNetSDK.h"

std::vector<LONG> g_lRealPlayHandleVec; // 保存每个通道的句柄
std::mutex g_mtx; // 互斥锁，用于保护共享资源

void RealPlayThread(int iChannel)
{
    NET_DVR_PREVIEWINFO struPreviewInfo = {0}; // 预览参数
    struPreviewInfo.lChannel = iChannel; // 设置通道号
    struPreviewInfo.dwStreamType = 0; // 主码流
    struPreviewInfo.dwLinkMode = 0; // TCP方式取流
    struPreviewInfo.bBlocked = true; // 阻塞取流

    // 打开通道
    LONG lRealPlayHandle = NET_DVR_RealPlay_V40(g_lUserID, &struPreviewInfo, nullptr, nullptr);
    if (lRealPlayHandle < 0)
    {
        std::cerr << "NET_DVR_RealPlay_V40 failed, error code: " << NET_DVR_GetLastError() << std::endl;
        return;
    }

    {
        std::lock_guard<std::mutex> lock(g_mtx);
        g_lRealPlayHandleVec.push_back(lRealPlayHandle); // 保存句柄
    }

    // 开始取流
    if (!NET_DVR_RealPlay(lRealPlayHandle, nullptr, nullptr, nullptr))
    {
        std::cerr << "NET_DVR_RealPlay failed, error code: " << NET_DVR_GetLastError() << std::endl;
        return;
    }

    // 等待停止取流信号
    while (true)
    {
        std::unique_lock<std::mutex> lock(g_mtx);
        if (g_lRealPlayHandleVec.empty())
        {
            break;
        }
        lock.unlock();
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
    }

    // 停止取流
    if (!NET_DVR_StopRealPlay(lRealPlayHandle))
    {
        std::cerr << "NET_DVR_StopRealPlay failed, error code: " << NET_DVR_GetLastError() << std::endl;
        return;
    }

    // 关闭通道
    if (!NET_DVR_CloseRealPlayHandle(lRealPlayHandle))
    {
        std::cerr << "NET_DVR_CloseRealPlayHandle failed, error code: " << NET_DVR_GetLastError() << std::endl;
        return;
    }
}

int main()
{
    // 初始化SDK
    NET_DVR_Init();
    // 登录设备
    NET_DVR_USER_LOGIN_INFO struLoginInfo = {0};
    NET_DVR_DEVICEINFO_V40 struDeviceInfo = {0};
    struLoginInfo.bUseAsynLogin = false;
    strncpy(struLoginInfo.sDeviceAddress, "192.168.1.64", NET_DVR_DEV_ADDRESS_MAX_LEN);
    strncpy(struLoginInfo.sUserName, "admin", NAME_LEN);
    strncpy(struLoginInfo.sPassword, "password", NAME_LEN);
    LONG lUserID = NET_DVR_Login_V40(&struLoginInfo, &struDeviceInfo);
    if (lUserID < 0)
    {
        std::cerr << "NET_DVR_Login_V40 failed, error code: " << NET_DVR_GetLastError() << std::endl;
        return -1;
    }

    // 创建多个线程，每个线程读取一个通道的数据
    std::vector<std::thread> threads;
    for (int iChannel = 1; iChannel <= struDeviceInfo.struDeviceV30.byChanNum; ++iChannel)
    {
        threads.emplace_back(std::thread(RealPlayThread, iChannel));
    }

    // 等待一段时间后停止取流
    std::this_thread::sleep_for(std::chrono::seconds(10));

    // 停止取流，关闭通道
    {
        std::lock_guard<std::mutex> lock(g_mtx);
        for (auto lRealPlayHandle : g_lRealPlayHandleVec)
        {
            NET_DVR_StopRealPlay(lRealPlayHandle);
            NET_DVR_CloseRealPlayHandle(lRealPlayHandle);
        }
        g_lRealPlayHandleVec.clear();
    }

    // 退出登录，释放资源
    NET_DVR_Logout(lUserID);
    NET_DVR_Cleanup();

    // 等待所有线程结束
    for (auto& thread : threads)
    {
        thread.join();
    }

    return 0;
}