海康大华摄像头高起播低延时RTSP网页无插件流媒体播放器EasyPlayer-RTSP-Win录像和抓图实现线程优化方案分享

本文主要是介绍海康大华摄像头高起播低延时RTSP网页无插件流媒体播放器EasyPlayer-RTSP-Win录像和抓图实现线程优化方案分享,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

EasyPlayer-RTSP播放器是一套RTSP专用的播放器,包括有:Windows(支持IE插件,npapi插件)、Android、iOS三个平台,是由青犀TSINGSEE开放平台开发和维护的区别于市面上大部分的通用播放器,EasyPlayer-RTSP系列从2014年初发展至今得到了各行各业(尤其是安防行业)的广泛应用,其主要原因是EasyPlayer-RTSP更加精炼、更加专注,具备低延时和高RTSP协议兼容性。

EasyPlayerRTSP.png

EasyPlayer-RTSP-Win录像和抓图实现线程优化

测试发现,通过EasyPlayer-RTSP-Win拉取网络摄像机的流, 其音频可能是G711,G726等,而写MP4或者转推RTMP等都不支持这些音频格式,那么我们就需要将其音频转码成AAC,可以使用libEasyAACEncoder库进行转码,然后写MP4或者推送;

然而,在实际应用中,我们发现转码过程其实还是比较耗时的,它甚至会导致解码线程来不及从而使直播延时增大,所以,我们采用队列缓存+线程的方式来优化录像和抓图。

实现如下:

1、录像优化
1> 开启录像

if (pThread->manuRecording == 0x01 && NULL==pThread->m_pMP4Writer && frameinfo.type==EASY_SDK_VIDEO_FRAME_I)//开启录制{//EnterCriticalSection(&pThread->critRecQueue);				if (!pThread->m_pMP4Writer){pThread->m_pMP4Writer = new EasyMP4Writer();}unsigned int timestamp = (unsigned int)time(NULL);time_t tt = timestamp;struct tm *_time = localtime(&tt);char szTime[64] = {0,};strftime(szTime, 32, "%Y%m%d%H%M%S", _time);int nRecordPathLen = strlen(pThread->manuRecordingPath);if (nRecordPathLen==0 || (pThread->manuRecordingPath[nRecordPathLen-1] != '/' && pThread->manuRecordingPath[nRecordPathLen-1] != '\\') ){pThread->manuRecordingPath[nRecordPathLen] = '/';}char sFileName[512] = {0,};sprintf(sFileName, "%sch%d_%s.mp4", pThread->manuRecordingPath, pThread->channelId, szTime);if (!pThread->m_pMP4Writer->CreateMP4File(sFileName, ZOUTFILE_FLAG_FULL)){delete pThread->m_pMP4Writer;pThread->m_pMP4Writer = NULL;//return -1;}		else{}//LeaveCriticalSection(&pThread->critRecQueue);}

2> 录像数据写缓存

					if (NULL != pThread->pRecAVQueue){SSQ_AddData(pThread->pRecAVQueue, channelid, MEDIA_TYPE_VIDEO, (MEDIA_FRAME_INFO*)&frameinfo, pbuf);}

3> 录像线程处理

