EasyPlayerPro Windows播放器实时流进行本地缓冲区即时回放功能实现

本文主要是介绍EasyPlayerPro Windows播放器实时流进行本地缓冲区即时回放功能实现,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

背景描述

参照国内视频监控行业监控软件,实现当前视频的即时回放功能,例如: 监控人员发现刚刚的某个视频点有可疑,就像录像回放一样,想倒回去看一下,但又不想切换到录像回放界面, 此处就体现即时回放的价值了,还可将回放片断保存为录像文件;

实现流程

  • 在视频播放时, 将收到的帧数据写入待解码播放队列;
  • 当用户切换到即时回放功能, 则停止解码当前的帧;
  • 在解码线程中修改用者ID(涉及到缓冲队列的设计);
  • 解码线程一直读取历史队列中的帧进行解码显示;
  • 当读到队列的最后一帧时,再从头开始循环;

代码实现

//即时回放处理: 将当前正在播放的缓冲队列中的数据,拷贝到即时回放队列, 然后从即时回放队列中读取数据进行回放
int ChannelManager::InstantReplayProcess(MEDIA_VIDEO_CHANNEL_OBJ_T *pMediaChannel, CONSUMER_HANDLE *handle, BUFFER_TYPE_ENUM *bufferType, int *headerSize, char *headerData, int *payloadSize, char *payloadData)
{
if (NULL == pMediaChannel)      return -1;int     ret = -1;
CONSUMER_HANDLE consumerHandle = *handle;if (NULL == pMediaChannel->pInstantReplay)      return -1;if ( pMediaChannel->pInstantReplay->instantReplay == 0x01 )
{if (NULL == pMediaChannel->pInstantReplay->bufQueueHandle)      //创建即时回放缓冲队列{//创建即时回放缓冲区int queueSize = pMediaChannel->pSourcePtr->GetQueueSize();BUFQUE_Create(&pMediaChannel->pInstantReplay->bufQueueHandle, 0, NULL, queueSize, MAX_PRE_RECORDING_SECS, 0, 1);//此处将sourcePtr中的bufqueue拷贝到 即时回放中的缓冲区CONSUMER_HANDLE consumerHandleInstantReplay = BUFQUE_RegisterConsumer(pMediaChannel->pInstantReplay->bufQueueHandle, (unsigned int)pMediaChannel, 0x00);if (NULL == consumerHandleInstantReplay){_TRACE(TRACE_LOG_DEBUG, "channel[%d]注册即时回放调用者失败.\n", pMediaChannel->id);BUFQUE_Release(&pMediaChannel->pInstantReplay->bufQueueHandle);return ret;}*handle = consumerHandleInstantReplay;consumerHandle = consumerHandleInstantReplay;pMediaChannel->pInstantReplay->consumerHandle = BUFQUE_RegisterConsumer(pMediaChannel->pInstantReplay->bufQueueHandle, (unsigned int)pMediaChannel->pInstantReplay, 0x00);  //再注册一个,用于和consumerHandleInstantReplay循环使用pMediaChannel->pInstantReplay->frameNum = 0;pMediaChannel->pInstantReplay->frameNo  = 0;BUFFER_TYPE_ENUM    bufferType = BUFFER_TYPE_UNKNOWN;CONSUMER_HANDLE     consumerHandleTmp = NULL;consumerHandleTmp = pMediaChannel->pSourcePtr->RegisterConsumer((unsigned int)&pMediaChannel->pInstantReplay, 0x01);//从当前正在播放的缓冲队列中,拷贝数据到即时回放队列if (NULL != consumerHandleTmp){int     headerSize = 0;EASY_FRAME_INFO     tmpFrameInfo;memset(&tmpFrameInfo, 0x00, sizeof(EASY_FRAME_INFO));BUFF_T      buffSource;memset(&buffSource, 0x00, sizeof(BUFF_T));BUFF_MALLOC(&buffSource, MAX_ENCODE_FRAME_SIZE);            //最大编码帧大小为MAX_ENCODE_FRAME_SIZE(1024*1024)int     writeKeyFrame = 0x00;int     bufferId = 0;do{//从队列中获取音视频和事件数据bufferType = BUFFER_TYPE_UNKNOWN;if (0 != pMediaChannel->pSourcePtr->GetSourceData(consumerHandleTmp, NULL, &bufferType, &headerSize, (char *)&tmpFrameInfo, &buffSource.bufpos, buffSource.pbuf, 0x01)){break;}//保证第一帧为视频关键帧if (writeKeyFrame == 0x01 || ( BUFFER_TYPE_VIDEO == bufferType && tmpFrameInfo.type == FRAME_TYPE_I) ){BUFQUE_AddData(pMediaChannel->pInstantReplay->bufQueueHandle, ++bufferId, bufferType, headerSize, (char *)&tmpFrameInfo, buffSource.bufpos, buffSource.pbuf);writeKeyFrame = 0x01;pMediaChannel->pInstantReplay->frameNum ++;//pMediaChannel->pInstantReplay->frameNo = 0;}}while (1);BUFF_FREE(&buffSource);pMediaChannel->pSourcePtr->UnRegisterConsumer(&consumerHandleTmp);}}//当前对即时回放队列进行录像if (pMediaChannel->pInstantReplay->recording == 0x01){pMediaChannel->pInstantReplay->recording = 0x00;InstantReplayRecording(pMediaChannel);              //即时回放录像}if (pMediaChannel->pInstantReplay->status==PLAY_SPEED_PAUSED){if (pMediaChannel->pInstantReplay->instantReplay == 0x00)       //暂停状态时, 上层已调用关闭即时回放{if (NULL != pMediaChannel->pInstantReplay->bufQueueHandle){if (NULL != consumerHandle){BUFQUE_UnRegisterConsumer(pMediaChannel->pInstantReplay->bufQueueHandle, &consumerHandle);*handle = NULL;}if (NULL != pMediaChannel->pInstantReplay->consumerHandle){BUFQUE_UnRegisterConsumer(pMediaChannel->pInstantReplay->bufQueueHandle, &pMediaChannel->pInstantReplay->consumerHandle);}BUFQUE_Release(&pMediaChannel->pInstantReplay->bufQueueHandle);}delete pMediaChannel->pInstantReplay;pMediaChannel->pInstantReplay = NULL;}return 0;}ret = BUFQUE_GetData(pMediaChannel->pInstantReplay->bufQueueHandle, consumerHandle, NULL, bufferType, headerSize, headerData, payloadSize, payloadData, 0x01);if (ret < 0){BUFQUE_CopyConsumer(pMediaChannel->pInstantReplay->bufQueueHandle, consumerHandle, pMediaChannel->pInstantReplay->consumerHandle);ret = BUFQUE_GetData(pMediaChannel->pInstantReplay->bufQueueHandle, consumerHandle, NULL, bufferType, headerSize, headerData, payloadSize, payloadData, 0x01);if (ret == 0x00)            pMediaChannel->pInstantReplay->frameNo = 1;else                pMediaChannel->pInstantReplay->frameNo = 0;}else if (ret == 0 && *bufferType==BUFFER_TYPE_VIDEO){pMediaChannel->pInstantReplay->frameNo ++;}
}
else if (pMediaChannel->pInstantReplay->instantReplay == 0x00)      //关闭即时回放
{if (NULL != pMediaChannel->pInstantReplay->bufQueueHandle){if (NULL != consumerHandle){BUFQUE_UnRegisterConsumer(pMediaChannel->pInstantReplay->bufQueueHandle, &consumerHandle);*handle = NULL;}if (NULL != pMediaChannel->pInstantReplay->consumerHandle){BUFQUE_UnRegisterConsumer(pMediaChannel->pInstantReplay->bufQueueHandle, &pMediaChannel->pInstantReplay->consumerHandle);}BUFQUE_Release(&pMediaChannel->pInstantReplay->bufQueueHandle);}delete pMediaChannel->pInstantReplay;pMediaChannel->pInstantReplay = NULL;ret = 100;
}return ret;
}

