基于live555的rtsp 客户端模块优化

之前发布过一个基于testRtspClient.cpp 改装的 rtsp client模块   http://blog.csdn.net/mtour/article/details/40073371

该模块支持多路rtsp流，基于这个模块做了一个录像服务



录像服务需要稳定性比较好，在测试的过程中发现 运行几个小时 1天 后 程序出现崩溃。 经过仔细排查 做了如下优化解决

更改 BasicUsageEnvironment 库的 doeventloop函数

void BasicTaskScheduler0::doEventLoop(char* watchVariable) {
// Repeatedly loop, handling readble sockets and timed events:
/*while (1) {
if (watchVariable != NULL && *watchVariable != 0) break;
SingleStep();
}*/
SingleStep();
}

在库外层进行循环操作如下

static DWORD WINAPI StartRtspEventLoop(LPVOID pUser)
{
theApp.g_scheduler=BasicTaskScheduler::createNew();
theApp.g_env = BasicUsageEnvironment::createNew(*theApp.g_scheduler);
while (theApp.g_WatchVariable)
{
//theApp.g_env->taskScheduler().doEventLoop(&eventLoopWatchVariable);
WaitForSingleObject(theApp.g_eventLoopMutex,INFINITE);
theApp.g_env->taskScheduler().doEventLoop();
ReleaseMutex(theApp.g_eventLoopMutex);
}

return 0;
}

注意加互斥锁， 在 rtspclient对象的删除也加互斥锁

void CloseClientFun(void *data)
{
if (!data)
{
return;
}
RTSPClient* pClient=(RTSPClient*)data;
shutdownStream(pClient,0);
}

int CStreamItem::Close()
{
if (m_pRtspClient)
{
m_pRtspClient->m_lpStreamCallBack=NULL;
m_pRtspClient->m_pUserData=NULL;

WaitForSingleObject(theApp.g_eventLoopMutex,INFINITE);
theApp.g_scheduler->scheduleDelayedTask(1000*1000, CloseClientFun, m_pRtspClient);
ReleaseMutex(theApp.g_eventLoopMutex);

m_pRtspClient=NULL;
}
return 0;
}
客户端打开的代码 增加互斥锁

WaitForSingleObject(theApp.g_eventLoopMutex,INFINITE);
m_pRtspClient->sendDescribeCommand(continueAfterDESCRIBE);
ReleaseMutex(theApp.g_eventLoopMutex);

引起报错的原因归根结底还是 Live555 单线程机制