linux下的实时流媒体编程.html

基于Linux的实时流媒体编程介绍以及实现

用RTPGetErrorString()函数得到。RTPGetErrorString()函数将错误代码作为参数传入，然后返回该错误代码所对应的错
误信息。清单2给出了一个更加完整的初始化框架，它可以对RTP会话初始化过程中所产生的错误进行更好的处理：</p>
<p>代码清单2：framework.cpp</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

#include &lt;stdio.h&gt;
#include "rtpsession.h"

int main(void)
{
  RTPSession sess;
  int status;
  char* msg;

  sess.Create(6000);
  msg = RTPGetErrorString(status);
  printf("Error String: %s\\n", msg);
  return 0;
}
</code></pre></td></tr></tbody></table>



<p>设置恰当的时戳单元，是RTP会话初始化过程所要进行的另外一项重要工作，这是通过调用RTPSession类的SetTimestampUnit
()方法来实现的，该方法同样也只有一个参数，表示的是以秒为单元的时戳单元。例如，当使用RTP会话传输8000Hz采样的音频数据时，由于时戳每秒钟
将递增8000，所以时戳单元相应地应该被设置成1/8000：</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

sess.SetTimestampUnit(1.0/8000.0);
</code></pre></td></tr></tbody></table>



<p><b>3.3 数据发送</b></p>

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


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

unsigned long addr = ntohl(inet_addr("127.0.0.1"));
sess.AddDestination(addr, 6000);
</code></pre></td></tr></tbody></table>



<p>目标地址全部指定之后，接着就可以调用RTPSession类的SendPacket()方法，向所有的目标地址发送流媒体数据。SendPacket()是RTPSession类提供的一个重载函数，它具有下列多种形式：</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

int SendPacket(void *data,int len)
int SendPacket(void *data,int len,unsigned char pt,bool mark,unsigned long timestampinc)
int SendPacket(void *data,int len,unsigned short hdrextID,void *hdrextdata,int numhdrextwords)
int SendPacket(void *data,int len,unsigned char pt,bool mark,unsigned long timestampinc,unsigned short hdrextID,void *hdrextdata,int numhdrextwords)
</code></pre></td></tr></tbody></table>




<p>SendPacket()最典型的用法是类似于下面的语句，其中第一个参数是要被发送的数据，而第二个参数则指明将要发送数据的长度，再往后依次是RTP负载类型、标识和时戳增量。</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

sess.SendPacket(buffer, 5, 0, false, 10);
</code></pre></td></tr></tbody></table>



<p>对于同一个RTP会话来讲，负载类型、标识和时戳增量通常来讲都是相同的，JRTPLIB允许将它们设置为会话的默认参数，这是通过调用
RTPSession类的SetDefaultPayloadType()、SetDefaultMark()和
SetDefaultTimeStampIncrement()方法来完成的。为RTP会话设置这些默认参数的好处是可以简化数据的发送，例如，如果为
RTP会话设置了默认参数：</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

sess.SetDefaultPayloadType(0);
sess.SetDefaultMark(false);
sess.SetDefaultTimeStampIncrement(10);
</code></pre></td></tr></tbody></table>



<p>之后在进行数据发送时只需指明要发送的数据及其长度就可以了：</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

sess.SendPacket(buffer, 5);
</code></pre></td></tr></tbody></table>



<p><b>3.4 数据接收</b></p>

<p>对于流媒体数据的接收端，首先需要调用RTPSession类的PollData()方法来接收发送过来的RTP或者RTCP数据报。由于同一个
RTP会话中允许有多个参与者（源），你既可以通过调用RTPSession类的GotoFirstSource()和GotoNextSource()
方法来遍历所有的源，也可以通过调用RTPSession类的GotoFirstSourceWithData()和
GotoNextSourceWithData()方法来遍历那些携带有数据的源。在从RTP会话中检测出有效的数据源之后，接下去就可以调用
RTPSession类的GetNextPacket()方法从中抽取RTP数据报，当接收到的RTP数据报处理完之后，一定要记得及时释放。下面的代码
示范了该如何对接收到的RTP数据报进行处理：</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

if (sess.GotoFirstSourceWithData()) {
  do {
    RTPPacket *pack;					
    pack = sess.GetNextPacket();					
    // 处理接收到的数据
    delete pack;
  } while (sess.GotoNextSourceWithData());
}
</code></pre></td></tr></tbody></table>



<p>JRTPLIB为RTP数据报定义了三种接收模式，其中每种接收模式都具体规定了哪些到达的RTP数据报将会被接受，而哪些到达的RTP数据报将会被拒绝。通过调用RTPSession类的SetReceiveMode()方法可以设置下列这些接收模式：</p>


<ul>
<li><b>RECEIVEMODE_ALL</b>　　缺省的接收模式，所有到达的RTP数据报都将被接受；</li>
<li><b>RECEIVEMODE_IGNORESOME</b>　　除了某些特定的发送者之外，所有到达的RTP数据报都将被接受，而被拒绝的发送者列表可以通过调用AddToIgnoreList()、DeleteFromIgnoreList()和ClearIgnoreList()方法来进行设置；</li>
<li><b>RECEIVEMODE_ACCEPTSOME</b>　　除了某些特定的发送者之外，所有到达的RTP数据报都将被拒绝，而被接受的发送者列表可以通过调用AddToAcceptList ()、DeleteFromAcceptList和ClearAcceptList ()方法来进行设置。</li>
</ul>



<p><b>3.5 控制信息</b></p>

<p>JRTPLIB是一个高度封装后的RTP库，程序员在使用它时很多时候并不用关心RTCP数据报是如何被发送和接收的，因为这些都可以由
JRTPLIB自己来完成。只要PollData()或者SendPacket()方法被成功调用，JRTPLIB就能够自动对到达的RTCP数据报进行
处理，并且还会在需要的时候发送RTCP数据报，从而能够确保整个RTP会话过程的正确性。</p>

<p>而另一方面，通过调用RTPSession类提供的SetLocalName()、SetLocalEMail()、
SetLocalLocation()、SetLocalPhone()、SetLocalTool()和SetLocalNote()方法，
JRTPLIB又允许程序员对RTP会话的控制信息进行设置。所有这些方法在调用时都带有两个参数，其中第一个参数是一个char型的指针，指向将要被设
置的数据；而第二个参数则是一个int型的数值，表明该数据中的前面多少个字符将会被使用。例如下面的语句可以被用来设置控制信息中的电子邮件地址：</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

sess.SetLocalEMail("[e-mail]",19);
</code></pre></td></tr></tbody></table>



<p>在RTP会话过程中，不是所有的控制信息都需要被发送，通过调用RTPSession类提供的EnableSendName()、
EnableSendEMail()、EnableSendLocation()、EnableSendPhone()、EnableSendTool
()和EnableSendNote()方法，可以为当前RTP会话选择将被发送的控制信息。</p>

<p><b>3.6 实际应用</b></p>

<p>最后通过一个简单的流媒体发送-接收实例，介绍如何利用JRTPLIB来进行实时流媒体的编程。清单3给出了数据发送端的完整代码，它负责向用户指定的IP地址和端口，不断地发送RTP数据包：</p>


<p>代码清单3：sender.cpp</p>


<table bgcolor="#cccccc" border="1" cellpadding="5" cellspacing="0" width="100%">
<tbody><tr><td><pre><code>

#include &lt;stdio.h&gt;
#include &lt;string.h&gt;
#include "rtpsession.h"

// 错误处理函数
void checkerror(int err)
{
  if (err &lt; 0) {