AI 助理
备案控制台
开发者社区 云计算 文章 正文

ortp编程示例代码

2017-11-27 1256
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

鉴于很多网友找我要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接收端封装类


//////////////////////////////////////////////////////////////////////////  
//  COPYRIGHT NOTICE  
//  Copyright (c) 2011, 华中科技大学 卢俊（版权声明）  
//  All rights reserved.  
//   
/// @file    CortpClient.h    
/// @brief   ortp客户端类声明文件  
///  
/// 实现和提供ortp的客户端应用接口  
///  
/// @version 1.0     
/// @author  卢俊   
/// @date    2011/11/03  
//  
//  
//  修订说明：  
//////////////////////////////////////////////////////////////////////////  
 
#ifndef CORTPCLIENT_H_  
#define CORTPCLIENT_H_  
 
#include <ortp/ortp.h>  
#include <string>  
 
/**  
 *  COrtpClient ortp客户端管理类   
 *     
 *  负责封装和提供ortp相关接口  
 */ 
class COrtpClient  
{  
public:   
     
    /**  构造函数/析构函数  
     *    
     *  在创建/销毁该类对象时自动调用  
     */ 
    COrtpClient();  
    ~COrtpClient();    
 
    /** ORTP模块的初始化  
     *  
     *  在整个系统最开始调用，负责ORTP库的初始化  
     *  @return: bool  是否成功  
     *  @note:     
     *  @see:      
     */ 
    static bool init();  
 
    /** ORTP模块的逆初始化  
     *  
     *  在系统退出前调用，负责ORTP库的释放  
     *  @return: bool  是否成功  
     *  @note:     
     *  @see:      
     */ 
    static bool deInit();  
 
    /** 创建RTP接收会话  
     *  
     *  负责产生RTP接收端会话，监听服务器端的数据  
     *  @param:  const char * localip 本地ip地址  
     *  @param:  int localport  本地监听端口  
     *  @return: bool  是否成功  
     *  @note:     
     *  @see:      
     */ 
    bool create(const char * localip, int localport );  
 
    /** 获取接收到的rtp包  
     *  
     *  将接收到的rtp数据包取出  
     *  @param:  char * pBuffer  
     *  @param:  int & len  
     *  @return: bool  是否成功  
     *  @note:     
     *  @see:      
     */ 
    bool get_recv_data( char *pBuffer, int &len );  
   
private:  
 
    RtpSession *m_pSession;     /** rtp会话句柄 */   
 
    long        m_curTimeStamp; /** 当前时间戳 */   
    int         m_timeStampInc; /** 时间戳增量 */   
 
};  
   
#endif // CortpClient_H_  
 
//////////////////////////////////////////////////////////////////////////  
//  COPYRIGHT NOTICE  
//  Copyright (c) 2011, 华中科技大学 卢俊（版权声明）  
//  All rights reserved.  
//   
/// @file    CortpClient.cpp    
/// @brief   ortp客户端类实现文件  
///  
/// 实现和提供ortp的客户端应用接口  
///  
/// @version 1.0     
/// @author  lujun   
/// @date    2011/11/03  
//  
//  
//  修订说明：  
//////////////////////////////////////////////////////////////////////////  
 
#include "CortpClient.h"  
 
/* the payload type define */ 
#define PAYLOAD_TYPE_VIDEO 34  
 
/* RTP video Send time stamp increase */ 
#define VIDEO_TIME_STAMP_INC  3600  
 
/** 从rtp接收缓冲区一次读取的字节数 */   
#define READ_RECV_PER_TIME    1024  
 
COrtpClient::COrtpClient()  
{  
    m_pSession = NULL;  
    m_timeStampInc = 0;  
    m_curTimeStamp = 0;  
}  
 
COrtpClient::~COrtpClient()  
{  
    if (!m_pSession)  
    {  
        rtp_session_destroy(m_pSession);  
    }  
}  
 
bool COrtpClient::init()  
{  
    int ret;  
    WSADATA wsaData;  
 
    /** 初始化winsocket */   
    if ( WSAStartup(MAKEWORD(2,2), &wsaData) != 0)  
    {  
        return false;  
    }  
 
    ortp_init();  
    ortp_scheduler_init();  
 
    return true;  
}  
 
