linux 下基于jrtplib库的实时传送实现

时间  2020-04-18
标签 linux 基于 jrtplib 实时 传送 实现 栏目 Linux 繁體版
原文   原文链接
linux 下基于jrtplib库的实时传送实现
1、RTP 是进行实时流媒体传输的标准协议和关键技术
实时传输协议（Real-time Transport Protocol，PRT）是在 Internet 上处理多媒体数据流的一种网络协议，利用它可以在一对一（unicast，单播）或者一对多（multicast，多播）的网络环境中实现传流媒体数据的 实时传输。RTP 一般使用 UDP 来进行多媒体数据的传输，但若是须要的话可使用 TCP 或者 ATM 等其它协议。

协议分析 ：每个RTP数据报都由头部（Header）和负载（Payload）两个部分组成，其中头部前 12 个字节的含义是固定的，而负载则能够是音频或者视频数据。

     RTP 是目前解决流媒体实时传输问题的最好办法，要在 Linux 平台上进行实时传送编程，能够考虑使用一些开放源代码的 RTP 库，如 LIBRTP、JRTPLIB 等。JRTPLIB 是一个面向对象的 RTP 库，它彻底遵循 RFC 1889 设计，在不少场合下是一个很是不错的选择。JRTPLIB 是一个用 C++ 语言实现的 RTP 库，这个库使用socket 机制实现网络通信 所以能够运行在 Windows、Linux、FreeBSD、Solaris、Unix和VxWorks 等多种操做系统上。
2、JRTPLIB 库的使用方法及程序实现
(1)JRTPLIB  函数 的使用
a、在使用 JRTPLIB 进行实时流媒体数据传输以前，首先应该生成 RTPSession 类的一个实例来表示这次 RTP 会话，而后调用 Create() 方法来对其进行初始化操做。RTPSession 类的 Create() 方法只有一个参数，用来指明这次 RTP 会话所采用的端口号。
RTPSession sess;  sess.Create(5000);

b、设置恰当的时戳单元，是 RTP 会话初始化过程所要进行的另一项重要工做，这是经过调用 RTPSession 类的 SetTimestampUnit() 方法来实现的，该方法一样也只有一个参数，表示的是以秒为单元的时戳单元。
sess.SetTimestampUnit(1.0/8000.0);

c、当 RTP 会话成功创建起来以后，接下去就能够开始进行流媒体数据的实时传输了。首先须要设置好数据发送的目标地址，RTP 协议容许同一会话存在多个目标地址，这能够经过调用 RTPSession 类的 AddDestination()、DeleteDestination() 和 ClearDestinations() 方法来完成。例如，下面的语句表示的是让 RTP 会话将数据发送到本地主机的 6000 端口：

unsigned long addr = ntohl(inet_addr("127.0.0.1"));
sess.AddDestination(addr, 6000);

d、目标地址所有指定以后，接着就能够调用 RTPSession 类的 SendPacket() 方法，向全部的目标地址发送流媒体数据。SendPacket() 是 RTPSession 类提供的一个重载函数
对于同一个 RTP 会话来说，负载类型、标识和时戳增量一般来说都是相同的，JRTPLIB 容许将它们设置为会话的默认参数，这是经过调用 RTPSession 类的 SetDefaultPayloadType()、SetDefaultMark() 和 SetDefaultTimeStampIncrement() 方法来完成的。为 RTP 会话设置这些默认参数的好处是能够简化数据的发送，例如，若是为 RTP 会话设置了默认参数：

sess.SetDefaultPayloadType(0);
 sess.SetDefaultMark(false);  
sess.SetDefaultTimeStampIncrement(10);



以后在进行数据发送时只需指明要发送 的数据及其长度就能够了：

sess.SendPacket(buffer, 5);


e、对于流媒体数据的接收端，首先须要调用 RTPSession 类的 PollData() 方法来接收发送过来的 RTP 或者 RTCP 数据报。因为同一个 RTP 会话中容许有多个参与者（源），你既能够经过调用 RTPSession 类的 GotoFirstSource() 和 GotoNextSource() 方法来遍历全部的源，也能够经过调用 RTPSession 类的 GotoFirstSourceWithData() 和 GotoNextSourceWithData() 方法来遍历那些携带有数据的源。在从 RTP 会话中检测出有效的数据源以后，接下去就能够调用 RTPSession 类的 GetNextPacket() 方法从中抽取 RTP 数据报，当接收到的 RTP 数据报处理完以后，必定要记得及时释放。

