ortp庫使用入門

我們知道， RTP（Real-timeTransportProtocol）是用于Internet上針對多媒體資料流的一種傳輸協定，做流媒體傳輸方面的應用離不開RTP協定的實作及使用，為了更加快速地在項目中應用RTP協定實作流媒體的傳輸，我們一般會選擇使用一些RTP庫，例如使用c++語言編寫的JRTPLIB庫，網上關于RTP協定以及JRTPLIB庫的介紹已經很多了，在此我也不再贅述，文本主要介紹實作了RTP協定的另一種開源庫——ORTP庫，這個庫是純使用c語言編寫，由于我們的項目是基于Linux下的c語言程式設計，故我們選擇了ortp作為我們的第三方庫，在此我也對該庫進行一個簡單地介紹，希望對其他ortp的初學者有所幫助。

一、簡介

ORTP是一個支援RTP以及RFC3550協定的庫，有如下的特性：

（1）使用C語言編寫，可以工作于windows, Linux, 以及 Unix平台

（2）實作了RFC3550協定，提供簡單易用的API。支援多種配置，RFC3551為預設的配置。

（3）支援單線程下的多個RTP會話，支援自适應抖動處理。

ORTP可以在其官方網站上（http://www.linphone.org/index.php/eng/code_review/ortp）下載下傳，下載下傳解壓後得到ORTP的源碼包和示例程式（tests）。其幫助文檔在docs目錄下，也可以在http://download.savannah.gnu.org/releases/linphone/ortp/docs/線上檢視。

關于ORTP的資料并不多，主要是其源碼、幫助文檔以及示例程式，關于示例程式說明如下：

rtprecv.c 和 rtpsend.c 展示了如何接收和發送單RTP資料流。

mrtprecv.c mrtpsend.c 展示了如何同時接收和發送多個RTP資料流。

二、主要函數介紹

rtp_session_init

函數原型：void rtp_session_init (RtpSession * session, int mode)

函數功能：執行rtp會話的一些必要的初始化工作

參數含義：

session： rtp會話結構體，含有一些rtp會話的基本資訊

mode：傳輸模式，有以下幾種，決定本會話的一些特性。

RTP_SESSION_RECVONLY：隻進行rtp資料的接收

RTP_SESSION_SENDONLY：隻進行rtp資料的發送

RTP_SESSION_SENDRECV：可以進行rtp資料的接收和發送

執行的操作：

1. 設定rtp包緩沖隊列的最大長度

2. 根據傳輸模式設定标志變量的值

3. 随機産生×××C和同步源描述資訊

4. 傳入全局的av_profile，即使用預設的profile配置

5. 初始化rtp包緩沖區隊列

6. 發送負載類型預設設定為0（pcmu音頻），接收負載類型預設設定為-1（未定義）

7. 将session的其他成員的值均設定一個預設值。

rtp_session_set_scheduling_mode

函數原型：void rtp_session_set_scheduling_mode (RtpSession * session, int yesno)

函數功能： RtpScheduler管理多個session的排程和收發的控制，本函數設定是否使用該session排程管理功能。

session： rtp會話結構體

yesno: 是否使用rtp session的系統排程功能

說明：

如果yesno為1，則表明使用系統的session排程管理功能，意味着可以使用以下功能：

1. 可以使用session_set_select在多個rtp會話之間進行選擇，根據時間戳判定某個會話是否到達了收發的時間。

2. 可以使用rtp_session_set_blocking_mode()設定是否使用阻塞模式來進行rtp包的發送和接收。

如果yesno為0，則表明該會話不受系統管理和排程。

關于rtp session的管理和排程，由全局的變量RtpScheduler *__ortp_scheduler來負責，該變量必須通過ortp_scheduler_init() 來進行初始化操作。

rtp_session_set_blocking_mode

函數原型：void rtp_session_set_blocking_mode (RtpSession * session, int yesno)

