程序師世界是廣大編程愛好者互助、分享、學習的平台，程序師世界有你更精彩！
設為首頁 加入收藏
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> C語言 >> 關於C語言 >> ortp編程示例代碼

ortp編程示例代碼

編輯：關於C語言

     鑒於很多網友找我要ortp的示例代碼，因此，今天抽空把相關資料整理了一下，寫了一個windows版的ortp示例程序，發布在這裡供網友們參考吧。

    編譯及運行環境：VS2008，windows

    編程語言：c/c++，ortp庫為c語言封裝，我用c++對其進行了進一步封裝，如果需要c語言的封裝接口，只需要把類中相關函數提取出來即可使用。

    ortp庫：ortp-0.9.1由於是以前寫的代碼，故用的ortp庫比較老，但不影響使用和學習，我附件中的工程中已經把ortp-0.9.1庫文件添加進去了）

    整個測試代碼在工程的附件中，大家下載後直接編譯後，在Debug目錄下打開2個本程序，一個選擇Client，一個選擇Server，即可看到測試效果。

    下面，我的相關代碼發布如下附件中有完整的工程）。

一、ORTP接收端封裝類

  1. //////////////////////////////////////////////////////////////////////////  
  2. //  COPYRIGHT NOTICE  
  3. //  Copyright (c) 2011, 華中科技大學 盧俊版權聲明）  
  4. //  All rights reserved.  
  5. //   
  6. /// @file    CortpClient.h    
  7. /// @brief   ortp客戶端類聲明文件  
  8. ///  
  9. /// 實現和提供ortp的客戶端應用接口  
  10. ///  
  11. /// @version 1.0     
  12. /// @author  盧俊   
  13. /// @date    2011/11/03  
  14. //  
  15. //  
  16. //  修訂說明：  
  17. //////////////////////////////////////////////////////////////////////////  
  18.  
  19. #ifndef CORTPCLIENT_H_  
  20. #define CORTPCLIENT_H_  
  21.  
  22. #include <ortp/ortp.h>  
  23. #include <string>  
  24.  
  25. /**  
  26.  *  COrtpClient ortp客戶端管理類   
  27.  *     
  28.  *  負責封裝和提供ortp相關接口  
  29.  */ 
  30. class COrtpClient  
  31. {  
  32. public:   
  33.      
  34.     /**  構造函數/析構函數  
  35.      *    
  36.      *  在創建/銷毀該類對象時自動調用  
  37.      */ 
  38.     COrtpClient();  
  39.     ~COrtpClient();    
  40.  
  41.     /** ORTP模塊的初始化  
  42.      *  
  43.      *  在整個系統最開始調用，負責ORTP庫的初始化  
  44.      *  @return: bool  是否成功  
  45.      *  @note:     
  46.      *  @see:      
  47.      */ 
  48.     static bool init();  
  49.  
  50.     /** ORTP模塊的逆初始化  
  51.      *  
  52.      *  在系統退出前調用，負責ORTP庫的釋放  
  53.      *  @return: bool  是否成功  
  54.      *  @note:     
  55.      *  @see:      
  56.      */ 
  57.     static bool deInit();  
  58.  
  59.     /** 創建RTP接收會話  
  60.      *  
  61.      *  負責產生RTP接收端會話，監聽服務器端的數據  
  62.      *  @param:  const char * localip 本地ip地址  
  63.      *  @param:  int localport  本地監聽端口  
  64.      *  @return: bool  是否成功  
  65.      *  @note:     
  66.      *  @see:      
  67.      */ 
  68.     bool create(const char * localip, int localport );  
  69.  
  70.     /** 獲取接收到的rtp包  
  71.      *  
  72.      *  將接收到的rtp數據包取出  
  73.      *  @param:  char * pBuffer  
  74.      *  @param:  int & len  
  75.      *  @return: bool  是否成功  
  76.      *  @note:     
  77.      *  @see:      
  78.      */ 
  79.     bool get_recv_data( char *pBuffer, int &len );  
  80.    
  81. private:  
  82.  
  83.     RtpSession *m_pSession;     /** rtp會話句柄 */   
  84.  
  85.     long        m_curTimeStamp; /** 當前時間戳 */   
  86.     int         m_timeStampInc; /** 時間戳增量 */   
  87.  
  88. };  
  89.    
  90. #endif // CortpClient_H_  
  91.  
  92. //////////////////////////////////////////////////////////////////////////  
  93. //  COPYRIGHT NOTICE  
  94. //  Copyright (c) 2011, 華中科技大學 盧俊版權聲明）  
  95. //  All rights reserved.  
  96. //   
  97. /// @file    CortpClient.cpp    
  98. /// @brief   ortp客戶端類實現文件  
  99. ///  
  100. /// 實現和提供ortp的客戶端應用接口  
  101. ///  
  102. /// @version 1.0     
  103. /// @author  lujun   
  104. /// @date    2011/11/03  
  105. //  
  106. //  
  107. //  修訂說明：  
  108. //////////////////////////////////////////////////////////////////////////  
  109.  
  110. #include "CortpClient.h"  
  111.  
  112. /* the payload type define */ 
  113. #define PAYLOAD_TYPE_VIDEO 34  
  114.  
  115. /* RTP video Send time stamp increase */ 
  116. #define VIDEO_TIME_STAMP_INC  3600  
  117.  
  118. /** 從rtp接收緩沖區一次讀取的字節數 */   
  119. #define READ_RECV_PER_TIME    1024  
  120.  
  121. COrtpClient::COrtpClient()  
  122. {  
  123.     m_pSession = NULL;  
  124.     m_timeStampInc = 0;  
  125.     m_curTimeStamp = 0;  
  126. }  
  127.  
  128. COrtpClient::~COrtpClient()  
  129. {  
  130.     if (!m_pSession)  
  131.     {  
  132.         rtp_session_destroy(m_pSession);  
  133.     }  
  134. }  
  135.  
  136. bool COrtpClient::init()  
  137. {  
  138.     int ret;  
  139.     WSADATA wsaData;  
  140.  
  141.     /** 初始化winsocket */   
  142.     if ( WSAStartup(MAKEWORD(2,2), &wsaData) != 0)  
  143.     {  
  144.         return false;  
  145.     }  
  146.  
  147.     ortp_init();  
  148.     ortp_scheduler_init();  
  149.  
  150.     return true;  
  151. }  
  152.  
  153. bool COrtpClient::deInit()  
  154. {  
  155.     ortp_exit();  
  156.  
  157.     if (WSACleanup() == SOCKET_ERROR)  
  158.     {  
  159.         return false;  
  160.     }  
  161.  
  162.     return true;  
  163. }  
  164.  
  165. bool COrtpClient::create( const char * localip, int localport )  
  166. {  
  167.     if ( m_pSession != NULL)  
  168.     {  
  169.         return false;  
  170.     }  
  171.  
  172.     /** 創建新會話 */   
  173.     m_pSession = rtp_session_new(RTP_SESSION_RECVONLY);  
  174.     if ( !m_pSession)  
  175.     {  
  176.         return false;  
  177.     }  
  178.  
  179.     /** 配置相關參數 */   
  180.     rtp_session_set_scheduling_mode(m_pSession,1);  
  181.     rtp_session_set_blocking_mode(m_pSession,1);  
  182.     rtp_session_set_local_addr(m_pSession,localip,localport);  
  183.     rtp_session_enable_adaptive_jitter_compensation(m_pSession,1);  
  184.     rtp_session_set_jitter_compensation(m_pSession,40);  
  185.  
  186.     rtp_session_set_payload_type(m_pSession,PAYLOAD_TYPE_VIDEO);  
  187.     m_timeStampInc = VIDEO_TIME_STAMP_INC;  
  188.  
  189.     return true;  
  190. }  
  191.  
  192. bool COrtpClient::get_recv_data( char *pBuffer, int &len )  
  193. {  
  194.     int recvBytes  = 0;  
  195.     int totalBytes = 0;  
  196.     int have_more = 1;  
  197.  
  198.     while(have_more)  
  199.     {  
  200.         if ( totalBytes+READ_RECV_PER_TIME > len )  
  201.         {  
  202.             /** 緩沖區大小不夠 */   
  203.             return false;  
  204.         }  
  205.         recvBytes = rtp_session_recv_with_ts(m_pSession,pBuffer+totalBytes,READ_RECV_PER_TIME,m_curTimeStamp,&have_more);  
  206.         if (recvBytes <= 0)  
  207.         {  
  208.             break;  
  209.         }  
  210.         totalBytes += recvBytes;  
  211.     }  
  212.  
  213.     /** 判斷是否讀取到數據 */   
  214.     if (totalBytes == 0)  
  215.     {  
  216.         return false;  
  217.     }  
  218.  
  219.     /** 記錄有效字節數 */   
  220.     len = totalBytes;  
  221.  
  222.     /** 時間戳增加 */   
  223.     m_curTimeStamp += m_timeStampInc;  
  224.  
  225.     return true;  
  226. }  
  227.  

