Linux下的实时流媒体编程（4）流媒体编程更新

look_w

3.5 控制信息
JRTPLIB是一个高度封装后的RTP库，程序员在使用它时很多时候并不用关心RTCP数据报是如何被发送和接收的，因为这些都可以由JRTPLIB自己来完成。只要PollData()或者SendPacket()方法被成功调用，JRTPLIB就能够自动对到达的RTCP数据报进行处理，并且还会在需要的时候发送RTCP数据报，从而能够确保整个RTP会话过程的正确性。
而另一方面，通过调用RTPSession类提供的SetLocalName()、SetLocalEMail()、SetLocalLocation()、SetLocalPhone()、SetLocalTool()和SetLocalNote()方法，JRTPLIB又允许程序员对RTP会话的控制信息进行设置。所有这些方法在调用时都带有两个参数，其中第一个参数是一个char型的指针，指向将要被设置的数据；而第二个参数则是一个int型的数值，表明该数据中的前面多少个字符将会被使用。例如下面的语句可以被用来设置控制信息中的电子邮件地址：

1	sess.SetLocalEMail("xiaowp@linuxgam.com",19);

在RTP会话过程中，不是所有的控制信息都需要被发送，通过调用RTPSession类提供的EnableSendName()、EnableSendEMail()、EnableSendLocation()、EnableSendPhone()、EnableSendTool()和EnableSendNote()方法，可以为当前RTP会话选择将被发送的控制信息。
3.6 实际应用
最后通过一个简单的流媒体发送-接收实例，介绍如何利用JRTPLIB来进行实时流媒体的编程。清单3给出了数据发送端的完整代码，它负责向用户指定的IP地址和端口，不断地发送RTP数据包：
代码清单3：sender.cpp

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51

#include <stdio.h> #include <string.h> #include "rtpsession.h" // 错误处理函数 void checkerror(int err) {   if (err < 0) {     char* errstr = RTPGetErrorString(err);     printf("Error:%s\\n", errstr);     exit(-1);   } } int main(int argc, char** argv) {   RTPSession sess;   unsigned long destip;   int destport;   int portbase = 6000;   int status, index;   char buffer[128];   if (argc != 3) {     printf("Usage: ./sender destip destport\\n");     return -1;   }   // 获得接收端的IP地址和端口号   destip = inet_addr(argv[1]);   if (destip == INADDR_NONE) {     printf("Bad IP address specified.\\n");     return -1;   }   destip = ntohl(destip);   destport = atoi(argv[2]);   // 创建RTP会话   status = sess.Create(portbase);   checkerror(status);   // 指定RTP数据接收端   status = sess.AddDestination(destip, destport);   checkerror(status);   // 设置RTP会话默认参数   sess.SetDefaultPayloadType(0);   sess.SetDefaultMark(false);   sess.SetDefaultTimeStampIncrement(10);   // 发送流媒体数据   index = 1;   do {     sprintf(buffer, "%d: RTP packet", index ++);     sess.SendPacket(buffer, strlen(buffer));     printf("Send packet !\\n");   } while(1);   return 0; }

清单4则给出了数据接收端的完整代码，它负责从指定的端口不断地读取RTP数据包：
代码清单4：receiver.cpp

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44

#include <stdio.h> #include "rtpsession.h" #include "rtppacket.h" // 错误处理函数 void checkerror(int err) {   if (err < 0) {     char* errstr = RTPGetErrorString(err);     printf("Error:%s\\n", errstr);     exit(-1);   } } int main(int argc, char** argv) {   RTPSession sess;   int localport;   int status;   if (argc != 2) {     printf("Usage: ./sender localport\\n");     return -1;   }    // 获得用户指定的端口号   localport = atoi(argv[1]);   // 创建RTP会话   status = sess.Create(localport);   checkerror(status);   do {     // 接受RTP数据     status = sess.PollData();     // 检索RTP数据源     if (sess.GotoFirstSourceWithData()) {       do {         RTPPacket* packet;         // 获取RTP数据报         while ((packet = sess.GetNextPacket()) != NULL) {           printf("Got packet !\\n");           // 删除RTP数据报           delete packet;         }       } while (sess.GotoNextSourceWithData());     }   } while(1);   return 0; }