函數功能：設定是否使用阻塞模式，

yesno: 是否使用阻塞模式

阻塞模式隻有在scheduling mode被開啟的情況下才能使用，本函數決定了rtp_session_recv_with_ts() 和 rtp_session_send_with_ts()兩個函數的行為，如果啟用了阻塞模式，則rtp_session_recv_with_ts()會一直阻塞直到接收RTP包的時間點到達（這個時間點由該函數參數中所定義的時間戳來決定），當接收完RTP資料包後，該函數才會傳回。同樣，rtp_session_send_with_ts()也會一直阻塞直到需要被發送的RTP包的時間點到達，發送結束後，函數才傳回。

rtp_session_signal_connect

函數原型：int rtp_session_signal_connect (RtpSession * session, const char *signal, RtpCallback cb, unsigned long user_data)

函數功能：本函數提供一種方式，用于通知應用程式各種可能發生的RTP事件（信号）。可能通過注冊回調函數的形式來實作本功能。

signal：信号的名稱

cb：回調函數

user_data：傳遞給回調函數的資料

傳回值：0表示成功，-EOPNOTSUPP表示信号名稱不存在，-1表示回調函數綁定錯誤

信号的名稱必須是以下字元串中的一種：

"ssrc_changed" : 資料流的同步源辨別改變

"payload_type_changed" : 資料流的負載類型改變

"telephone-event_packet" : telephone-event RTP包(RFC2833)被接收

"telephone-event" : telephone event 發生

"network_error" : 網絡錯誤産生，傳遞給回調函數的是描述錯誤的字元串（const char *型）或者錯誤碼（int型）

"timestamp_jump" : 接收到的資料包發生了時間戳的跳躍。

要取消事件（信号）的監聽，可以使用下面這個函數

int rtp_session_signal_disconnect_by_callback ( RtpSession * session, const char * signal_name, RtpCallback cb )

rtp_session_set_local_addr

函數原型：int rtp_session_set_local_addr( RtpSession * session, const char * addr,int port)

函數功能：設定本地rtp資料監聽位址

addr：本地IP位址，例如127.0.0.1，如果為NULL，則系統配置設定0.0.0.0

port：監聽端口，如果設定為-1，則系統為其自動配置設定端口

傳回值： 0表示成功

如果是RTP_SESSION_SENDONLY（隻發送）型會話，則不需要進行本設定，而必須設定rtp_session_set_remote_addr() 來設定遠端目的位址。

如果采用了系統自動配置設定監聽端口，則可以通過int rtp_session_get_local_port(const RtpSession *session) 來擷取系統配置設定的監聽端口号。

rtp_session_set_remote_addr

函數原型：int rtp_session_set_remote_addr (RtpSession * session, const char * addr, int port)

函數功能：設定RTP發送的目的位址

addr：目的IP位址

port：目的位址的監聽端口号

rtp_session_set_send_payload_type

函數原型：int rtp_session_set_send_payload_type (RtpSession * session, int paytype)

函數功能：設定RTP發送資料的負載類型

paytype：負載類型

傳回值： 0表示成功，-1表示負載未定義

負載類型在payloadtype.h檔案中有詳細的定義，RTP接收端有着類似的負載類型設定函數，int rtp_session_set_recv_payload_type ( RtpSession * session, int paytype ) ，注意，發送的負載類型必須與接收的負載類型一緻才能正常完成收發。

rtp_session_send_with_ts

函數原型：int rtp_session_send_with_ts (RtpSession * session, const char * buffer, int len,uint32_t userts)

函數功能：發送RTP資料包

buffer：需要發送的RTP資料的緩沖區

len：需要發送的RTP資料的長度

userts：本RTP資料包的時間戳

傳回值：成功發送到網絡中的位元組數

發送RTP資料需要自己管理時間戳的遞增，每調用一次本函數，請根據實際情況對userts進行遞增，具體遞增的規則見RTP協定中的說明。

