当前位置:文档之家› VC+6+RTP流媒体传输协议编程实例(jrtplib)

VC+6+RTP流媒体传输协议编程实例(jrtplib)

资源下载:/source/444512实时流协议RTSP(RealTimeStreamingProtocol)是由RealNetworks和Netscape共同提出的,该协议定义了一对多应用程序如何有效地通过IP网络传送多媒体数据。

RTSP在体系结构上位于RTP(实时传输)和RTCP(实时控制)之上,它使用TCP或RTP完成数据传输。

HTTP与RTSP相比,HTTP传送HTML,而RTP传送的是多媒体数据。

HTTP请求由客户机发出,服务器作出响应;使用RTSP时,客户机和服务器都可以发出请求,即RTSP可以是双向的。

实时流协议(RTSP)是应用级协议,控制实时数据的发送。

RTSP提供了一个可扩展框架,使实时数据,如音频与视频,的受控、点播成为可能。

RTSP是应用级的协议,完成多媒体服务器的远程控制,控制信息的传输可以使用TCP,控制指令包括如:Setup、Play、Record、Pause、Teardwon等等。

对于流媒体应用,用户和服务器都可以发出请求,请求包括几种连接方法:持久、每个请求/响应传输一个连接、无连接。

常见的URL流媒体地址如:rtsp://:554RTP 数据报组成:Header + PayloadRTCP:应用程序启动RTP会话时将同时占用两个端口,供RTP和RTCP使用。

如果有必要,RTP使用时可以有两个伴随文档:1)配置文档,定义负载的编码类型和格式。

2)负载格式的规范文档。

在流传输过程中,有两类服务完成对流的转发处理:1)译流服务器Translator,进入的流在流出时发生变化,作用之一是更好地穿越防火墙。

2)混流服务器Mixer,多个流进入,合并后变成一个流流出。

由于进入的流可能有多个源,比如视频会议,会有多个话筒和视频头等等情况,对于RTP来说,就有一个同步化源的问题,因此,RTP协议中用SSRC(Synchronization Source)字段来供Mixer实现同步功能。

Translator的一个作用是多播变成多个单播。

为了提供播放和回放功能,RTP提供时间标签+序列号,在流动的概念中,时间标签是最重要的信息。

RTP报文不提供长度和报文边界的描述。

RTP虽然是传输层协议,但没有在OSI体系中作为单独的层来使用。

RTP是目前解决流媒体实时传输问题的最好办法,如果要开发,可以选择JRTPLIB库。

JRTPLIB是一个面向对象的RTP库,它完全遵循RFC 1889设计。

JRTPLIB是一个用C++语言实现的RTP库,目前已经可以运行在Windows、Linux、FreeBSD、Solaris、Unix和VxWorks等多种操作系统上。

了解更多RTP参考:/zouzheng/archive/2008/01/04/38449.html下面的例子参考jrtplib的example1,加了解析负载的部分。

// RTPClient.cpp : Defines the entry point for the console application.//#include "stdafx.h"#include "rtpsession.h"#include "rtppacket.h"#include "rtpudpv4transmitter.h"#include "rtpipv4address.h"#include "rtpsessionparams.h"#include "rtperrors.h"#include <winsock2.h>#include <stdlib.h>#include <stdio.h>#include "windows.h"#include <iostream>#include <string>using namespace std;#pragma comment(lib,"jrtplib.lib")#pragma comment(lib,"jthread.lib")#pragma comment(lib,"WS2_32.lib")void checkerror(int rtperr)...{if (rtperr < 0)...{std::cout << "ERROR: " << RTPGetErrorString(rtperr) << std::endl;exit(-1);}}int main(int argc, char* argv[])...{#ifdef WIN32WSADATA dat;WSAStartup(MAKEWORD(2,2),&dat);#endif // WIN32RTPSession sess;uint16_t portbase,destport;uint32_t destip;std::string ipstr;int status,i,num;BYTE *pBuffer;BYTE *pfBuffer;//输入一些必要信息std::cout << "Enter local portbase:" << std::endl;std::cin >> portbase;std::cout << std::endl;std::cout << "Enter the destination IP address" << std::endl;std::cin >> ipstr;destip = inet_addr(ipstr.c_str());if (destip == INADDR_NONE)...{std::cerr << "Bad IP address specified" << std::endl;return -1;}destip = ntohl(destip);std::cout << "Enter the destination port" << std::endl;std::cin >> destport;std::cout << std::endl;std::cout << "Number of packets you wish to be sent:" << std::endl;std::cin >> num;// 创建RTP sessionRTPUDPv4TransmissionParams transparams;RTPSessionParams sessparams;// IMPORTANT: The local timestamp unit MUST be set, otherwise // RTCP Sender Report info will be calculated wrong// In this case, we'll be sending 10 samples each second, so we'll // put the timestamp unit to (1.0/10.0)sessparams.SetOwnTimestampUnit(1.0/10.0);sessparams.SetAcceptOwnPackets(true);transparams.SetPortbase(portbase);status = sess.Create(sessparams,&transparams);checkerror(status);RTPIPv4Address addr(destip,destport);status = sess.AddDestination(addr);checkerror(status);for (i = 1 ; i <= num ; i++)...{printf(" Sending packet %d/%d ",i,num);// 发送数据“1234567890”status = sess.SendPacket((void *)"1234567890",10,0,false,10);checkerror(status);sess.BeginDataAccess();// check incoming packetsif (sess.GotoFirstSourceWithData())...{do...{RTPPacket *pack;while ((pack = sess.GetNextPacket()) != NULL)...{// You can examine the data hereprintf("Got packet ! ");std::cout << "Got packet with "<< "extended sequence number "<< pack->GetExtendedSequenceNumber()<< " from SSRC " << pack->GetSSRC()<< std::endl;int dataLength = pack->GetPayloadLength();pfBuffer =(unsigned char*)pack->GetPayloadData();pBuffer = new BYTE[dataLength + 1];memcpy(pBuffer, pfBuffer, dataLength);pBuffer[dataLength] = 0;std::cout << pBuffer << std::endl;// we don't longer need the packet, so// we'll delete itsess.DeletePacket(pack);}} while (sess.GotoNextSourceWithData());}sess.EndDataAccess();#ifndef RTP_SUPPORT_THREADstatus = sess.Poll();checkerror(status);#endif // RTP_SUPPORT_THREADRTPTime::Wait(RTPTime(1,0));}sess.BYEDestroy(RTPTime(10,0),0,0);#ifdef WIN32WSACleanup();#endif // WIN32return 0;}编译注意修改每个Source File的code generation下的Use run-time library为Debug Multithreaded DLL。

相关主题