电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛

标题: Linux下的实时流媒体编程（4）流媒体编程更新 [打印本页]

作者: look_w 时间: 2018-5-7 19:20 标题: Linux下的实时流媒体编程（4）流媒体编程更新

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;
}

欢迎光临电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/)