LPTHREAD_START_ROUTINE CChannelManager::_lpRecordThread( LPVOID _pParam )
{PLAY_THREAD_OBJ *pThread = (PLAY_THREAD_OBJ*)_pParam;if (NULL == pThread)			return 0;pThread->recordThread.flag	=	0x02;#ifdef _DEBUG_TRACE("录像线程[%d]已启动. ThreadId:%d ...\n", pThread->channelId, GetCurrentThreadId());
#endifEasyAACEncoder_Handle m_pAACEncoderHandle = NULL;int buf_size = 1024*1024;char *pbuf = new char[buf_size];if (NULL == pbuf){pThread->recordThread.flag	=	0x00;return 0;}char* m_pAACEncBufer = new char[buf_size];memset(m_pAACEncBufer, 0x00, buf_size);//#define AVCODEC_MAX_AUDIO_FRAME_SIZE	(192000)
#define AVCODEC_MAX_AUDIO_FRAME_SIZE	(64000)int audbuf_len = (AVCODEC_MAX_AUDIO_FRAME_SIZE * 3) / 2;unsigned char *audio_buf = new unsigned char[audbuf_len+1];memset(audio_buf, 0x00, audbuf_len);MEDIA_FRAME_INFO frameinfo;unsigned int channelid = 0;unsigned int mediatype = 0;while (1){if (pThread->recordThread.flag == 0x03)		break;int ret = SSQ_GetData(pThread->pRecAVQueue, &channelid, &mediatype, &frameinfo, pbuf);if (ret < 0){_VS_BEGIN_TIME_PERIOD(1);__VS_Delay(1);_VS_END_TIME_PERIOD(1);continue;}long long nTimeStamp = frameinfo.timestamp_sec*1000+frameinfo.timestamp_usec/1000;byte*pdata=NULL;int datasize=0;bool keyframe=false;try{	if (mediatype == MEDIA_TYPE_VIDEO){pdata = (byte*)pbuf;//获取到的编码数据datasize = frameinfo.length;int nVideoWidth     = frameinfo.width;int nVideoHeight    = frameinfo.height;keyframe = frameinfo.type==EASY_SDK_VIDEO_FRAME_I?true:false;if (pThread->m_pMP4Writer){pThread->m_pMP4Writer->WriteMp4File((unsigned char*)pdata, datasize, keyframe,  nTimeStamp, nVideoWidth, nVideoHeight);}}else //音频{pdata = (byte*)pbuf;//获取到的编码数据datasize = frameinfo.length;int bits_per_sample = frameinfo.bits_per_sample;int channels = frameinfo.channels;int sampleRate = frameinfo.sample_rate;if (EASY_SDK_AUDIO_CODEC_G711U == frameinfo.codec|| EASY_SDK_AUDIO_CODEC_G726 == frameinfo.codec || EASY_SDK_AUDIO_CODEC_G711A == frameinfo.codec ) {if (!m_pAACEncoderHandle){InitParam initParam;initParam.u32AudioSamplerate=frameinfo.sample_rate;initParam.ucAudioChannel=frameinfo.channels;initParam.u32PCMBitSize=frameinfo.bits_per_sample;if (frameinfo.codec == EASY_SDK_AUDIO_CODEC_G711U){initParam.ucAudioCodec = Law_ULaw;} else if (frameinfo.codec == EASY_SDK_AUDIO_CODEC_G726){initParam.ucAudioCodec = Law_G726;}else if (frameinfo.codec == EASY_SDK_AUDIO_CODEC_G711A){initParam.ucAudioCodec = Law_ALaw;}m_pAACEncoderHandle = Easy_AACEncoder_Init( initParam);}unsigned int out_len = 0;int nRet = Easy_AACEncoder_Encode(m_pAACEncoderHandle, (unsigned char*)pbuf, frameinfo.length, (unsigned char*)m_pAACEncBufer, &out_len) ;if (nRet>0&&out_len>0){pdata = (byte*)m_pAACEncBufer;datasize = out_len;frameinfo.codec = EASY_SDK_AUDIO_CODEC_AAC;} else{continue;}}if (pThread->m_pMP4Writer){if (pThread->m_pMP4Writer->CanWrite()){pThread->m_pMP4Writer->WriteAACToMp4File((unsigned char*)pdata, datasize, nTimeStamp, sampleRate, channels, bits_per_sample);}}}}catch (...){continue;}}pThread->recordThread.flag	=	0x00;#ifdef _DEBUG_TRACE("录像线程[%d]已退出 ThreadId:%d.\n", pThread->channelId, GetCurrentThreadId());
#endifreturn 0;
}

2、抓图原理同录像,唯一区别是直接数据传入线程,进行jpg编码存文件,详见EasyPlayer-RTSP的代码(这个代码大部分是开源的)。