二、ORTP發送端封裝類

  1. //////////////////////////////////////////////////////////////////////////  
  2. //  COPYRIGHT NOTICE  
  3. //  Copyright (c) 2011, 華中科技大學 盧俊版權聲明）  
  4. //  All rights reserved.  
  5. //   
  6. /// @file    CortpServer.h  
  7. /// @brief   ortp服務器類聲明文件  
  8. ///  
  9. /// 實現和提供ortp的服務器端應用接口  
  10. ///  
  11. /// @version 1.0     
  12. /// @author  盧俊  
  13. /// @date    2011/11/03  
  14. //  
  15. //  
  16. //  修訂說明：  
  17. //////////////////////////////////////////////////////////////////////////  
  18.  
  19. #ifndef CORTPSERVER_H_  
  20. #define CORTPSERVER_H_  
  21.    
  22. #include <ortp/ortp.h>  
  23.  
  24. /**  
  25.  *  COrtpServer RTP發送類   
  26.  *     
  27.  *  負責使用RTP協議進行數據的發送  
  28.  */ 
  29. class COrtpServer  
  30. {  
  31. public:   
  32.      
  33.     /**  構造函數  
  34.      *    
  35.      *  該函數為該類的構造函數，在創建該類對象時自動調用  
  36.      */ 
  37.     COrtpServer();  
  38.  
  39.     /** 析構函數  
  40.      *  
  41.      * 該函數執行析構操作，由系統自動調用  
  42.      */ 
  43.     ~COrtpServer();    
  44.     
  45.     /** ORTP模塊的初始化  
  46.     *  
  47.     *  在整個系統最開始調用，負責ORTP庫的初始化  
  48.     *  @return: bool  是否成功  
  49.     *  @note:     
  50.     *  @see:      
  51.     */ 
  52.     static bool init();  
  53.  
  54.     /** ORTP模塊的逆初始化  
  55.     *  
  56.     *  在系統退出前調用，負責ORTP庫的釋放  
  57.     *  @return: bool  是否成功  
  58.     *  @note:     
  59.     *  @see:      
  60.     */ 
  61.     static bool deInit();  
  62.  
  63.     /** 創建RTP接收會話  
  64.     *  
  65.     *  負責產生RTP接收端會話，監聽服務器端的數據  
  66.     *  @param:  const char * destIP 目的地址的IP  
  67.     *  @param:  int destport 目的地址的監聽端口號  
  68.     *  @return: bool  是否成功  
  69.     *  @note:     
  70.     *  @see:      
  71.     */ 
  72.     bool create(const char * destIP, int destport );  
  73.  
  74.     /** 發送RTP數據  
  75.      *  
  76.      *  將指定的buffer中的數據發送到客戶端  
  77.      *  @param:  unsigned char * buffer 需要發送的數據  
  78.      *  @param:  int len 有效字節數  
  79.      *  @return: int 實際發送的字節數  
  80.      *  @note:    
  81.      *  @see:     
  82.      */ 
  83.     int send_data( unsigned char *buffer, int len );  
  84.    
  85. private:  
  86.  
  87.     RtpSession *m_pSession;     /** rtp會話句柄 */   
  88.  
  89.     long        m_curTimeStamp; /** 當前時間戳 */   
  90.     int         m_timeStampInc; /** 時間戳增量 */   
  91.  
  92.     char       *m_ssrc;         /** 數據源標識 */   
  93. };  
  94.  
  95. #endif // COrtpServer_H_  
  96.  
  97. //////////////////////////////////////////////////////////////////////////  
  98. //  COPYRIGHT NOTICE  
  99. //  Copyright (c) 2011, 華中科技大學 盧俊版權聲明）  
  100. //  All rights reserved.  
  101. //   
  102. /// @file    CortpServer.cpp  
  103. /// @brief   ortp服務器類實現文件  
  104. ///  
  105. /// 實現和提供ortp的服務器端應用接口  
  106. ///  
  107. /// @version 1.0     
  108. /// @author  lujun   
  109. /// @date    2011/11/03  
  110. //  
  111. //  
  112. //  修訂說明：  
  113. //////////////////////////////////////////////////////////////////////////  
  114.  
  115. #include "COrtpServer.h"  
  116.  
  117. /* the payload type define */ 
  118. #define PAYLOAD_TYPE_VIDEO 34  
  119.  
  120. /* RTP video Send time stamp increase */ 
  121. #define VIDEO_TIME_STAMP_INC  3600  
  122.  
  123. COrtpServer::COrtpServer()  
  124. {  
  125.     m_ssrc     = NULL;  
  126.     m_pSession = NULL;  
  127.     m_timeStampInc = 0;  
  128.     m_curTimeStamp = 0;  
  129. }  
  130.  
  131. COrtpServer::~COrtpServer()  
  132. {  
  133.     if (!m_pSession)  
  134.     {  
  135.         rtp_session_destroy(m_pSession);  
  136.     }  
  137. }  
  138.  
  139. bool COrtpServer::init()  
  140. {  
  141.     int ret;  
  142.     WSADATA wsaData;  
  143.  
  144.     /** 初始化winsocket */   
  145.     if ( WSAStartup(MAKEWORD(2,2), &wsaData) != 0)  
  146.     {  
  147.         return false;  
  148.     }  
  149.  
  150.     ortp_init();  
  151.     ortp_scheduler_init();  
  152.  
  153.     return true;  
  154. }  
  155.  
  156. bool COrtpServer::deInit()  
  157. {  
  158.     ortp_exit();  
  159.  
  160.     if (WSACleanup() == SOCKET_ERROR)  
  161.     {  
  162.         return false;  
  163.     }  
  164.  
  165.     return true;  
  166. }  
  167.  
  168. bool COrtpServer::create( const char * destIP, int destport )  
  169. {  
  170.     m_ssrc = getenv("SSRC");  
  171.  
  172.     m_pSession = rtp_session_new(RTP_SESSION_SENDONLY);   
  173.  
  174.     rtp_session_set_scheduling_mode(m_pSession,1);  
  175.     rtp_session_set_blocking_mode(m_pSession,1);  
  176.     rtp_session_set_remote_addr(m_pSession,destIP,destport);  
  177.  
  178.     if(m_ssrc != NULL)  
  179.     {  
  180.         rtp_session_set_ssrc(m_pSession,atoi(m_ssrc));  
  181.     }  
  182.  
  183.     rtp_session_set_payload_type(m_pSession,PAYLOAD_TYPE_VIDEO);  
  184.     m_timeStampInc = VIDEO_TIME_STAMP_INC;  
  185.  
  186.     return true;  
  187. }  
  188.  
  189. int COrtpServer::send_data( unsigned char *buffer, int len )  
  190. {  
  191.     int sendBytes = 0;  
  192.  
  193.     /** 強轉 */   
  194.     const char *sendBuffer = (const char*)buffer;  
  195.  
  196.     sendBytes = rtp_session_send_with_ts(m_pSession,sendBuffer,len,m_curTimeStamp);  
  197.  
  198.     if ( sendBytes > 0)  
  199.     {  
  200.         m_curTimeStamp += m_timeStampInc; /** 增加時間戳 */   
  201.     }     
  202.  
  203.     return sendBytes;  
  204. } 

