关于开源的RTP——jrtplib的使用

session.BeginDataAccess();<br />if (session.GotoFirstSource()){<br />do{<br /> RTPPacket *packet;<br />while ((packet = session.GetNextPacket()) != 0){<br /> cout << “Got packet with extended sequence number ”<br /> << packet->GetExtendedSequenceNumber()<br /> << ” from SSRC ” << packet->GetSSRC() <<endl;<br /> session.DeletePacket(packet);<br />}<br /> } while (session.GotoNextSource());<br /> }<br /> session.EndDataAccess();<br />

关于jrtplib环境的建立，能够见我曾经写的总结，如今我主要来谈谈jrtplib3.71下的几个example的学习。 一、sample是一个简单的IPv4的列子，它实现了RTP在本机上的数据的传输。 1、初始化。我们知道RTP是一般是使用UDP协议来实现数据的传输，在windows环境下，当然要用到我们熟悉的套接字的使用，所以我们先要进行初始化，载入套接字库。

函数RTPGetErrorString（…）依据出错返回的一个负数来推断，利用jrtplib採用的统一出错机制返回的是一个C++中标准的字符串std::string,表示出错的信息，比喻我们指定的Portbase不是一个偶数。(为什么，以下要讲)
2、关于RTPSession对象设置
   因为要使用套接字，故我们在使用之前一定要为我们的监听socket指定一个监听端口，也就是这里的portbase的值。我们能够通过调用RTPSession的第二个參数RTPUDPv4TransmissionParams的成员函数来设定，
   transparams.SetPortbase(portbase);
 
   还有就是我们要通过RTPSession的第一个參数来设定以下一些值：
  
sessparams.SetOwnTimestampUnit(1.0/10.0);
//注意这个值我们一定要设置，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)     
//设置时间戳是一件非常重要的事情，是RTP会话初始化过程所要进行的另外一项重要工
//作，他的单位是秒，如：当使用RTP会话传输8000Hz採样的音频数据时，因为时戳
//每秒钟将递增8000，所以时戳单元对应地应该被设置成1/8000：
sessparams.SetAcceptOwnPackets(true);
//通过这个函数我们能够设置是不是接收我们自己定义的数据包。
 
3、数据发送
   我想当我们要想建立连接的时候，我们就要让发送端知道要发送到的主机的IP地址，在jrtplib中我们能够通过RTPSession成员函数AddDestination()、DeleteDestination()和 ClearDestinations()来完毕。如以下是将数据发送给本机的6000号端口:
 
unsigned long addr = ntohl(inet_addr(“127.0.0.1”));
sess.AddDestination(addr, 6000);
 
当然我们还能够这样来完毕添�一个client，
 
RTPIPv4Address addr(destip,destport);//destip为clientIP地址,destport为client//端口号
status = sess.AddDestination(addr);
checkerror(status);  
  
   目标地址全部指定之后，接着就能够调用RTPSession类的SendPacket()方法，向全部的目标地址发送流媒体数据。SendPacket()是RTPSession类提供的一个重载函数，它具有下列多种形式：
