流媒体协议

VC6RTP流媒体传输协议编程实例实时流协议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://media.example.com:554RTP数据报组成：Header+PayloadRTCP：应用程序启动RTP会话时将同时占用两个端口，供RTP和RTCP使用。如果有必要，RTP使用时可以有两个伴随文档：1）配置文档，定义负载的编码类型和格式。2）负载格式的规范文档。在流传输过程中，有两类服务完成对流的转发处理：1）译流服务器Translator，进入的流在流出时发生变化，作用之一是更好地穿越防火墙。2）混流服务器Mixer，多个流进入，合并后变成一个流流出。由于进入的流可能有多个源，比如视频会议，会有多个话筒和视频头等等情况，对于RTP来说，就有一个同步化源的问题，因此，RTP协议中用SSRC（SynchronizationSource）字段来供Mixer实现同步功能。Translator的一个作用是多播变成多个单播。为了提供播放和回放功能，RTP提供时间标签+序列号，在流动的概念中，时间标签是最重要的信息。RTP报文不提供长度和报文边界的描述。RTP虽然是传输层协议，但没有在OSI体系中作为单独的层来使用。RTP是目前解决流媒体实时传输问题的最好办法，如果要开发，可以选择JRTPLIB库。JRTPLIB是一个面向对象的RTP库，它完全遵循RFC1889设计。JRTPLIB是一个用C++语言实现的RTP库，目前已经可以运行在Windows、Linux、FreeBSD、Solaris、Unix和VxWorks等多种操作系统上。了解更多RTP参考：下面的例子参考jrtplib的example1,加了解析负载的部分。//RTPClient.cpp:Definestheentrypointfortheconsoleapplication.//#includestdafx.h#includertpsession.h#includertppacket.h#includertpudpv4transmitter.h#includertpipv4address.h#includertpsessionparams.h#includertperrors.h#includewinsock2.h#includestdlib.h#includestdio.h#includewindows.h#includeiostream#includestringusingnamespacestd;#pragmacomment(lib,jrtplib.lib)#pragmacomment(lib,jthread.lib)#pragmacomment(lib,WS2_32.lib)voidcheckerror(intrtperr)...{if(rtperr0)...{std::coutERROR:RTPGetErrorString(rtperr)std::endl;exit(-1);}}intmain(intargc,char*argv[])...{#ifdefWIN32WSADATAdat;WSAStartup(MAKEWORD(2,2),&dat);#endif//WIN32RTPSessionsess;uint16_tportbase,destport;uint32_tdestip;std::stringipstr;intstatus,i,num;BYTE*pBuffer;BYTE*pfBuffer;//输入一些必要信息std::coutEnterlocalportbase:std::endl;std::cinportbase;std::coutstd::endl;std::coutEnterthedestinationIPaddressstd::endl;std::cinipstr;destip=inet_addr(ipstr.c_str());if(destip==INADDR_NONE)...{std::cerrBadIPaddressspecifiedstd::endl;第2/6页return-1;}destip=ntohl(destip);std::coutEnterthedestinationportstd::endl;std::cindestport;std::coutstd::endl;std::coutNumberofpacketsyouwishtobesent:std::endl;std::cinnum;//创建RTPsessionRTPUDPv4TransmissionParamstransparams;RTPSessionParamssessparams;//IMPORTANT:ThelocaltimestampunitMUSTbeset,otherwise//RTCPSenderReportinfowillbecalculatedwrong//Inthiscase,we'llbesending10sampleseachsecond,sowe'll//putthetimestampunitto(1.0/10.0)sessparams.SetOwnTimestampUnit(1.0/10.0);sessparams.SetAcceptOwnPackets(true);transparams.SetPortbase(portbase);status=sess.Create(sessparams,&transparams);checkerror(status);RTPIPv4Addressaddr(destip,destport);status=sess.AddDestination(addr);checkerror(status);for(i=1;i=num;i++)...{printf(Sendingpacket%d/%d,i,num);//发送数据“1234567890”status=sess.SendPacket((void*)1234567890,10,0,false,10);checkerror(status);sess.BeginDataAccess();//checkincomingpacketsif(sess.GotoFirstSourceWithData())第3/6页...{do...{RTPPacket*pack;while((pack=sess.GetNextPacket())!=NULL)...{//Youcanexaminethedatahereprintf(Gotpacket!);std::coutGotpacketwithextendedsequencenumberpack-GetExtendedSequenceNumber()fromSSRCpack-GetSSRC()std::endl;intdataLength=pack-GetPayloadLength();pfBuffer=(unsignedchar*)pack-GetPayloadData();pBuffer=newBYTE[dataLength+1];memcpy(pBuffer,pfBuffer,dataLength);pBuffer[dataLength]=0;std::coutpBufferstd::endl;//wedon'tlongerneedthepacket,so//we'lldeleteitsess.DeletePacket(pack);}}while(sess.GotoNextSourceWithData());}sess.EndDataAccess();#ifndefRTP_SUPPORT_THREADstatus=sess.Poll();checkerror(status);#endif//RTP_SUPPORT_THREADRTPTime::Wait(RTPTime(1,0));}sess.BYEDestroy(RTPTime(10,0),0,0);#ifdefWIN32WSACleanup();#endif//WIN32return0;}编译注意修改每个SourceFile的codegeneration下的Userun-timelibrary为DebugMultithreadedDLL。第4/6页如图关于jrtplib的环境，可以参考网上很多的资料，也可以从我的资源里下载，我已经编译好了相关lib,只要加的VC环境里就可以了。执行测试程序的效果如下：Enterlocalportbase:8000EnterthedestinationIPaddress127.0.0.1Enterthedestinationport8000Numberofpacketsyouwishtobesent:5Sendingpacket1/5Gotpacket!Gotpacketwithextendedsequencenumber59262fromSSRC30292411921234567890Sendingpacket2/5Gotpacket!Gotpacketwithextendedsequencenumber59263fromSSRC30292411921234567890Sendingpacket3/5第5/6页Sendingpacket4/5Gotpacket!Gotpacketwithextendedsequencenumber59264fromSSRC30292411921234567890Gotpacket!Gotpacketwithextendedsequencenumber59265fromSSRC30292411921234567890Sendingpacket5/5上面执行的意思是程序自己开了8000端口，然后往自己的8000发送，所以不仅发送出去，还收到并解析出了内容。如果要往另外机器上发，另一个机器上也运行这个程序就可以了。当然可以专门再写一个接收端。