三、測試程序

  1. //////////////////////////////////////////////////////////////////////////  
  2. //  COPYRIGHT NOTICE  
  3. //  Copyright (c) 2011, 華中科技大學 盧俊 版權聲明）  
  4. //  All rights reserved.  
  5. //  
  6. /// @file    main.cpp   
  7. /// @brief   ortp測試文件  
  8. ///  
  9. /// 測試ortp發送結構體  
  10. ///  
  11. /// @version 1.0    
  12. /// @author  盧俊  
  13. /// @e-mail  [email protected]  
  14. /// @date    2011/10/19  
  15. //  
  16. //  
  17. //  修訂說明：  
  18. //////////////////////////////////////////////////////////////////////////  
  19.  
  20. #include <iostream>  
  21.  
  22. #include "COrtpClient.h"  
  23. #include "COrtpServer.h"  
  24.  
  25. /** 本地IP地址 */ 
  26. const char * LOCAL_IP_ADDR = "127.0.0.1";  
  27.  
  28. /** 本地監聽端口 */   
  29. const int LOCAL_RTP_PORT = 8000;  
  30.  
  31. /** 目的監聽端口 */   
  32. const int DEST_RTP_PORT = 8000;  
  33.  
  34. /** 目的IP地址 */   
  35. const char * DEST_IP_ADDR  = "127.0.0.1";  
  36.  
  37. /** 一次發送的數據長度 */   
  38. const int SEND_LEN_PER_TIME =  8*1024;  
  39.  
  40. /** 接收緩沖區的總大小 */   
  41. const int RECV_BUFFER_LEN   = 10*1024;  
  42.  
  43. /** 一次接收的數據長度 */   
  44. const int RECV_LEN_PER_TIME = 1024;  
  45.  
  46. bool ortpServer()  
  47. {  
  48.     COrtpServer ortpServer;  
  49.  
  50.     COrtpServer::init();  
  51.  
  52.     if (!ortpServer.create(DEST_IP_ADDR,DEST_RTP_PORT))  
  53.     {  
  54.         std::cout << "ortpServer.create fail!\n";  
  55.         getchar();  
  56.         getchar();  
  57.         return false;  
  58.     }  
  59.  
  60.     unsigned char * buffer = new unsigned char[SEND_LEN_PER_TIME];  
  61.  
  62.     while (1)  
  63.     {  
  64.         if ( ortpServer.send_data(buffer,SEND_LEN_PER_TIME) <= 0)  
  65.         {  
  66.             std::cout << "send fail!\n";  
  67.         }  
  68.  
  69.         Sleep(100);  
  70.         std::cout << "send bytes\n";  
  71.     }  
  72.  
  73.     delete [] buffer;  
  74.  
  75.     COrtpClient::deInit();  
  76.  
  77.     return true;  
  78. }  
  79.  
  80. bool ortpClient()  
  81. {  
  82.     COrtpClient ortpClient;  
  83.  
  84.     COrtpClient::init();      
  85.  
  86.     if (!ortpClient.create(LOCAL_IP_ADDR,LOCAL_RTP_PORT))  
  87.     {  
  88.         std::cout << "ortpClient.create fail!\n";  
  89.         getchar();  
  90.         getchar();  
  91.         return false;  
  92.     }  
  93.  
  94.     char *buffer = new char[RECV_BUFFER_LEN];  
  95.  
  96.     while(1)  
  97.     {  
  98.         int len = RECV_BUFFER_LEN;  
  99.         if (!ortpClient.get_recv_data(buffer,len))  
  100.         {  
  101.             Sleep(10);  
  102.             continue;  
  103.         }  
  104.  
  105.         std::cout << "successful recv,data len =" << len << std::endl;  
  106.     }  
  107.  
  108.     COrtpClient::deInit();  
  109.  
  110.     delete [] buffer;  
  111.  
  112.     return true;  
  113. }  
  114.  
  115. void main()  
  116. {  
  117.     std::cout << "enter num,1 ->client, 2->server! \n";  
  118.  
  119.     int num;  
  120.  
  121.     std::cin >> num;  
  122.  
  123.     while(1)  
  124.     {  
  125.         if (num == 1)  
  126.         {  
  127.             ortpClient();  
  128.             break;  
  129.         }  
  130.         else if (num == 2)  
  131.         {  
  132.             ortpServer();  
  133.             break;  
  134.         }  
  135.         else 
  136.         {  
  137.             std::cout << "please input 1 or 2 !\n";  
  138.         }  
  139.     }  
  140.  
  141.     getchar();  
  142.     getchar();  
  143. } 

        有關ORTP的介紹、RTP的介紹、RTP的負載類型和時間戳的含義等理論性的東西，都可以在我博客中的其他文章中找到，以上就是整個工程的代碼，注釋不是很多，因為有些地方我也不是特別清楚，比如jitter、scheduling什麼的，如果有什麼其他疑問歡迎留言或者E-mail來信交流。