JRTPLIB 为 RTP 数据报定义了三种接收模式，其中每种接收模式都具体规定了哪些到达的 RTP 数据报将会被接受，而哪些到达的 RTP 数据报将会被拒绝。经过调用 RTPSession 类的 SetReceiveMode() 方法能够设置下列这些接收模式：
? RECEIVEMODE_ALL　　缺省的接收模式，全部到达的 RTP 数据报都将被接受；
? RECEIVEMODE_IGNORESOME　　除了某些特定的发送者以外，全部到达的 RTP 数据报都将被接受，而被拒绝的发送者列表能够经过调用 AddToIgnoreList()、DeleteFromIgnoreList() 和 ClearIgnoreList() 方法来进行设置；
? RECEIVEMODE_ACCEPTSOME　　除了某些特定的发送者以外，全部到达的 RTP 数据报都将被拒绝，而被接受的发送者列表能够经过调用 AddToAcceptList ()、DeleteFromAcceptList 和 ClearAcceptList () 方法来进行设置。 下面是采用第三种接收模式的程序示例。
if (sess.GotoFirstSourceWithData()) {  
 do {  
  sess.AddToAcceptList(remoteIP, allports,portbase);
         sess.SetReceiveMode(RECEIVEMODE_ACCEPTSOME);

   RTPPacket *pack;        
   pack = sess.GetNextPacket();            // 处理接收到的数据    
   delete pack;   }
 while (sess.GotoNextSourceWithData());
 }


 （2）程序流程图
发送：得到接 收端的 IP 地址和端口号        建立 RTP 会话        指定 RTP 数据接收端 设置 RTP 会话默认参数   发送流媒体数据
接收：得到用户指定的端口号  建立RTP会话  设置接收模式  接受RTP数据  检索RTP数据源  获取RTP数据报  删除RTP数据报


3、环境搭建及编译方法
引用
（1）Toolchain的安装
首先找到xscale-arm-toolchain.tgz文件，假设该文件包放在/tmp/下
#cd /
#tar -zxvf /tmp/xscale-arm-toolchain.tgz
再设置环境变量
#export PATH=/usr/local/arm-linux/bin:$PATH
最后检查一下交叉编译工具是否安装成功
#arm-linux-g++ --version
看是否显示arm-linux-g++的版本，若有则安装成功。
（2）JRTPLIB 库的交叉编译及安装
首先从 JRTPLIB 的网站（http://lumumba.luc.ac.be/jori/jrtplib/jrtplib.htmll） 下载最新的源码包，此处使用的是jrtplib-2.8.tar，假设下载后的源码包放在/tmp下，执 行下面的命令对其解压缩：
#cd /tmp
#tar -zxvf jrtplib-2.8.tar
而后要对jrtplib进行配置和编译
#cd jrtplib-2.8
#./configure CC=arm-linux-g++ cross-compile=yes
修改Makefile文件
将连接命令ld 和ar改成arm-linux-ld和 arm-linux-ar
#make
最后再执行以下命令就能够完成 JRTPLIB 的安装：
#make install
(3)程序编译
a、配置编译环境
能够用export来配置，也能够用编写Makefile的方法。这里采用Makefile。
编写Makefile&:
INCL = -I/usr/local/include
CFLAGS = -pipe -O2 -fno-strength-reduce
LFLAGS = /usr/local/lib/libjrtp.a -L/usr/X11R6/lib
LIBS = -LX11 -LXext /usr/local/lib/libjrtp.a
CC = arm-linux-g++

main:main.o
$(CC) $(LFLAGS) $(INCL) -o main main.o $(LIBS)
main.o:main.cpp

clean:
rm -f main
rm -f *.o

.SUFFIXES:.cpp
.cpp.o:
$(CC) -c $(CFLAGS) $(INCL) -o $@ $<         /*  $@表示目标的完整名字      */
         /* $<表示第一个依赖文件的名字 */
b、编译
假设发送和接收程序分别放在/tmp/send和/tmp/receive目录下
#cd /tmp/send
#make
#cd /tmp/receive
#make

4、易出错误及注意问题
引用
一、找不到一些标准的最 基本的一些头文件。
 主要是由于Toolchain路径没安装对，要 严格按照步骤安装。
二、找不到使用的jrtplib库中的一些头文件。
 在 jrtplib的安装目录下，include路径下不能再有别的目录。
三、recieve函数接收数据包不能正确提出所要数据。
 因为每个RTP数据报都由头部（Header）和负载（Payload）两个部分组成，若使用getrawdata()是返回整个数据包的数据，包含 传输媒体的类型、格式、序列号、时间戳以及是否有附加数据等信息。getpayload()函数是返回所发送的数据。二者必定要分清。
四、设置RECEIVEMODE_ACCEPTSOME　　接收模式后，运行程序接收端不能接包。
 IP地址格式出了问题。iner_addr()与ntohl()函数要用对，不然参数传不进去，接受列表中无值，固然接收不了数据包。
五、编译经过，但测试时接收端不能接收到数据。
 多是接收机防火墙未关闭。运行：
 #iptables -F
 也多是IP地址没有设置好。运行：
 #ifocnfig eth0  *.*.*.*  netmask *.*.*.*
六、使用jrtolib库时，在程序中include 后最好加上库所在的路径。
5、程序