bool COrtpClient::deInit()  
{  
    ortp_exit();  
 
    if (WSACleanup() == SOCKET_ERROR)  
    {  
        return false;  
    }  
 
    return true;  
}  
 
bool COrtpClient::create( const char * localip, int localport )  
{  
    if ( m_pSession != NULL)  
    {  
        return false;  
    }  
 
    /** 创建新会话 */   
    m_pSession = rtp_session_new(RTP_SESSION_RECVONLY);  
    if ( !m_pSession)  
    {  
        return false;  
    }  
 
    /** 配置相关参数 */   
    rtp_session_set_scheduling_mode(m_pSession,1);  
    rtp_session_set_blocking_mode(m_pSession,1);  
    rtp_session_set_local_addr(m_pSession,localip,localport);  
    rtp_session_enable_adaptive_jitter_compensation(m_pSession,1);  
    rtp_session_set_jitter_compensation(m_pSession,40);  
 
    rtp_session_set_payload_type(m_pSession,PAYLOAD_TYPE_VIDEO);  
    m_timeStampInc = VIDEO_TIME_STAMP_INC;  
 
    return true;  
}  
 
bool COrtpClient::get_recv_data( char *pBuffer, int &len )  
{  
    int recvBytes  = 0;  
    int totalBytes = 0;  
    int have_more = 1;  
 
    while(have_more)  
    {  
        if ( totalBytes+READ_RECV_PER_TIME > len )  
        {  
            /** 缓冲区大小不够 */   
            return false;  
        }  
        recvBytes = rtp_session_recv_with_ts(m_pSession,pBuffer+totalBytes,READ_RECV_PER_TIME,m_curTimeStamp,&have_more);  
        if (recvBytes <= 0)  
        {  
            break;  
        }  
        totalBytes += recvBytes;  
    }  
 
    /** 判断是否读取到数据 */   
    if (totalBytes == 0)  
    {  
        return false;  
    }  
 
    /** 记录有效字节数 */   
    len = totalBytes;  
 
    /** 时间戳增加 */   
    m_curTimeStamp += m_timeStampInc;  
 
    return true;  
}


二、ORTP发送端封装类


//////////////////////////////////////////////////////////////////////////  
//  COPYRIGHT NOTICE  
//  Copyright (c) 2011, 华中科技大学 卢俊（版权声明）  
//  All rights reserved.  
//   
/// @file    CortpServer.h  
/// @brief   ortp服务器类声明文件  
///  
/// 实现和提供ortp的服务器端应用接口  
///  
/// @version 1.0     
/// @author  卢俊  
/// @date    2011/11/03  
//  
//  
//  修订说明：  
//////////////////////////////////////////////////////////////////////////  
 
#ifndef CORTPSERVER_H_  
#define CORTPSERVER_H_  
   
#include <ortp/ortp.h>  
 
/**  
 *  COrtpServer RTP发送类   
 *     
 *  负责使用RTP协议进行数据的发送  
 */ 
class COrtpServer  
{  
public:   
     
    /**  构造函数  
     *    
     *  该函数为该类的构造函数，在创建该类对象时自动调用  
     */ 
    COrtpServer();  
 
    /** 析构函数  
     *  
     * 该函数执行析构操作，由系统自动调用  
     */ 
    ~COrtpServer();    
    
    /** ORTP模块的初始化  
    *  
    *  在整个系统最开始调用，负责ORTP库的初始化  
    *  @return: bool  是否成功  
    *  @note:     
    *  @see:      
    */ 
    static bool init();  
 
    /** ORTP模块的逆初始化  
    *  
    *  在系统退出前调用，负责ORTP库的释放  
    *  @return: bool  是否成功  
    *  @note:     
    *  @see:      
    */ 
    static bool deInit();  
 
    /** 创建RTP接收会话  
    *  
    *  负责产生RTP接收端会话，监听服务器端的数据  
    *  @param:  const char * destIP 目的地址的IP  
    *  @param:  int destport 目的地址的监听端口号  
    *  @return: bool  是否成功  
    *  @note:     
    *  @see:      
    */ 
    bool create(const char * destIP, int destport );  
 