关于EasyPlayerPro

EasyPlayerPro是一款全功能的流媒体播放器,支持RTSP、RTMP、HTTP、HLS、UDP、RTP、File等多种流媒体协议播放、支持本地文件播放,支持本地抓拍、本地录像、播放旋转、多屏播放、倍数播放等多种功能特性,核心基于ffmpeg,稳定、高效、可靠、可控,支持Windows、Android、iOS三个平台,目前在多家教育、安防、行业型公司,都得到的应用,广受好评!

EasyPlayerPro:https://github.com/EasyDSS/EasyPlayerPro

点击链接加入群【EasyPlayer & EasyPlayerPro】:544917793

获取更多信息

邮件:support@easydarwin.org

EasyDarwin开源流媒体服务器:www.EasyDarwin.org

EasyDSS商用流媒体解决方案:www.EasyDSS.com

EasyNVR无插件直播方案:www.EasyNVR.com

Copyright © EasyDarwin Team 2012-2017

EasyDarwin

这篇关于EasyPlayerPro Windows播放器实时流进行本地缓冲区即时回放功能实现的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/314334

相关文章

MySQL 8 中的一个强大功能 JSON_TABLE示例详解

《MySQL8中的一个强大功能JSON_TABLE示例详解》JSON_TABLE是MySQL8中引入的一个强大功能,它允许用户将JSON数据转换为关系表格式,从而可以更方便地在SQL查询中处理J... 目录基本语法示例示例查询解释应用场景不适用场景1. ‌jsON 数据结构过于复杂或动态变化‌2. ‌性能要

