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

相关文章

基于Python实现一个图片拆分工具

《基于Python实现一个图片拆分工具》这篇文章主要为大家详细介绍了如何基于Python实现一个图片拆分工具,可以根据需要的行数和列数进行拆分,感兴趣的小伙伴可以跟随小编一起学习一下... 简单介绍先自己选择输入的图片,默认是输出到项目文件夹中,可以自己选择其他的文件夹,选择需要拆分的行数和列数,可以通过

Python中将嵌套列表扁平化的多种实现方法

《Python中将嵌套列表扁平化的多种实现方法》在Python编程中,我们常常会遇到需要将嵌套列表(即列表中包含列表)转换为一个一维的扁平列表的需求,本文将给大家介绍了多种实现这一目标的方法,需要的朋... 目录python中将嵌套列表扁平化的方法技术背景实现步骤1. 使用嵌套列表推导式2. 使用itert

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

在Linux中改变echo输出颜色的实现方法

《在Linux中改变echo输出颜色的实现方法》在Linux系统的命令行环境下,为了使输出信息更加清晰、突出,便于用户快速识别和区分不同类型的信息,常常需要改变echo命令的输出颜色,所以本文给大家介... 目python录在linux中改变echo输出颜色的方法技术背景实现步骤使用ANSI转义码使用tpu

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库:CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

golang版本升级如何实现

《golang版本升级如何实现》:本文主要介绍golang版本升级如何实现问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录golanwww.chinasem.cng版本升级linux上golang版本升级删除golang旧版本安装golang最新版本总结gola

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具

Mysql实现范围分区表(新增、删除、重组、查看)

《Mysql实现范围分区表(新增、删除、重组、查看)》MySQL分区表的四种类型(范围、哈希、列表、键值),主要介绍了范围分区的创建、查询、添加、删除及重组织操作,具有一定的参考价值,感兴趣的可以了解... 目录一、mysql分区表分类二、范围分区(Range Partitioning1、新建分区表:2、分

MySQL 定时新增分区的实现示例

《MySQL定时新增分区的实现示例》本文主要介绍了通过存储过程和定时任务实现MySQL分区的自动创建,解决大数据量下手动维护的繁琐问题,具有一定的参考价值,感兴趣的可以了解一下... mysql创建好分区之后,有时候会需要自动创建分区。比如,一些表数据量非常大,有些数据是热点数据,按照日期分区MululbU