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