青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

牽著老婆滿街逛

嚴以律己,寬以待人. 三思而后行.
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

1RTSP連接的建立過程
    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[此處實現了:OPTIONSDESCRIBESETUPTEARDOWNPLAYPAUSEGET_PARAMETERSET_PARAMETER]
               
其中PLAYPAUSEGET_PARAMETERSET_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 楊粼波 閱讀(1963) 評論(0)  編輯 收藏 引用

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            亚洲电影免费观看高清完整版在线 | 亚洲亚洲精品三区日韩精品在线视频| 久久人人爽国产| 久久精品国产99国产精品| 久久九九国产精品怡红院| 久久露脸国产精品| 欧美激情亚洲自拍| 一本色道久久综合精品竹菊 | 亚洲人成在线观看网站高清| 亚洲激情视频在线播放| 一区二区三区视频在线观看| 午夜激情亚洲| 两个人的视频www国产精品| 欧美日韩国产大片| 国产亚洲人成a一在线v站| 一区在线视频| 亚洲视频免费在线观看| 久久久久国内| 99国产精品一区| 久久国产欧美精品| 欧美日韩国产成人| 国产一区二区三区日韩| 中国日韩欧美久久久久久久久| 欧美在线啊v一区| 亚洲日本成人女熟在线观看| 亚洲专区免费| 欧美精品久久久久久| 国产婷婷色一区二区三区在线 | 午夜视频在线观看一区二区| 久久亚洲综合色| 亚洲伊人网站| 欧美在线播放一区| 免费不卡视频| 午夜激情综合网| 欧美日本三级| 欧美劲爆第一页| 久久先锋影音| 欧美午夜免费电影| 亚洲国产成人在线播放| 欧美有码视频| 亚洲另类视频| 欧美电影在线| 亚洲国产美女久久久久| 久久精品在线| 亚洲一区二区三区影院| 欧美日韩亚洲成人| 99精品视频免费在线观看| 久久在线播放| 久久国产精品久久国产精品| 国产精品一二三四| 亚洲综合首页| 一区二区不卡在线视频 午夜欧美不卡在 | 亚洲一区二区三区在线观看视频| 嫩草影视亚洲| 亚洲国产另类 国产精品国产免费| 欧美一级专区免费大片| 亚洲视频欧美在线| 国产精品扒开腿做爽爽爽软件| 亚洲免费播放| 亚洲精选91| 欧美性生交xxxxx久久久| 在线亚洲伦理| 在线视频一区二区| 亚洲视频精品在线| 国产精品看片你懂得| 亚洲欧美一区二区视频| 亚洲一区二区在线观看视频| 国产精品美女www爽爽爽视频| 亚洲欧美日本国产有色| 亚洲综合三区| 国内精品嫩模av私拍在线观看| 久久成人免费电影| 欧美淫片网站| 亚洲欧洲综合| 夜夜爽夜夜爽精品视频| 国产精品女主播一区二区三区| 亚洲淫片在线视频| 亚洲欧美日韩一区二区三区在线观看 | 欧美高清视频www夜色资源网| 久久福利视频导航| 一色屋精品视频免费看| 亚洲精品1234| 国产精品入口夜色视频大尺度| 欧美一级免费视频| 久久香蕉国产线看观看网| 最新国产乱人伦偷精品免费网站 | 久久久www| 亚洲欧洲在线一区| 亚洲伊人观看| 亚洲国产日韩欧美综合久久| 亚洲美女区一区| 国产亚洲成av人在线观看导航| 蜜桃av噜噜一区二区三区| 欧美日本在线观看| 久久久www成人免费精品| 免费在线日韩av| 欧美在线精品一区| 欧美aⅴ一区二区三区视频| 亚洲欧美bt| 免费亚洲一区| 久久精品在这里| 欧美日韩一区二区三区四区五区| 久久九九国产精品| 欧美午夜精品电影| 欧美ab在线视频| 国产精品一国产精品k频道56| 欧美二区乱c少妇| 国产精品一区二区三区四区| 欧美国产一区二区在线观看 | 香蕉成人久久| 欧美激情视频在线播放| 久久综合五月天婷婷伊人| 欧美日韩一区免费| 欧美不卡一卡二卡免费版| 国产精品视频| 亚洲精品免费一二三区| 在线观看视频日韩| 欧美一区二区精品| 亚洲影视综合| 欧美日韩国产色综合一二三四 | 亚洲伦伦在线| 亚洲免费一区二区| 日韩亚洲国产欧美| 久久精品国产免费| 亚洲欧美国产高清va在线播| 欧美成人免费在线视频| 美女图片一区二区| 国内精品久久久久久影视8| 久久精品国产96久久久香蕉| 国产亚洲精品v| 亚洲欧美在线播放| 夜夜嗨av一区二区三区四区| 巨乳诱惑日韩免费av| 久久―日本道色综合久久| 国产美女精品免费电影| 亚洲一区视频在线观看视频| 亚洲伊人久久综合| 国产精品视频xxx| 亚洲欧美日韩区| 久久精品国产免费观看| 国产日韩欧美三区| 久久疯狂做爰流白浆xx| 久久综合伊人77777| 一区一区视频| 噜噜爱69成人精品| 亚洲成人资源网| 亚洲看片网站| 欧美日韩亚洲在线| 亚洲午夜免费视频| 欧美与欧洲交xxxx免费观看| 国产午夜精品视频| 久久精品国产精品亚洲综合| 美女在线一区二区| 亚洲精品欧美| 欧美性做爰猛烈叫床潮| 亚洲在线观看免费| 猫咪成人在线观看| 亚洲精品视频免费在线观看| 欧美日韩免费| 亚洲欧美日韩国产综合| 免费不卡中文字幕视频| 日韩亚洲精品在线| 国产精品久久久久久久久动漫| 亚洲欧美日韩中文视频| 女仆av观看一区| 亚洲视频中文| 黑人巨大精品欧美一区二区| 欧美成人午夜剧场免费观看| aa级大片欧美三级| 久久麻豆一区二区| 一本色道久久99精品综合| 国产日韩视频一区二区三区| 久久亚洲精品网站| 一区二区三区久久网| 乱人伦精品视频在线观看| 亚洲精品久久久蜜桃| 国产精品国产三级国产aⅴ无密码| 欧美亚洲三级| 日韩亚洲国产精品| 久久蜜桃资源一区二区老牛| aaa亚洲精品一二三区| 国产一区二区激情| 欧美日韩亚洲高清| 玖玖玖国产精品| 亚洲欧美国内爽妇网| 亚洲高清视频在线| 久久av一区二区三区亚洲| 日韩视频一区二区三区在线播放免费观看 | 欧美插天视频在线播放| 亚洲欧美日韩天堂一区二区| 亚洲高清视频在线观看| 久久久久久国产精品一区| 一区二区三区精品久久久| 亚洲美女在线视频| 欧美视频在线免费看| 久久五月婷婷丁香社区| 亚洲午夜精品久久久久久浪潮| 欧美成人在线免费视频| 久久精品中文字幕免费mv| 午夜精品福利在线|