本文出自 “對影成三人” 博客，請務必保留此出處http://ticktick.blog.51cto.com/823160/704891

  1. 上一頁:
  2. 下一頁:
關於C語言
提前認識軟件開發(20) 如何在C語言裡面執行SQL語句

在通信類軟件中，程序經常需要與數據庫打交道。為了實現諸如從數
C#發現之旅-高性能ASP.NET樹狀列表控件(上)(5)

則這段Html代碼的顯示效果為分析這段Html代碼，讀者可
C中的define 特殊用法

今天，我的一個同學告
兔子問題

查看全套“c語言習題集&rdquo
二級c程序設計題（1），c程序設計題

二級c程序設計題（1），c程序設計題  原文：ht
設計模式學習筆記：factory method(工廠方法)

工廠方法是一種對象創建型模式，它的目的是定義一個用於創
相關文章
閱讀排行榜
如何學好C語言 C語言初學 比較五個整數並輸出最大值和最小值2，五個最小值 C語言函數大全(u開頭) 問題五十九: 創建一個長度為20的數組，其中存放斐波那契數列的前20項 [學習筆記—Objective-C]《Objective-C 程序設計 第6版》第十章 變量和數據類型 2 curses庫IO處理--curses的一些說明 一步一步寫算法（之 回數） 程序猿之---C語言細節21（#define和typedef區別、結構體細節） 動態單鏈表的傳統存儲方式和10種常見操作-C語言實現 C語言函數動態調用(參考UnderC實現) 【編程好習慣】通過命名規則區分變量
熱門圖文
[C語言] 實現strstr函數 asp頁面和Asp.net頁面傳中文參數UrlEncode編碼以及接收解碼 php面向對象編程（一） phpinfo 系統查看參數函數代碼 NT注冊表結構介紹 深入解讀PHP抽象類abstract的應用 J2EE初學者需要注意的問題 關於unserialize的問題
欄目導航
CC++VCVC.net關於C語言
Copyright © 程式師世界 All Rights Reserved