    /** 发送RTP数据  
     *  
     *  将指定的buffer中的数据发送到客户端  
     *  @param:  unsigned char * buffer 需要发送的数据  
     *  @param:  int len 有效字节数  
     *  @return: int 实际发送的字节数  
     *  @note:    
     *  @see:     
     */ 
    int send_data( unsigned char *buffer, int len );  
   
private:  
 
    RtpSession *m_pSession;     /** rtp会话句柄 */   
 
    long        m_curTimeStamp; /** 当前时间戳 */   
    int         m_timeStampInc; /** 时间戳增量 */   
 
    char       *m_ssrc;         /** 数据源标识 */   
};  
 
#endif // COrtpServer_H_  
 
//////////////////////////////////////////////////////////////////////////  
//  COPYRIGHT NOTICE  
//  Copyright (c) 2011, 华中科技大学 卢俊（版权声明）  
//  All rights reserved.  
//   
/// @file    CortpServer.cpp  
/// @brief   ortp服务器类实现文件  
///  
/// 实现和提供ortp的服务器端应用接口  
///  
/// @version 1.0     
/// @author  lujun   
/// @date    2011/11/03  
//  
//  
//  修订说明：  
//////////////////////////////////////////////////////////////////////////  
 
#include "COrtpServer.h"  
 
/* the payload type define */ 
#define PAYLOAD_TYPE_VIDEO 34  
 
/* RTP video Send time stamp increase */ 
#define VIDEO_TIME_STAMP_INC  3600  
 
COrtpServer::COrtpServer()  
{  
    m_ssrc     = NULL;  
    m_pSession = NULL;  
    m_timeStampInc = 0;  
    m_curTimeStamp = 0;  
}  
 
COrtpServer::~COrtpServer()  
{  
    if (!m_pSession)  
    {  
        rtp_session_destroy(m_pSession);  
    }  
}  
 
bool COrtpServer::init()  
{  
    int ret;  
    WSADATA wsaData;  
 
    /** 初始化winsocket */   
    if ( WSAStartup(MAKEWORD(2,2), &wsaData) != 0)  
    {  
        return false;  
    }  
 
    ortp_init();  
    ortp_scheduler_init();  
 
    return true;  
}  
 
bool COrtpServer::deInit()  
{  
    ortp_exit();  
 
    if (WSACleanup() == SOCKET_ERROR)  
    {  
        return false;  
    }  
 
    return true;  
}  
 
bool COrtpServer::create( const char * destIP, int destport )  
{  
    m_ssrc = getenv("SSRC");  
 
    m_pSession = rtp_session_new(RTP_SESSION_SENDONLY);   
 
    rtp_session_set_scheduling_mode(m_pSession,1);  
    rtp_session_set_blocking_mode(m_pSession,1);  
    rtp_session_set_remote_addr(m_pSession,destIP,destport);  
 
    if(m_ssrc != NULL)  
    {  
        rtp_session_set_ssrc(m_pSession,atoi(m_ssrc));  
    }  
 
    rtp_session_set_payload_type(m_pSession,PAYLOAD_TYPE_VIDEO);  
    m_timeStampInc = VIDEO_TIME_STAMP_INC;  
 
    return true;  
}  
 
int COrtpServer::send_data( unsigned char *buffer, int len )  
{  
    int sendBytes = 0;  
 
    /** 强转 */   
    const char *sendBuffer = (const char*)buffer;  
 
    sendBytes = rtp_session_send_with_ts(m_pSession,sendBuffer,len,m_curTimeStamp);  
 
    if ( sendBytes > 0)  
    {  
        m_curTimeStamp += m_timeStampInc; /** 增加时间戳 */   
    }     
 
    return sendBytes;  
}


三、测试程序


//////////////////////////////////////////////////////////////////////////  
//  COPYRIGHT NOTICE  
//  Copyright (c) 2011, 华中科技大学 卢俊 （版权声明）  
//  All rights reserved.  
//  
/// @file    main.cpp   
/// @brief   ortp测试文件  
///  
/// 测试ortp发送结构体  
///  
/// @version 1.0    
/// @author  卢俊  
/// @e-mail  lujun.hust@gmail.com  
/// @date    2011/10/19  
//  
//  
//  修订说明：  
//////////////////////////////////////////////////////////////////////////  
 
