轉(zhuǎn)載自:http://blog.sina.com.cn/s/blog_77c632410101awzk.html
1，RTSP連接的建立過程
RTSPServer類用于構(gòu)建一個RTSP服務(wù)器，該類同時在其內(nèi)部定義了一個RTSPClientSession類，用于處理單獨的客戶會話。
首先創(chuàng)建RTSP服務(wù)器(具體實現(xiàn)類是DynamicRTSPServer)，在創(chuàng)建過程中，先建立Socket(ourSocket)在TCP的554端口進行監(jiān)聽，然后把連接處理函數(shù)句柄
(RTSPServer:: incomingConnectionHandler)和socket句柄傳給任務(wù)調(diào)度器(taskScheduler)。
任務(wù)調(diào)度器把socket句柄放入后面select調(diào)用中用到的socket句柄集(fReadSet)中，同時將socket句柄和incomingConnectionHandler句柄關(guān)聯(lián)起來。接著，主程序開始進入任務(wù)調(diào)度器的主循環(huán)（doEventLoop），在主循環(huán)中調(diào)用系統(tǒng)函數(shù)select阻塞，等待網(wǎng)絡(luò)連接。
當(dāng)RTSP客戶端輸入(rtsp://192.168.1.109/1.mpg)連接服務(wù)器時，select返回對應(yīng)的scoket，進而根據(jù)前面保存的對應(yīng)關(guān)系，可找到對應(yīng)處理函數(shù)句柄，這里就是前面提到的incomingConnectionHandler了。在incomingConnectionHandler中創(chuàng)建了RTSPClientSession，開始對這個客戶端的會話進行處理。
具體分析如下：
DynamicRTSPServer::creatnew()：
1.調(diào)用繼承自RTPSever::setUpOurSocket：
1.調(diào)用GroupsockHelper 的setupStreamSocket創(chuàng)建一個socket連接，并綁定，
2.設(shè)置socket的發(fā)送緩存大小，
3.調(diào)用listen開始監(jiān)聽端口，設(shè)置同時最大能處理連接數(shù)LISTEN_BACKLOG_SIZE=20，如果達到這個上限則client端將收到ECONNERREFUSED的錯誤
4.測試綁定端口是否為0，為0的話重新綁定斷口，并返回系統(tǒng)自己選擇的新的端口。
5.返回建立的socket文件描述符
2.調(diào)用自己和RTPSever的構(gòu)造函數(shù)：
RTPSever構(gòu)造函數(shù):
1.用一個UsageEnvironment對象的引用構(gòu)造其父類Medium
2.設(shè)置最大等待回收連接時間reclamationTestSeconds，超過這個時間從客戶端沒有RTSP命令或者RTSP的RR包則收回其RTSPClientSession
3.建立一個HashTable（實際上是一個BasicHashTable）,fServerMediaSessions指向這個表。
4.調(diào)用參數(shù)UsageEnvironment對象env的成員,一個TaskScheduler指針?biāo)笇ο螅▽嶋H就是一個BasicTaskScheduler對象）的成員函數(shù)
turnOnBackgroundReadHandling()：
1.調(diào)用一個HandlerSet::assignHandler()創(chuàng)建一個Handler，把socketNum【此處為服務(wù)器監(jiān)聽的socket描述符】和處理函數(shù)RTSPServer::incomingConnectionHandler()，還有指向RTSPSever的指針綁定在一起。
incomingConnectionHandler作用：
1.調(diào)用accept返回服務(wù)器與客戶端連接的socket描述符
2.設(shè)置客戶端描述符為非阻塞
3.增加客戶端socket描述符的發(fā)送緩存為50*1024
4.為此客戶端隨機分配一個sessionId
5.用客戶端socket描述符clientSocket,sessionId,和客戶端地址clientAddr調(diào)用creatNewClientSession創(chuàng)建一個clientSession。
2，請求消息處理過程
上節(jié)我們談到RTSP服務(wù)器收到客戶端的連接請求，建立了RTSPClientSession類，處理單獨的客戶會話。在建立 RTSPClientSession的過程中，將新建立的socket句柄（clientSocket）和RTSP請求處理函數(shù)句柄RTSPClientSession::incomingRequestHandler傳給任務(wù)調(diào)度器，由任務(wù)調(diào)度器對兩者進行一對一關(guān)聯(lián)。當(dāng)客戶端發(fā)出 RTSP請求后，服務(wù)器主循環(huán)中的select調(diào)用返回，根據(jù)socket句柄找到對應(yīng)的incomingRequestHandler，開始消息處理。先進行消息的解析。
RTSPClientSession::RTSPClientSession()構(gòu)造函數(shù)：
1.重置請求緩存
2.調(diào)用envir().taskScheduler().turnOnBackgroundReadHandling()，這次socketnumber為客戶端socket描述符這次的處理函數(shù)是RTSPServer::RTSPClientSession::incomingRequestHandler()
RTSPServer::RTSPClientSession::incomingRequestHandler():
調(diào)用handleAlternativeRequestByte1(uint8_t requestByte)：
1.fRequestBuffer[fRequestBytesAlreadySeen] =requestByte;把請求字符放入請求緩存fRequestBuffer
2.調(diào)用handleRequestBytes(1) 處理請求緩存
handleRequestBytes(int newBytesRead):
1.調(diào)用noteLiveness()查看請求是否到期,如果服務(wù)器的reclamationTestSeconds> 0，調(diào)用taskScheduler對象的rescheduleDelayedTask函數(shù): 參數(shù)為
( fLivenessCheckTask,fOurServer.fReclamationTestSeconds*1000000,(TaskFunc*)livenessTimeoutTask, this )
其中livenessTimeoutTask()函數(shù)作用是刪除new出來的clientSession.
1.調(diào)用unscheduleDelayedTask(TaskToken&prevTask)：
從DelayQueue中刪除prevTask項， prevTask置空.
2.調(diào)用scheduleDelayedTask(int64_t microseconds,
TaskFunc* proc, void*clientData)：
1.創(chuàng)建一個DelayInterval對象timeToDelay，用microseconds初始化。
2.創(chuàng)建一個AlarmHandler對象，用proc, clientData, timeToDelay初始化
3.調(diào)用fDelayQueue.addEntry(),把這個AlarmHandler對象加入到延遲隊列中
4.返回AlarmHandler對象的token[long類型]的指針
2.如果請求的的長度超過請求緩存可讀長度fRequestBufferBytesLeft，結(jié)束這個連接。
3.找到請求消息的結(jié)尾：。
4.如果找到消息結(jié)尾，調(diào)用RTSPServer::RTSPClientSession::handleRequestBytes()[值得關(guān)注此函數(shù)]把請求字符串轉(zhuǎn)換成命令各部分包括：cmdName[方法]，urlPreSuffix[url地址]，urlSuffix[要讀取的文件名]，sceq[消息的Cseq]，否則函數(shù)返回需要繼續(xù)從連接中讀取請求。分別存入對應(yīng)的數(shù)組。
5.如果轉(zhuǎn)換成功，調(diào)用handleCmd_xxx()處理對應(yīng)的cmdName: xxx[此處實現(xiàn)了：OPTIONS，DESCRIBE，SETUP，TEARDOWN，PLAY，PAUSE，GET_PARAMETER，SET_PARAMETER]
其中PLAY，PAUSE，GET_PARAMETER，SET_PARAMETER調(diào)用handleCmd_withinSession (cmdName,urlPreSuffix, urlSuffix,cseq,(char const*)fRequestBuffer);
6.清空 RequestBuffer
比如：消息解析后，如果發(fā)現(xiàn)客戶端的請求是DESCRIBE則進入handleCmd_DESCRIBE函數(shù)。RTSP服務(wù)器收到客戶端的DESCRIBE請求后，根據(jù)請求URL(rtsp://192.168.1.109/1.mpg)，找到對應(yīng)的流媒體資源，返回響應(yīng)消息。live555中的ServerMediaSession類用來處理會話中描述，它包含多個（音頻或視頻）的子會話描述(ServerMediaSubsession)。根據(jù)客戶端請求URL的后綴(例如是1.mpg), 調(diào)用成員函數(shù) DynamicRTSPServer::lookupServerMediaSession查找對應(yīng)的流媒體信息 ServerMediaSession。（根據(jù)urlSuffix查找）。
如果ServerMediaSession不存在，查找文件是否存在，若文件不存在，則判斷ServerMediaSession （即smsExists）是否存在，如果存在則將其remove（調(diào)用removeServerMediaSession方法）。但是如果本地存在1.mpg文件，則根據(jù)文件名創(chuàng)建一個新的 ServerMediaSession（調(diào)用createNewSMS方法，若在該方法中找不到對應(yīng)的文件擴展名，則將返回NULL）。
如果通過lookupServerMediaSession返回的是NULL，則向客戶端發(fā)送響應(yīng)消息并將fSessionIsActive置為FALSE；否則，為該session組裝一個SDP描述信息（調(diào)用generateSDPDescription方法，該方法在ServerMediaSession類中），組裝完成后，生成一個RTSP URL（調(diào)用rtspURL方法，該方法在RTSPServer類中）。
在創(chuàng)建ServerMediaSession過程中，根據(jù)文件后綴.mpg，創(chuàng)建媒體MPEG-1or2的解復(fù)用器 (MPEG1or2FileServerDemux)。再由MPEG1or2FileServerDemux創(chuàng)建一個子會話描述 MPEG1or2DemuxedServerMediaSubsession。最后由ServerMediaSession完成組裝響應(yīng)消息中的SDP信息（SDP組裝過程見下面的描述），然后將響應(yīng)消息發(fā)給客戶端，完成一次消息交互。