多媒体开发之---live555的多线程支持,原本只是单线程,单通道

1)我对Live555进行了一次封装,但是Live555 是单线程的,里面定义的全局变量太多,我封装好dll库后,在客户端调用,因为多个对话框中要使用码流,我就定义了多个对象从设备端接收码流,建立多个连接,但是当一路码流退出,然后在退出另外的一路码流时,库里面出现问题,原因是Live555 里面的全局变量被破坏了!

针对上面问题:我目前的解决办法是将全局的信息隔离:

定义一个结构:

#define CLIENT_STREAM_NUM 4

class ourRTSPClient;

typedef struct  _RtspGlobal
{
 ourRTSPClient *pRtspClient;
 NetSdk *pNetSdk;
}RtspGlobal;

//
RtspGlobal struRtspGlobal[CLIENT_STREAM_NUM];

这样每一路码流对应数组中的一项,就做成多线程的了,在全局的回调函数中,根据RTSPClient*rtspClient的指针和struRtspGloball数组中的指针进行比较,如果相同,就知道是哪个流对应的连接了,比如在continueAfterSETUP函数里面建立sink时,我们可以如下判断:

for (int i=0;i<CLIENT_STREAM_NUM;i++)
  {
   if (struRtspGlobal[i].pNetSdk!=NULL)
   {
    if (struRtspGlobal[i].pRtspClient==rtspClient)
    {
     scs.subsession->sink = CRtpMediaSink::createNew(env, *scs.subsession,
      (RtpMediaSinkCallback)struRtspGlobal[i].pNetSdk->rtspDataCallback,
      (void *)&struRtspGlobal[i],RTPMEDAA_SINK_RECEIVE_BUFFER_SIZE, rtspClient->url());

break;
    }
   }

}

这样使得testRtspClient例子支持到多线程了。

2)Live555 的断网重连问题

1)重连死锁

1.1)重连时如果将解码回调线程放在NetSdk里面,使用两个Event,当接受线程结束时,发送接受线程结束的信号,然后在解码线程里面判断接收线程信号 ,如果有信号,就发送一个退出解码线程,发送一个解码结束的信号;

1.2)当超时重连时,首先Stop码流,然后Restart码流;停止码流时,将eventLoopWatchVariable=1;让数据接收线程顺利退出;同时在stop函数里面等待解码线程结束,

WaitForThreadExit(m_DecodeExitEvent);

这时会造成死锁;因为Live555是单线程的,在超时函数中需要等待本线程的结束,造成死锁;

解决办法:

1)使用单独的心跳线程来实现重连功能或者在回调数据给客户端的的解码线程里面实现重连功能;

2)网络断开判断方法 使用延迟队列来判断,初始化时候调用noteLiveness,然后每次收到Sink的一帧数据时,再次调用noteLiveness,这样如果网络断开,超时后,就能判断出来;在数据接收线程的doEventLoop后面将重连标记置位:

m_bReConnect=true;

3)断网重连的工作不能放在livenessTimeoutTask这个函数里面,不然会造成重连死锁,因为live555是单线程的;只能放在其它的线程里面实现重连;我是放在回调给客户端的解码线程里面实现重连;

void NetSdk::noteLiveness(void* clientData,UsageEnvironment& env) 
{

if (m_ReconnectTime> 0) 
 {
  env.taskScheduler().rescheduleDelayedTask(fLivenessCheckTask,m_ReconnectTime*1000000,(TaskFunc*)livenessTimeoutTask, clientData);
 }

}

void NetSdk::livenessTimeoutTask(void* clientData) {

TRACE("livenessTimeoutTask run\n");
 RtspGlobal *pRtspGlobal=(RtspGlobal *)clientData;
 pRtspGlobal->pNetSdk->fLivenessCheckTask= NULL;
 UsageEnvironment& env = pRtspGlobal->pRtspClient->envir(); // alias

pRtspGlobal->pNetSdk->RestopVideo();

}

重连线程如下:

void NetSdk::DecodeThread(void *arg)
{
 NetSdk *pThis=(NetSdk*)arg;

while (!pThis->m_bQuit)
 {

if (pThis->m_bReConnect)
  {
   //
   pThis->RestartVideo();
   pThis->m_bReConnect=false;

}else
  {
   pThis->ImageDecodeAndShow();
  }

}

SetEvent(pThis->m_DecodeExitEvent);

}

哪位有更好的办法,不妨告诉我!

http://blog.csdn.net/smilestone_322/article/details/18319867

时间: 2024-11-06 04:59:30

多媒体开发之---live555的多线程支持,原本只是单线程,单通道的相关文章

多媒体开发之--- live555 vs2010/vs2013下编译,使用,测试

Ⅰ live555简介 Live555 是一个为流媒体提供解决方案的跨平台的C++开源项目,它实现了对标准流媒体传输协议如RTP/RTCP.RTSP.SIP等的支持.Live555实现了对多种音视频编码格式的音视频数据的流化.接收和处理等支持,包括MPEG.H.263+.DV.JPEG视频和多种音频编码.同时由于良好的设计,Live555非常容易扩展对其他格式的支持.目前,Live555已经被用于多款播放器的流媒体播放功能的实现,如VLC(VideoLan).MPlayer. 该项目的源代码包括