这篇关于海康大华摄像头高起播低延时RTSP网页无插件流媒体播放器EasyPlayer-RTSP-Win录像和抓图实现线程优化方案分享的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/930874

相关文章

Python实战之SEO优化自动化工具开发指南

《Python实战之SEO优化自动化工具开发指南》在数字化营销时代,搜索引擎优化(SEO)已成为网站获取流量的重要手段,本文将带您使用Python开发一套完整的SEO自动化工具,需要的可以了解下... 目录前言项目概述技术栈选择核心模块实现1. 关键词研究模块2. 网站技术seo检测模块3. 内容优化分析模

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp

Java+AI驱动实现PDF文件数据提取与解析

《Java+AI驱动实现PDF文件数据提取与解析》本文将和大家分享一套基于AI的体检报告智能评估方案,详细介绍从PDF上传、内容提取到AI分析、数据存储的全流程自动化实现方法,感兴趣的可以了解下... 目录一、核心流程:从上传到评估的完整链路二、第一步:解析 PDF,提取体检报告内容1. 引入依赖2. 封装

Java实现复杂查询优化的7个技巧小结

《Java实现复杂查询优化的7个技巧小结》在Java项目中,复杂查询是开发者面临的“硬骨头”,本文将通过7个实战技巧,结合代码示例和性能对比,手把手教你如何让复杂查询变得优雅,大家可以根据需求进行选择... 目录一、复杂查询的痛点:为何你的代码“又臭又长”1.1冗余变量与中间状态1.2重复查询与性能陷阱1.

Python内存优化的实战技巧分享

《Python内存优化的实战技巧分享》Python作为一门解释型语言,虽然在开发效率上有着显著优势,但在执行效率方面往往被诟病,然而,通过合理的内存优化策略,我们可以让Python程序的运行速度提升3... 目录前言python内存管理机制引用计数机制垃圾回收机制内存泄漏的常见原因1. 循环引用2. 全局变

python 线程池顺序执行的方法实现

《python线程池顺序执行的方法实现》在Python中,线程池默认是并发执行任务的,但若需要实现任务的顺序执行,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋... 目录方案一:强制单线程(伪顺序执行)方案二:按提交顺序获取结果方案三:任务间依赖控制方案四:队列顺序消

Redis实现分布式锁全过程

《Redis实现分布式锁全过程》文章介绍Redis实现分布式锁的方法,包括使用SETNX和EXPIRE命令确保互斥性与防死锁,Redisson客户端提供的便捷接口,以及Redlock算法通过多节点共识... 目录Redis实现分布式锁1. 分布式锁的基本原理2. 使用 Redis 实现分布式锁2.1 获取锁

Linux实现查看某一端口是否开放

《Linux实现查看某一端口是否开放》文章介绍了三种检查端口6379是否开放的方法:通过lsof查看进程占用,用netstat区分TCP/UDP监听状态,以及用telnet测试远程连接可达性... 目录1、使用lsof 命令来查看端口是否开放2、使用netstat 命令来查看端口是否开放3、使用telnet

使用SpringBoot+InfluxDB实现高效数据存储与查询

《使用SpringBoot+InfluxDB实现高效数据存储与查询》InfluxDB是一个开源的时间序列数据库,特别适合处理带有时间戳的监控数据、指标数据等,下面详细介绍如何在SpringBoot项目... 目录1、项目介绍2、 InfluxDB 介绍3、Spring Boot 配置 InfluxDB4、I

基于Java和FFmpeg实现视频压缩和剪辑功能

《基于Java和FFmpeg实现视频压缩和剪辑功能》在视频处理开发中,压缩和剪辑是常见的需求,本文将介绍如何使用Java结合FFmpeg实现视频压缩和剪辑功能,同时去除数据库操作,仅专注于视频处理,需... 目录引言1. 环境准备1.1 项目依赖1.2 安装 FFmpeg2. 视频压缩功能实现2.1 主要功