int SendPacket(void *data,int len)
int SendPacket(void *data,int len,unsigned char pt,bool mark,
unsigned long timestampinc)
int SendPacket(void *data,int len,unsigned short hdrextID,void *hdrextdata,
int numhdrextwords)
int SendPacket(void *data,int len,unsigned char pt,bool mark,
unsigned long timestampinc,unsigned short hdrextID,
void *hdrextdata,int numhdrextwords)
SendPacket()最典型的使用方法是相似于以下的语句，当中第一个參数是要被发送的数据，而第二个參数则指明将要发送数据的长度，再往后依次是RTP负载类型、标识和时戳增量。例如以下所看到的：
status = sess.SendPacket((void *)”1234567890″,10,0,false,10);
checkerror(status);
对于同一个RTP会话来讲，负载类型、标识和时戳增量通常来讲都是同样的，JRTPLIB同意将它们设置为会话的默认參数，这是通过调用 RTPSession类的SetDefaultPayloadType()、SetDefaultMark()和 SetDefaultTimeStampIncrement()方法来完毕的。为RTP会话设置这些默认參数的优点是能够简化数据的发送，比如，假设为 RTP会话设置了默认參数：
session.SetDefaultPayloadType(96);//注意这个參数不能随便设置，參考RFC3551
session.SetDefaultMark(false);
session.SetDefaultTimestampIncrement(160);
在设置了以上的值后，我们能够这样来发送数据：
status = sess.SendPacket((void *)”1234567890″,10);
3、数据接收
对于流媒体数据的接收端，首先须要调用RTPSession类的PollData()方法来接收发送过来的RTP或者RTCP数据报。因为同一个 RTP会话中同意有多个參与者（源），你既能够通过调用RTPSession类的GotoFirstSource()和GotoNextSource() 方法来遍历全部的源，也能够通过调用RTPSession类的GotoFirstSourceWithData()和 GotoNextSourceWithData()方法来遍历那些携带有数据的源。在从RTP会话中检測出有效的数据源之后，接下去就能够调用 RTPSession类的GetNextPacket()方法从中抽取RTP数据报，当接收到的RTP数据报处理完之后，一定要记得及时释放。以下的代码示范了该怎样对接收到的RTP数据报进行处理：

#ifdef WIN32<br />WSADATA dat;<br />WSAStartup(MAKEWORD(2,2),&dat);<br />#endif // WIN32<br />RTPSession sess;</p> <p>#ifdef WIN32<br /> WSACleanup();<br />#endif // WIN32 </p> <p>#include “rtpsession.h”<br />#include “rtppacket.h”<br />#include “rtpudpv4transmitter.h”<br />//RTPUDPv4TransmissionParams<br />#include “rtpipv4address.h”<br />#include “rtpsessionparams.h”<br />#include “rtperrors.h”</p> <p>void checkerror(int rtperr)<br />{<br /> if (rtperr < 0)<br /> {<br /> std::cout << “ERROR: ” << RTPGetErrorString(rtperr) << std::endl;<br /> exit(-1);<br /> }<br />}<br />

JRTPLIB为RTP数据报定义了三种接收模式，当中每种接收模式都详细规定了哪些到达的RTP数据报将会被接受，而哪些到达的RTP数据报将会被拒绝。通过调用RTPSession类的SetReceiveMode()方法能够设置下列这些接收模式：
① RECEIVEMODE_ALL　缺省的接收模式，全部到达的RTP数据报都将被接受；
② RECEIVEMODE_IGNORESOME　　除了某些特定的发送者之外，全部到达的RTP数据报都将被接受，而被拒绝的发送者列表能够通过调用AddToIgnoreList()、ClearIgnoreList()     和DeleteFromIgnoreList()方法来进行设置；
③ RECEIVEMODE_ACCEPTSOME　　除了某些特定的发送者之外，全部到达的RTP数据报都将被拒绝，而被接受的发送者列表能够通过调用AddToAcceptList ()、ClearAcceptList ()和eleteFromAcceptList方法来进行设置。
4、执行程序
   在执行程序之前，我们要知道，这是基于UDP协议的数据报服务。我们的example1是在本机上实现的RTP传输，而且仅仅有一个RTPSession对象，所以我们的监听和接收的port是同一个，所以此时我们的portBase要和我们添�到RTPSession对象中的client的port一致，如上面我们能够都设置成6000.可是假设是在两个线程中，我们就要注意了，serverport和客户port一定不一样，这也是主要的知识，用的时候要注意，多思考。