#include <iostream>  
 
#include "COrtpClient.h"  
#include "COrtpServer.h"  
 
/** 本地IP地址 */ 
const char * LOCAL_IP_ADDR = "127.0.0.1";  
 
/** 本地监听端口 */   
const int LOCAL_RTP_PORT = 8000;  
 
/** 目的监听端口 */   
const int DEST_RTP_PORT = 8000;  
 
/** 目的IP地址 */   
const char * DEST_IP_ADDR  = "127.0.0.1";  
 
/** 一次发送的数据长度 */   
const int SEND_LEN_PER_TIME =  8*1024;  
 
/** 接收缓冲区的总大小 */   
const int RECV_BUFFER_LEN   = 10*1024;  
 
/** 一次接收的数据长度 */   
const int RECV_LEN_PER_TIME = 1024;  
 
bool ortpServer()  
{  
    COrtpServer ortpServer;  
 
    COrtpServer::init();  
 
    if (!ortpServer.create(DEST_IP_ADDR,DEST_RTP_PORT))  
    {  
        std::cout << "ortpServer.create fail!\n";  
        getchar();  
        getchar();  
        return false;  
    }  
 
    unsigned char * buffer = new unsigned char[SEND_LEN_PER_TIME];  
 
    while (1)  
    {  
        if ( ortpServer.send_data(buffer,SEND_LEN_PER_TIME) <= 0)  
        {  
            std::cout << "send fail!\n";  
        }  
 
        Sleep(100);  
        std::cout << "send bytes\n";  
    }  
 
    delete [] buffer;  
 
    COrtpClient::deInit();  
 
    return true;  
}  
 
bool ortpClient()  
{  
    COrtpClient ortpClient;  
 
    COrtpClient::init();      
 
    if (!ortpClient.create(LOCAL_IP_ADDR,LOCAL_RTP_PORT))  
    {  
        std::cout << "ortpClient.create fail!\n";  
        getchar();  
        getchar();  
        return false;  
    }  
 
    char *buffer = new char[RECV_BUFFER_LEN];  
 
    while(1)  
    {  
        int len = RECV_BUFFER_LEN;  
        if (!ortpClient.get_recv_data(buffer,len))  
        {  
            Sleep(10);  
            continue;  
        }  
 
        std::cout << "successful recv,data len =" << len << std::endl;  
    }  
 
    COrtpClient::deInit();  
 
    delete [] buffer;  
 
    return true;  
}  
 
void main()  
{  
    std::cout << "enter num,1 ->client, 2->server! \n";  
 
    int num;  
 
    std::cin >> num;  
 
    while(1)  
    {  
        if (num == 1)  
        {  
            ortpClient();  
            break;  
        }  
        else if (num == 2)  
        {  
            ortpServer();  
            break;  
        }  
        else 
        {  
            std::cout << "please input 1 or 2 !\n";  
        }  
    }  
 
    getchar();  
    getchar();  
}

        

有关ORTP的介绍、RTP的介绍、RTP的负载类型和时间戳的含义等理论性的东西，都可以在我博客中的其他文章中找到，以上就是整个工程的代码，注释不是很多，因为有些地方我也不是特别清楚，比如jitter、scheduling什么的，如果有什么其他疑问欢迎留言或者E-mail来信交流。




本文转自 Jhuster 51CTO博客，原文链接：http://blog.51cto.com/ticktick/704891，如需转载请自行联系原作者