例如：如果發送的是采樣率為90000Hz的視訊資料包，每秒25幀，則時間戳的增量為：90000/25 = 3600

時間戳的起始值為随機值，建議設定為0 。

rtp_session_recv_with_ts

函數原型：int rtp_session_recv_with_ts (RtpSession * session, char * buffer,int len, uint32_t time, int * have_more)

函數功能：接收RTP資料包

buffer：存放接收的RTP資料的緩沖區

len：期望接收的RTP資料的長度

time：期望接收的RTP資料的時間戳

have_more：辨別接收緩沖區是否還有資料沒有傳遞完。當使用者給出的緩沖區不夠大時，為了辨別緩沖區資料未取完，則have_more指向的資料為1，期望使用者以同樣的時間戳再次調用本函數；否則為0，辨別取完。

rtp_session_destroy

【原型】： void rtp_session_destroy(RtpSession *session)

【功能】：摧毀rtp會話對象，釋放資源

【參數】：session已經建立的RTP會話對象

三、程式示例

下面，我簡單地通過程式示範了怎麼使用ortp進行rtp資料包的發送，接收端的程式待以後有時間再整理出來吧。

//////////////////////////////////////////////////////////////////////////     
/// COPYRIGHT NOTICE     
 // Copyright (c) 2009, 華中科技大學ticktick Group     
/// All rights reserved.      
///      
/// @file    ortpSend.c       
/// @brief   ortpSend的測試     
///     
/// 本檔案示例使用ortp庫進行rtp資料包的發送    
///      
/// @version 1.0        
/// @author  tickTick   
/// @date    2010/07/07      
/// @E-mail  [email protected]     
///     
/// 修訂說明：建立檔案    
//////////////////////////////////////////////////////////////////////////      
 
#include <ortp/ortp.h>  
#include <signal.h>  
#include <stdlib.h>  
 
#ifndef _WIN32   
#include <sys/types.h>  
#include <sys/time.h>  
#include <stdio.h>  
#endif  
 
// 時間戳增量
#define TIME_STAMP_INC  160   
#define BYTES_PER_COUNT 65535
// 時間戳   
uint32_t g_user_ts;  
 
/**  初始化     
 *       
 *   主要用于對ortp以及其它參數進行初始化    
 *   @param:  char * ipStr 目的端IP位址描述串     
 *   @param:  iint port 目的端RTP監聽端口     
 *   @return:  RtpSession * 傳回指向RtpSession對象的指針,如果為NULL，則初始化失敗     
 *   @note:       
 */   
RtpSession * rtpInit(char * ipStr,int port)  
{  
    // Rtp會話對象    
    RtpSession *session;  
    char *ssrc;  
      
    // 時間戳初始化    
    g_user_ts = 0;  
 
    // ortp的一些基本初始化操作   
    ortp_init();  
    ortp_scheduler_init();  
    // 建立新的rtp會話對象  
    session=rtp_session_new(RTP_SESSION_SENDONLY);    
      
    rtp_session_set_scheduling_mode(session,1);  
    rtp_session_set_blocking_mode(session,1);  
    // 設定遠端RTP用戶端的的IP和監聽端口（即本rtp資料包的發送目的位址）   
    rtp_session_set_remote_addr(session,ipStr,port);  
    // 設定負載類型    
    rtp_session_set_payload_type(session,0);  
      
    // 擷取同步源辨別    
    ssrc=getenv("×××C");  
    if (ssrc!=NULL)   
    {  
        printf("using ×××C=%i.\n",atoi(ssrc));  
        rtp_session_set_ssrc(session,atoi(ssrc));  
    }  
      
    return session;  
 
}  
 
/**  發送rtp資料包     
 *       
 *   主要用于發送rtp資料包     
 *   @param:  RtpSession *session RTP會話對象的指針     
 *   @param:  const char *buffer 要發送的資料的緩沖區位址      
 *   @param: int len 要發送的資料長度     
 *   @return:  int 實際發送的資料包數目     
 *   @note:     如果要發送的資料包長度大于BYTES_PER_COUNT，本函數内部會進行分包處理     
 */ 