1.设置基本參数<br />RTPSession m_RTPSocket;<br />m_RTPSocket.Create(m_SPort);<br />m_RTPSocket.SetTimestampUnit(1.0/25.0);<br />m_RTPSocket.SetSessionBandwidth(900.0);<br />m_RTPSocket.SetMaxPacketSize(65535);<br />m_RTPSocket.SetDefaultPayloadType(0);<br />m_RTPSocket.SetDefaultMark(false);<br />m_RTPSocket.SetDefaultTimeStampIncrement(10);<br />2.发送<br />int status = m_RTPSocket.SendPacket(pFrame,wSize,1,name,10);<br />3,接收<br />int size = 0;<br />SOCKET sockRtp,sockRtcp;<br />struct timeval rttprev = {0,0},rtt,tv;<br />fd_set fdset;<br />bool frist = true;<br />int port = ((CRNetVideoCtrl*)m_pMainClass)-> m_destport;<br />if(port == -1)<br />StopThread();<br />RTPSession m_RTPSocket;<br />m_RTPSocket.Create(port);<br />m_RTPSocket.SetSessionBandwidth(64); </p> <p>m_RTPSocket.GetRTPSocket(&sockRtp);<br />m_RTPSocket.GetRTCPSocket(&sockRtcp); </p> <p>m_pDecoder = new CVideoDecode();<br />m_pDecoder-> dec_init(1); </p> <p>unsigned char* pBuffer = new unsigned char [320*240*2]; </p> <p>while(!m_bClose){<br />tv.tv_sec = 0;<br />tv.tv_usec = 100000;<br />FD_ZERO(&fdset);<br />FD_SET(sockRtcp,&fdset);<br />FD_SET(sockRtp,&fdset);<br />int maxSize = max(sockRtp, sockRtcp);<br />int selectRet = select(maxSize + 1,&fdset,NULL,NULL,&tv);<br />if (-1 == selectRet || 0 == selectRet)<br />continue;<br />/* poll for incoming data *///调用这个,这样才可以获得数据<br />m_RTPSocket.PollData();<br />/* check incoming packets *///原来是rtp数据包<br />if (FD_ISSET(sockRtp, &fdset)){ </p> <p>if (m_RTPSocket.GotoFirstSourceWithData()){<br />RTPPacket *pack;<br />while ((pack = m_RTPSocket.GetNextPacket()) != NULL){<br />if(frist){<br />//检查是否是关键帧<br />if(pack-> IsMarked()){<br />if((CRNetVideoCtrl*)m_pMainClass){<br />m_pDecoder-> dec_main(pack-> GetPayload(),pBuffer,pack-> GetPayloadLength(),&size);<br />((CRNetVideoCtrl*)m_pMainClass)-> DecodeVideo(pBuffer,size);<br />TRACE( “Client Received IFrame/n “);<br />frist = false;<br />}<br />}<br />}<br />else{<br />//解码并显示<br />m_pDecoder-> dec_main(pack-> GetPayload(),pBuffer,pack-> GetPayloadLength(),&size);<br />((CRNetVideoCtrl*)m_pMainClass)-> DecodeVideo(pBuffer,size);<br />}<br />delete pack;<br />}<br />}<br />}<br />if (FD_ISSET(sockRtcp, &fdset)){<br />if (m_RTPSocket.GotoFirstSource())<br />{<br />do<br />{<br />RTPSourceData *srcdat;<br />srcdat = m_RTPSocket.GetCurrentSourceInfo();<br />if (NULL != srcdat)<br />{<br />rtt = srcdat-> INF_GetRoundTripTime();<br />if (rtt.tv_sec != 0 || rtt.tv_usec != 0)<br />{<br />double t;<br />t = (double)rtt.tv_sec;<br />t += ((double)rtt.tv_usec)/1000000.0;<br />t *= 1000.0; // we want milliseconds;<br />TRACE( “rtt: %f ms/n “, (float)t);<br />rttprev = rtt;<br />}<br />if (parent-> m_canSend)<br />{<br />sprintf(msg, “丢包: %f/n “, srcdat-> RR_GetPacketsLost());<br />sprintf(msg, “包序号: %d/n “, srcdat-> RR_GetExtendedHighestSequenceNumber());<br />sprintf(msg, “jitter: %d/n “, srcdat-> RR_GetJitter());<br />reportNum = 0;<br />}<br />srcdat-> FlushPackets(); // we don ‘t need the actual data<br />}<br />srcdat = NULL;<br />} while (m_RTPSocket.GotoNextSource());<br />} </p> <p>} </p> <p>} </p> <p>if(m_pDecoder)<br />delete m_pDecoder;<br />m_pDecoder = NULL; </p> <p>delete []pBuffer; </p> <p>return 1L;