多媒体开发之---live555 分析客户端

live555的客服端流程:建立任务计划对象--建立环境对象--处理用户输入的参数(RTSP地址)--创建RTSPClient实例--发出DESCRIBE--发出SETUP--发出PLAY--进入Loop循环接收数据--发出TEARDOWN结束连接. 可以抽成3个函数接口:rtspOpen rtspRead rtspClose. 首先我们来分析rtspOpen的过程: int rtspOpen(rtsp_object_t *p_obj, int tcpConnect) { ... ... TRA

Android多媒体开发介绍(转)

Android多媒体开发介绍 转自:http://blog.csdn.net/reiliu/article/details/9060557 一.       多媒体架构 基于第三方PacketVideo公司的OpenCORE来实现,支持所有通用的音频/视频/静态图像格式,包括:MPEG4.H.264.MP3.AAC.AMR.JPG.PNG.GIF等.从功能上分为两部分,一是音/视频的回放(PlayBack),二是音视频的纪录(Recorder). CODEC(编解码器)使用OpenMAX 1L

多媒体开发库 之 SDL 详解

SDL 简介 SDL(Simple DirectMedia Layer)是一套开放源代码的跨平台多媒体开发库,使用C语言写成.SDL提供了数种控制图像.声音.输出入的函数,让开发者只要用相同或是相似的代码就可以开发出跨多个平台(Linux.Windows.Mac OS X等)的应用软件.目前SDL多用于开发游戏.模拟器.媒体播放器等多媒体应用领域. SDL提供的功能 1. 视频 设置8bpp或更高的任意色彩深度的视频模式.如果某个模式硬件不支持,可以选择转化为另一模式. 直接写入线性的图像帧缓冲

Windows Phone - 多媒体开发

这里有一些比较好的wp源码下载:http://code.662p.com/list/14_1.html 前言在上篇文章讲述了如何新建一个Silverlight for Windows Phone的应用程序,这篇文章讲述如何在WindowsPhone上进行多媒体应用的开发.同时介绍当前Windows Phone Beta版本所支持媒体文件格式,以及讲述WindowsPhone多媒体开发的一些限制性和注意点.MediaElement控件的使用使用Silverlight开发一般的多媒体应用,使用Med

iOS开发中GCD在多线程方面的理解

GCD为Grand Central Dispatch的缩写. Grand Central Dispatch (GCD)是Apple开发的一个多核编程的较新的解决方法.在Mac OS X 10.6雪豹中首次推出,并在最近引入到了iOS4.0. GCD是一个替代诸如NSThread等技术的很高效和强大的技术.GCD完全可以处理诸如数据锁定和资源泄漏等复杂的异步编程问题. GCD可以完成很多事情,但是这里仅关注在iOS应用中实现多线程所需的一些基础知识. 在开始之前,需要理解是要提供给GCD队列的是代

iOS开发系列--并行开发其实很容易多线程

概览 大家都知道,在开发过程中应该尽可能减少用户等待时间,让程序尽可能快的完成运算.可是无论是哪种语言开发的程序最终往往转换成汇编语言进而解释成机器码来执行.但是机器码是按顺序执行的,一个复杂的多步操作只能一步步按顺序逐个执行.改变这种状况可以从两个角度出发:对于单核处理器,可以将多个步骤放到不同的线程,这样一来用户完成UI操作后其他后续任务在其他线程中,当CPU空闲时会继续执行,而此时对于用户而言可以继续进行其他操作:对于多核处理器,如果用户在UI线程中完成某个操作之后,其他后续操作在别的线程

《连载 | 物联网框架ServerSuperIO教程》-4.如开发一套设备驱动,同时支持串口和网络通讯。附:将来支持Windows 10 IOT

感谢唯笑志在分享 原博主原地址:http://www.cnblogs.com/lsjwq/ 注:ServerSuperIO有可能被移植到Windows 10 IOT上,那么将来有可能开发一套设备驱动,可以支行在服务端.嵌入式设备中,将形成完整的解决方案.       现在已经调试通过部分代码,还得需要一段时间,一般都是晚上干,时间也有限.如下图: 目       录 4.如开发一套设备驱动,同时支持串口和网络通讯... 2 4.1           概述... 2 4.2          

iOS开发中的gcd多线程tips

iOS开发中的gcd多线程tips 我们经常用到的: dispatch_async(dispatch_get_global_queue(0, 0), ^{ // 处理耗时操作的代码块 //通知主线程刷新 dispatch_async(dispatch_get_main_queue(), ^{ //回调或者说是通知主线程刷新 }); }); 其中main_queue是系统默认的串行队列,global_queue是系统默认的并行队列. 什么是串行队列(Serial)? 创建任意个数的串行队列,每个队