send:
view plain print ?
  1. #include <stdio.h>  
  2. #include <string.h>  
  3. #include "rtpsession.h"  
  4.   
  5. // 错误处理函数  
  6. void checkerror(int err)  
  7. {  
  8.   if (err < 0) {  
  9.     char* errstr = RTPGetErrorString(err);  
  10.     printf("Error:%s\\n", errstr);  
  11.     exit(-1);  
  12.   }  
  13. }  
  14.   
  15. int main(int argc, char** argv)  
  16. {  
  17.   RTPSession sess;  
  18.   unsigned long destip;  
  19.   int destport;  
  20.   int portbase = 6000;  
  21.   int status, index;  
  22.   char buffer[128];  
  23.   
  24.   if (argc != 3) {  
  25.     printf("Usage: ./sender destip destport\\n");  
  26.     return -1;  
  27.   }  
  28.   
  29.   // 得到接收端的IP地址和端口号  
  30.   destip = inet_addr(argv[1]);  
  31.   if (destip == INADDR_NONE) {  
  32.     printf("Bad IP address specified.\\n");  
  33.     return -1;  
  34.   }  
  35.   destip = ntohl(destip);  
  36.   destport = atoi(argv[2]);  
  37.   
  38.   // 建立RTP会话  
  39.   status = sess.Create(portbase);  
  40.   checkerror(status);  
  41.   
  42.   // 指定RTP数据接收端  
  43.   status = sess.AddDestination(destip, destport);  
  44.   checkerror(status);  
  45.   
  46.   // 设置RTP会话默认参数  
  47.   sess.SetDefaultPayloadType(0);  
  48.   sess.SetDefaultMark(false);  
  49.   sess.SetDefaultTimeStampIncrement(10);  
  50.   
  51.   // 发送流媒体数据  
  52.   index = 1;  
  53.   do {  
  54.     sprintf(buffer, "%d: RTP packet", index ++);  
  55.     sess.SendPacket(buffer, strlen(buffer));  
  56.     printf("Send packet !\\n");  
  57.   } while(1);  
  58.   
  59.   return 0;  
  60. }  





receive:
view plain print ?
  1. #include <stdio.h>  
  2. #include "rtpsession.h"  
  3. #include "rtppacket.h"  
  4.   
  5. // 错误处理函数  
  6. void checkerror(int err)  
  7. {  
  8.   if (err < 0) {  
  9.     char* errstr = RTPGetErrorString(err);  
  10.     printf("Error:%s\\n", errstr);  
  11.     exit(-1);  
  12.   }  
  13. }  
  14.   
  15. int main(int argc, char** argv)  
  16. {  
  17.   RTPSession sess;  
  18.   int localport,portbase;  
  19.   int status;  
  20.   unsigned long remoteIP;  
  21.   if (argc != 4) {  
  22.     printf("Usage: ./sender localport\\n");  
  23.     return -1;  
  24.   }  
  25.   
  26.    // 得到用户指定的端口号  
  27.      
  28.   remoteIP = inet_addr(argv[1]);  
  29.   localport = atoi(argv[2]);  
  30.   portbase = atoi(argv[3]);  
  31.   // 建立RTP会话  
  32.   status = sess.Create(localport);  
  33.   checkerror(status);  
  34.     
  35.   //RTPHeader *rtphdr;  
  36.   unsigned long timestamp1;  
  37.   unsigned char * RawData;  
  38.   unsigned char temp[30];  
  39.   int lengh ,i;  
  40.   bool allports = 1;  
  41.     
  42.   sess.AddToAcceptList(remoteIP, allports,portbase);  
  43.     
  44.      do {  
  45.  //设置接收模式  
  46.         sess.SetReceiveMode(RECEIVEMODE_ACCEPTSOME);  
  47.    sess.AddToAcceptList(remoteIP, allports,portbase);  
  48.   
  49.     // 接受RTP数据  
  50.     status = sess.PollData();  
  51.   
  52.       
  53.  // 检索RTP数据源  
  54.     if (sess.GotoFirstSourceWithData()) {  
  55.       do {  
  56.           
  57.         RTPPacket* packet;  
  58.         // 获取RTP数据报  
  59.         while ((packet = sess.GetNextPacket()) != NULL) {  
  60.           printf("Got packet !\n");  
  61.   
  62.    timestamp1 = packet->GetTimeStamp();  
  63.    lengh=packet->GetPayloadLength();  
  64.    RawData=packet->GetPayload();  
  65.      
  66.    for(i=0;i<lengh;i++){  
  67.       temp[i]=RawData[i];  
  68.   printf("%c",temp[i]);  
  69.    }  
  70.    temp[i]='\0';  
  71.    printf("  timestamp: %d lengh=%d data:%s\n",timestamp1,lengh,&temp);  
  72.           // 删除RTP数据报  
  73.      
  74.           delete packet;  
  75.         }  
  76.       } while (sess.GotoNextSourceWithData());  
  77.     }  
  78.   } while(1);  
  79.   
  80.   return 0;  
  81. }  
相关日志
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程