鉴于很多网友找我要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，如需转载请自行联系原作者