int rtpSend(RtpSession *session,const char *buffer, int len)  
{  
    int curOffset = 0;  
    int sendBytes = 0;  
    int clockslide=500;   
    // 發送包的個數  
    int sendCount = 0;  
 
    ortp_message("send data len %i\n ",len);  
 
    // 是否全部發送完畢    
    while(curOffset < len )  
    {  
        // 如果需要發送的資料長度小于等于阙值，則直接發送  
        if( len <= BYTES_PER_COUNT )  
        {  
            sendBytes = len;  
        }  
        else 
        {  
            // 如果目前偏移 + 門檻值 小于等于 總長度，則發送門檻值大小的資料  
            if( curOffset + BYTES_PER_COUNT <= len )  
            {  
                sendBytes = BYTES_PER_COUNT;  
            }  
            // 否則就發送剩餘長度的資料  
            else 
            {  
                sendBytes = len - curOffset;  
            }  
        }  
          
        ortp_message("send data bytes %i\n ",sendBytes);  
          
        rtp_session_send_with_ts(session,(char *)(buffer+curOffset),sendBytes,g_user_ts);  
          
        // 累加  
        sendCount ++;  
        curOffset += sendBytes;                   
        g_user_ts += TIME_STAMP_INC;  
      
        // 發送一定資料包後休眠一會  
        if (sendCount%10==0)   
        {  
            usleep(20000);  
        }     
    }  
    return 0;  
}  
 
/**  結束ortp的發送，釋放資源     
 *      
 *   @param:  RtpSession *session RTP會話對象的指針     
 *   @return:  0表示成功     
 *   @note:         
 */ 
int rtpExit(RtpSession *session)  
{  
    g_user_ts = 0;  
      
    rtp_session_destroy(session);  
    ortp_exit();  
    ortp_global_stats_display();  
 
    return 0;  
}  
 
// 主函數，進行測試  
int main()  
{  
    // 待發送的資料緩沖區  
    char * pBuffer = "123445356234134234532523654323413453425236244123425234";  
      
    RtpSession * pRtpSession = NULL;  
    // 向（192.201.0.51，8000）目的位址發送rtp包  
    pRtpSession = rtpInit("192.201.0.51",8000);  
    if(pRtpSession==NULL)  
    {  
        printf("error rtpInit");  
        return 0;  
    }  
      
    // 循環發送  
    while(1)  
    {  
        if( rtpSend(pRtpSession,pBuffer,20) != 0)  
        {  
            printf("error rtpInit");  
            break;  
        }  
        usleep(10000);  
        printf("sleep");  
    }  
      
    // 退出  
    rtpExit(pRtpSession);  
      
    return 0;  
}

ortp庫使用入門

繼續閱讀

有這樣一個問題:昆曲等戲曲可以通過網際網路進行直播嗎？答案是可行的。随着網絡技術的發展，現在許多傳統表演形式都可以通過直播

計算機科學與技術專業培養計劃

用兩個線程來求1-100之間的和

NIO系列：4.NIO快速入門

對标準H264碼流的RTP打包 VLC播放RTP打包發送的.264檔案

jrtplib3.9.1 example5

基于Jrtplib的流媒體技術解析

Qt調用jrtplib實作單點傳播、多點傳播和廣播

jrtplib發送資料包時預設RTP參數設定講解

jrtplib-3.9.1+jthread-1.3.1使用cmake-3.1.0在windows下生成jrtplib的VS2010工程

jrtplib介紹

設計模式——政策模式（Strategy）政策設計模式（風景區購票示例）

如何重新編譯linux核心

網絡蜘蛛爬蟲 Scrapy - 簡介&Demo

[BLE--GAP]GAP Service及其使用

RTP的使用