example1.cpp

基于JRTPLIB的程序,用于不断向目标端口发送RTP包

#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)
{
#ifdef WIN32
	WSADATA dat;
	WSAStartup(MAKEWORD(2,2),&dat);
#endif
  
  RTPSession sess;
  unsigned long destip;
  int i=0;
  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);
    do {
   sprintf(buffer, "%d: RTP packet", index ++);
   sess.SendPacket(buffer, strlen(buffer));
   printf("Send packet !\\n");
   i++;
  } while(i<10);

  return 0;
}