Python实现终端清屏的几种方式详解

《Python实现终端清屏的几种方式详解》在使用Python进行终端交互式编程时,我们经常需要清空当前终端屏幕的内容,本文为大家整理了几种常见的实现方法,有需要的小伙伴可以参考下... 目录方法一:使用 `os` 模块调用系统命令方法二:使用 `subprocess` 模块执行命令方法三:打印多个换行符模拟

SpringBoot+EasyPOI轻松实现Excel和Word导出PDF

《SpringBoot+EasyPOI轻松实现Excel和Word导出PDF》在企业级开发中,将Excel和Word文档导出为PDF是常见需求,本文将结合​​EasyPOI和​​Aspose系列工具实... 目录一、环境准备与依赖配置1.1 方案选型1.2 依赖配置(商业库方案)二、Excel 导出 PDF

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

如何使用Lombok进行spring 注入

《如何使用Lombok进行spring注入》本文介绍如何用Lombok简化Spring注入,推荐优先使用setter注入,通过注解自动生成getter/setter及构造器,减少冗余代码,提升开发效... Lombok为了开发环境简化代码,好处不用多说。spring 注入方式为2种,构造器注入和setter

使用zip4j实现Java中的ZIP文件加密压缩的操作方法

《使用zip4j实现Java中的ZIP文件加密压缩的操作方法》本文介绍如何通过Maven集成zip4j1.3.2库创建带密码保护的ZIP文件,涵盖依赖配置、代码示例及加密原理,确保数据安全性,感兴趣的... 目录1. zip4j库介绍和版本1.1 zip4j库概述1.2 zip4j的版本演变1.3 zip4

MySQL进行数据库审计的详细步骤和示例代码

《MySQL进行数据库审计的详细步骤和示例代码》数据库审计通过触发器、内置功能及第三方工具记录和监控数据库活动,确保安全、完整与合规,Java代码实现自动化日志记录,整合分析系统提升监控效率,本文给大... 目录一、数据库审计的基本概念二、使用触发器进行数据库审计1. 创建审计表2. 创建触发器三、Java

python生成随机唯一id的几种实现方法

《python生成随机唯一id的几种实现方法》在Python中生成随机唯一ID有多种方法,根据不同的需求场景可以选择最适合的方案,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习... 目录方法 1:使用 UUID 模块(推荐)方法 2:使用 Secrets 模块(安全敏感场景)方法

Windows环境下解决Matplotlib中文字体显示问题的详细教程

《Windows环境下解决Matplotlib中文字体显示问题的详细教程》本文详细介绍了在Windows下解决Matplotlib中文显示问题的方法,包括安装字体、更新缓存、配置文件设置及编码調整,并... 目录引言问题分析解决方案详解1. 检查系统已安装字体2. 手动添加中文字体(以SimHei为例)步骤

MySQL深分页进行性能优化的常见方法

《MySQL深分页进行性能优化的常见方法》在Web应用中,分页查询是数据库操作中的常见需求,然而,在面对大型数据集时,深分页(deeppagination)却成为了性能优化的一个挑战,在本文中,我们将... 目录引言:深分页,真的只是“翻页慢”那么简单吗?一、背景介绍二、深分页的性能问题三、业务场景分析四、