解决QT中使用opencv打开Rtsp流网络异常时无法自动重连

1.项目背景

在QT中，在打开视频流时使用cv::VideoCapture类操作，但是在实践过程中偶尔发现存在网络异常时，使用open函数打开会导致流程卡住导致视频流卡住的问题。在网上查找资料发现该函数没有设置超时等待的方式，当网络异常时会直接影响用户体验。因此在发现该问题后提出了一下的解决方案。

2.解决思路

①在调用open函数之前通过ping或telnet操作判断网络是否异常；

②网络正常且端口正常时通过线程池的方式进行连接

③判断上一次重连时间与当前时间是否超过1分钟，超过1分钟则立即重连

3.代码实现

bool openVideo(cv::VideoCapture *cap){
    qDebug() <<("视频线程数量为["+QString::number(currentLoopCount)+"]");
    if(currentLoopCount > maxLoopCount){
        try{
            qDebug() <<("开始初始化视频");
            bool suc = false;
            qDebug()<<QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss|zzz") << "播放初始化！";
            if (m_rtsp.contains("localhost:camera")){
                suc = cap->open(0); //打开本地摄像头
            }else{
                if(vedioPort>0){
                    if(Telnet(vedionUrl,vedioPort)){
                        currentLoopCount--;
                        m_timeSpan.restart();
                        return false;
                    }
                }
                if(Ping(vedionUrl)){
                    qDebug() <<(vedionUrl + " 网络异常[线程]");
                    currentLoopCount--;
                    m_timeSpan.restart();
                    return false;
                }
                suc = cap->open(m_rtsp.toStdString()); //打开网络流地址
            }
            if (!suc){
                qDebug() <<("打开视频失败");
                qDebug()<<QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss|zzz") << "播放失败！";
                m_timeSpan.restart();
                return false;
            }
            qDebug()<<QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss|zzz") << "播放成功！";
            m_fps= cap->get(CV_CAP_PROP_FPS);
            qDebug() << "video rate:" << m_fps;
            qDebug()<< "m_fps is "+QString::number(m_fps);
            if(m_fps >0 && m_fps < 1000){//帧率有效
                m_slpTime = 1000/m_fps;
            }

            m_timeSpan.restart();
            return true;

        }catch(cv::Exception &e){
            qDebug() << "openVideo catched error:" << e.what();
            return  false;
        }
    }else{
        QtConcurrent::run([=](){
            currentLoopCount++;
            try{
                bool suc = false;
                qDebug()<<QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss|zzz") << "播放初始化！";
                if (m_rtsp.contains("localhost:camera")){
                    suc = cap->open(0); //打开本地摄像头
                }else{
                    if(vedioPort>0){
                        if(Telnet(vedionUrl,vedioPort)){
                            qDebug() <<(vedionUrl + " 网络异常[线程]");
                            currentLoopCount--;
                            m_timeSpan.restart();
                            return false;
                        }
                    }
                    if(Ping(vedionUrl)){
                        qDebug() <<(vedionUrl + " 网络异常[线程]");
                        currentLoopCount--;
                        m_timeSpan.restart();
                        return false;
                    }
                    suc = cap->open(m_rtsp.toStdString()); //打开网络流地址
                }
                if (!suc){
                    qDebug()<<QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss|zzz") << "播放失败！";
                    qDebug() <<("打开视频失败[线程]");
                    m_timeSpan.restart();
                    currentLoopCount--;
                    return false;
                }
                qDebug()<<QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss|zzz") << "播放成功！";
                qDebug() <<("打开视频成功[线程]");
                m_fps= cap->get(CV_CAP_PROP_FPS);
                qDebug() << "video rate:" << m_fps;
                qDebug() <<("m_fps is "+QString::number(m_fps));
                if(m_fps >0 && m_fps < 1000){//帧率有效
                    m_slpTime = 1000/m_fps;
                }

                m_timeSpan.restart();
                currentLoopCount--;
                qDebug() <<("视频操作完成[线程]");
                return true;

            }catch(cv::Exception &e){
                qDebug() << "openVideo catched error:" << e.what();
                currentLoopCount--;
                m_timeSpan.restart();
                return  false;
            }
        });
        return true;
    }
}

?