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

牽著老婆滿街逛

嚴以律己,寬以待人. 三思而后行.
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 楊粼波 閱讀(1971) 評論(0)  編輯 收藏 引用


只有注冊用戶登錄后才能發表評論。
網站導航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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国产精品国产精品久久| 欧美韩国日本一区| 久久亚洲美女| 亚洲国产天堂久久综合网| 欧美黄色大片网站| 一本色道**综合亚洲精品蜜桃冫| 亚洲图片欧洲图片av| 国产精品丝袜白浆摸在线| 午夜精品成人在线视频| 久久中文在线| 亚洲精品视频在线播放| 国产精品久久久久久久久久ktv | 一本色道久久综合狠狠躁的推荐| 亚洲伊人观看| 红桃视频国产精品| 欧美精品九九99久久| 一本久道久久综合狠狠爱| 欧美专区在线观看| 亚洲福利在线观看| 欧美日韩日本网| 午夜精彩国产免费不卡不顿大片| 久久久精品一区| 亚洲免费观看高清完整版在线观看熊| 欧美涩涩视频| 美女久久一区| 亚洲一区二区三区涩| 欧美高清在线一区二区| 亚洲最新合集| 黄色日韩网站视频| 国产精品高潮呻吟久久av黑人| 久久aⅴ国产紧身牛仔裤| 亚洲免费观看高清完整版在线观看| 久久精品在线免费观看| 亚洲国产高清一区| 国产麻豆91精品| 欧美精品高清视频| 午夜精品婷婷| 日韩视频国产视频| 欧美高清在线观看| 久久精品国产第一区二区三区| 亚洲精品看片| 在线观看不卡av| 国产精一区二区三区| 欧美日韩国产在线看| 麻豆精品传媒视频| 久久精品国产亚洲aⅴ| 亚洲私人影院在线观看| 亚洲国产影院| 久久亚洲国产精品日日av夜夜| 亚洲欧美日韩另类| 一区二区三区国产在线观看| 亚洲人成艺术| 亚洲国产成人精品久久久国产成人一区| 国产老女人精品毛片久久| 欧美日韩国产成人在线| 欧美高清视频一区| 美女性感视频久久久| 久久久久久久一区二区三区| 午夜精品福利一区二区蜜股av| 亚洲精品一区二区三区在线观看| 欧美国产日韩一区二区| 免费在线观看成人av| 久久婷婷激情| 久久五月激情| 玖玖玖国产精品| 久久久久久亚洲综合影院红桃| 欧美一区二区三区日韩| 亚洲一区一卡| 香港成人在线视频| 欧美一区二区高清在线观看| 香蕉久久a毛片| 欧美一区综合| 久久精品官网| 免费不卡在线视频| 欧美成人蜜桃| 亚洲风情亚aⅴ在线发布| 欧美国产成人精品| 欧美人与性动交cc0o| 欧美激情精品| 欧美午夜精品久久久久免费视| 在线亚洲电影| 亚洲最新合集| 欧美在线91| 亚洲一区欧美激情| 午夜在线播放视频欧美| 久久av一区二区三区| 久久成人18免费观看| 久久久久九九九| 欧美va亚洲va香蕉在线| 亚洲精品国产精品国自产观看浪潮 | 美女亚洲精品| 欧美激情精品久久久久久免费印度| 欧美激情bt| 一区二区欧美激情| 午夜视频一区在线观看| 久久久久久穴| 欧美日本中文| 国产女同一区二区| 久久在线精品| 欧美韩日一区| 欧美大片在线看免费观看| 亚洲福利视频网站| 亚洲无限av看| 久久精品视频免费播放| 久久9热精品视频| 久久综合国产精品| 亚洲人午夜精品免费| 亚洲免费在线| 蜜桃av一区二区三区| 欧美性猛交xxxx免费看久久久| 韩国视频理论视频久久| 99精品视频一区| 久久久久久午夜| 亚洲欧洲日本一区二区三区| 亚洲欧美在线另类| 欧美国产日韩一区| 国产欧美日韩视频| 日韩五码在线| 久久久久**毛片大全| 亚洲美女毛片| 久久午夜羞羞影院免费观看| 欧美日本一道本| 国语对白精品一区二区| 在线亚洲免费| 美女主播视频一区| 亚洲欧美中文日韩v在线观看| 欧美aaaaaaaa牛牛影院| 国产亚洲一区在线播放| 亚洲视频在线观看视频| 欧美高清视频| 久久国产综合精品| 国产精品人人爽人人做我的可爱| 亚洲人人精品| 裸体歌舞表演一区二区| 亚洲午夜一区| 欧美日韩精品免费观看视一区二区 | 欧美性做爰猛烈叫床潮| 亚洲福利视频二区| 久久久久久尹人网香蕉| 中文在线资源观看网站视频免费不卡| 老司机亚洲精品| 国产在线视频欧美| 亚洲一区二区在线免费观看视频 | 欧美日韩一二区| 亚洲国产毛片完整版| 久久精品国产亚洲aⅴ| 亚洲香蕉网站| 欧美三级午夜理伦三级中文幕| 亚洲国产专区| 欧美第一黄网免费网站| 久久精品亚洲国产奇米99| 国产精品免费在线| 亚洲一区一卡| 一区二区三区国产在线| 欧美日韩亚洲不卡| 亚洲作爱视频| 亚洲麻豆一区| 欧美久久久久久久久| 亚洲国产日韩欧美| 欧美高清视频在线播放| 另类尿喷潮videofree| 在线观看视频一区二区欧美日韩| 久热精品视频在线| 久久精品欧美| 亚洲第一黄网| 亚洲福利一区| 欧美美女bbbb| 中文欧美日韩| 夜夜爽av福利精品导航| 欧美色图一区二区三区| 亚洲欧美精品中文字幕在线| 亚洲图片欧洲图片日韩av| 国产精品久久久久久久久久ktv| 亚洲影院免费观看| 亚洲欧美久久久| 国产亚洲免费的视频看| 久久一区免费| 久久尤物视频| 妖精成人www高清在线观看| 在线视频精品一区| 国产日韩在线一区二区三区| 久久一区二区三区四区| 蜜桃久久av一区| 在线中文字幕不卡| 亚洲永久免费| 伊大人香蕉综合8在线视| 欧美 日韩 国产一区二区在线视频 | 久久人人97超碰国产公开结果 | 欧美一区二区三区在线观看视频| 性久久久久久久久久久久| 揄拍成人国产精品视频| 亚洲欧洲在线免费| 国产精品99一区| 久热精品视频在线观看| 欧美激情精品久久久久久| 午夜久久电影网| 久久久蜜臀国产一区二区| 亚洲最新合集| 欧美专区在线观看一区| 99精品视频免费观看|