• <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,DESCRIBE,SETUP,TEARDOWNPLAY,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)  編輯 收藏 引用

            狠狠色丁香久久婷婷综合五月| 久久最近最新中文字幕大全 | 品成人欧美大片久久国产欧美...| 91超碰碰碰碰久久久久久综合| 日本精品久久久久久久久免费| 久久久国产精华液| 国产ww久久久久久久久久| 精品久久久久成人码免费动漫| 久久99亚洲网美利坚合众国| 久久久久无码中| 97热久久免费频精品99| 午夜视频久久久久一区| 欧美伊香蕉久久综合类网站| 亚洲AV成人无码久久精品老人| 久久久久亚洲AV成人网人人软件| 色综合久久中文字幕无码| 久久99热这里只有精品国产 | 伊人久久精品无码二区麻豆| 久久最新精品国产| 久久亚洲精品中文字幕| 18禁黄久久久AAA片| 精品久久久久久国产牛牛app | 久久久久国产精品| 人妻精品久久久久中文字幕69 | 中文字幕乱码久久午夜| 三级韩国一区久久二区综合 | 亚洲午夜久久久久久噜噜噜| 久久伊人中文无码| 国产精品99久久久久久猫咪| 97久久精品无码一区二区| 中文精品久久久久人妻不卡| 久久青青草视频| 亚洲欧洲中文日韩久久AV乱码| 久久av免费天堂小草播放| 99久久人人爽亚洲精品美女| 久久精品国产精品亚洲精品| 97r久久精品国产99国产精| 久久国产精品无码一区二区三区| 久久亚洲美女精品国产精品| 久久婷婷国产综合精品| 97久久天天综合色天天综合色hd |