• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            牽著老婆滿街逛

            嚴以律己,寬以待人. 三思而后行.
            GMail/GTalk: yanglinbo#google.com;
            MSN/Email: tx7do#yahoo.com.cn;
            QQ: 3 0 3 3 9 6 9 2 0 .

            live555學習之RTSP連接建立以及請求消息處理過程

            轉載自:http://blog.sina.com.cn/s/blog_77c632410101awzk.html

            1,RTSP連接的建立過程
                RTSPServer
            類用于構建一個RTSP服務器,該類同時在其內部定義了一個RTSPClientSession類,用于處理單獨的客戶會話。
               
             首先創建RTSP服務器(具體實現類是DynamicRTSPServer),在創建過程中,先建立Socket(ourSocket)TCP554端口進行監聽,然后把連接處理函數句柄 

            (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命令或者RTSPRR包則收回其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,DESCRIBESETUP,TEARDOWN,PLAY,PAUSE,GET_PARAMETERSET_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組裝過程見下面的描述),然后將響應消息發給客戶端,完成一次消息交互。

            posted on 2013-09-10 04:05 楊粼波 閱讀(1958) 評論(0)  編輯 收藏 引用

            色综合久久久久综合99| 久久久久久久综合狠狠综合| 99精品久久久久久久婷婷| 一本色道久久88精品综合| 精品国产99久久久久久麻豆| 国产三级观看久久| 99精品久久久久久久婷婷| 国产精品久久久久蜜芽| 伊人久久国产免费观看视频| 久久久久九九精品影院| 国产精品久久久天天影视香蕉| 亚洲综合久久综合激情久久 | 亚洲va中文字幕无码久久| 一本色道久久HEZYO无码| …久久精品99久久香蕉国产| 亚洲AV日韩AV天堂久久| 久久99中文字幕久久| 欧美精品一区二区久久| 中文字幕乱码久久午夜| 日本免费久久久久久久网站| 久久精品国产亚洲麻豆| 亚洲国产日韩综合久久精品| 精品久久亚洲中文无码| 国产精品久久久久…| 日本精品久久久久久久久免费| 99久久精品免费看国产一区二区三区 | 99久久精品国产综合一区| 国产亚州精品女人久久久久久 | 精品久久人人爽天天玩人人妻| 亚洲国产成人久久笫一页| 蜜臀久久99精品久久久久久小说| www.久久热| 亚洲综合熟女久久久30p| 亚洲国产天堂久久综合网站| 久久久久久毛片免费看| 国内精品久久久久影院一蜜桃 | 久久综合九色综合网站| 久久免费大片| 久久久久一级精品亚洲国产成人综合AV区 | 久久国产成人| 婷婷久久综合九色综合绿巨人|