技术小阿哥
目录
相关文章
冷色系456
|
6月前
第七章 用函数实现模块化程序设计
第七章 用函数实现模块化程序设计
冷色系456
22 0
颦颦Admin@123
|
6月前
|
编译器 Linux C语言
C语言：预处理详解（知识点和代码演示）
C语言：预处理详解（知识点和代码演示）
颦颦Admin@123
49 0
游客5atojlwxsluse
|
存储 自然语言处理 程序员
进阶C语言 第七章-------《程序的编译(预处理操作)+链接》 （预编译、编译、汇编、#define、条件编译，#include的包含）知识点+完整思维导图+基本练习题+深入细节+通俗易懂建议收藏（一）
进阶C语言 第七章-------《程序的编译(预处理操作)+链接》 （预编译、编译、汇编、#define、条件编译，#include的包含）知识点+完整思维导图+基本练习题+深入细节+通俗易懂建议收藏（一）
游客5atojlwxsluse
127 0
博客小梦
|
编译器 C语言
你是真的“C”——详解C语言函数模块知识(下篇）
详解C语言函数模块知识
博客小梦
85 0
你是真的“C”——详解C语言函数模块知识(下篇）
清雨小竹
Mystring函数(编程练习代码)
Mystring函数(编程练习代码)
清雨小竹
86 0
IT辰柒_Java
|
编译器 C语言
【初识C语言】/*有关C语言函数部分细节展示*/
【初识C语言】/*有关C语言函数部分细节展示*/
IT辰柒_Java
138 0
【初识C语言】/*有关C语言函数部分细节展示*/
安然无虞
|
算法 程序员 C语言
零基础玩转C语言系列第四章——编程重点内容之函数
编程重点内容之函数
安然无虞
173 0
零基础玩转C语言系列第四章——编程重点内容之函数
诸葛青云h
|
测试技术 Linux C语言
你学不懂C语言，是因为不懂编写C程序的7个步骤
你学不懂C语言，是因为不懂编写C程序的7个步骤
诸葛青云h
2128 0
c里c气的
|
C语言 C++ 编译器
你学不会C语言，是因为不会编写C程序的七个步骤
喜欢这篇文章的朋友可以多多收藏、点赞、关注 一条龙~
c里c气的
1920 0
科技小能手
JSSE编程基本代码
科技小能手
821 0

热门文章

最新文章

  • 1
    Flutter之禅 内存优化篇
  • 2
    《Cadence 16.6电路设计与仿真从入门到精通》——2.4 Design Entry CIS原理图图形界面　
  • 3
    记一次对网络抖动经典案例的分析
  • 4
    国外成人网站xHamster大量用户信息黑市变卖，部分账号涉及英美政府官员
  • 5
    用户密码以BCrypt加密的方式来防范被破解
  • 6
    带你理清CPU，cache和存储器之间的逻辑运作
  • 7
    Git设置代理服务器
  • 8
    【DSW Gallery】PAI-DSW开通及授权
  • 9
    吐血整理：机器学习的30个基本概念，都在这里了（手绘图解）
  • 10
    MOSS站点的迁移(备份还原)
  • 1
    设计模式之 5 大创建型模式，万字长文深剖 ，近 30 张图解！
    48
  • 2
    《C++新特性：为多线程数据竞争检测与预防保驾护航》
    41
  • 3
    Kotlin - 区间与数组
    41
  • 4
    Kotlin - 参数与异常
    39
  • 5
    Kotlin - 运算符与中缀表达式
    34
  • 6
    Kotlin - 函数与Lambda表达式
    23
  • 7
    Kotlin - 分支与循环
    19
  • 8
    天气预报1天-中国气象局-地址查询版免费API接口教程
    20
  • 9
    《C++智能合约与区块链底层交互全解析：构建坚实的去中心化应用桥梁》
    19

    • 相关课程

    更多
  • Python语言基础 - 函数、面向对象、异常处理
  • Go语言核心编程 - 面向对象、文件、单元测试、反射、TCP编程
  • 5天玩转Java面向对象编程
  • Java面向对象编程
  • Python语言基础 - 语法入门
  • Java面向对象开发

    • 相关电子书

    更多
  • 用RxSwift写易维护易读的愉悦代码
  • 《0代码搭应用》
  • 不止代码

    • 相关实验场景

    更多
  • 面向对象-1：类的定义
  • 语言入门-2：基本类型
  • 语言入门-1：环境构建
  • 使用Java面向对象编写网络通信程序应用
  • Python网络通信程序典型应用
    • 下一篇
    阿里云OSS设置跨域访问