学步园

发送程序

// sample1.cpp : Defines the entry point for the console application.<br /> //</p> <p>#include "stdafx.h"</p> <p>#pragma comment(lib, "jrtplib.lib")<br /> #pragma comment(lib,"jthread.lib")<br /> #pragma comment(lib,"WS2_32.lib")<br /> #include "rtpsession.h"<br /> #include "rtppacket.h"<br /> #include "rtpudpv4transmitter.h"<br /> #include "rtpipv4address.h"<br /> #include "rtpsessionparams.h"<br /> #include "rtperrors.h"<br /> #ifndef WIN32<br /> #include <netinet/in.h><br /> #include <arpa/inet.h><br /> #else<br /> #include <winsock2.h><br /> #endif // WIN32<br /> #include <stdlib.h><br /> #include <stdio.h><br /> #include <iostream><br /> #include <string><br /> char *buf=NULL;;<br /> void checkerror(int rtperr)<br /> {<br /> if (rtperr < 0)<br /> {<br /> std::cout << "ERROR: " << RTPGetErrorString(rtperr) << std::endl;<br /> exit(-1);<br /> }<br /> }<br /> int _tmain(int argc, _TCHAR* argv[])<br /> {<br /> char c;<br /> #ifdef WIN32<br /> WSADATA dat;<br /> WSAStartup(MAKEWORD(2,2),&dat);//指示程序所采用的socket的版本<br /> #endif // WIN32</p> <p> RTPSession sess;//本次会话实例<br /> uint16_t portbase,destport;<br /> uint32_t destip;<br /> std::string ipstr;<br /> int status,i,num;<br /> std::cout << "Enter local portbase:" << std::endl;<br /> std::cin >> portbase;<br /> std::cout << std::endl;<br /> std::cout << "Enter the destination IP address" << std::endl;<br /> std::cin >> ipstr;<br /> destip = inet_addr(ipstr.c_str());<br /> if (destip == INADDR_NONE)<br /> {<br /> std::cerr << "Bad IP address specified" << std::endl;<br /> return -1;<br /> }<br /> destip = ntohl(destip);<br /> std::cout << "Enter the destination port" << std::endl;<br /> std::cin >> destport;<br /> std::cout << std::endl;<br /> std::cout << "Number of packets you wish to be sent:" << std::endl;<br /> std::cin >> num;<br /> RTPUDPv4TransmissionParams transparams;<br /> RTPSessionParams sessparams;</p> <p> // IMPORTANT: The local timestamp unit MUST be set, otherwise<br /> // RTCP Sender Report info will be calculated wrong<br /> // In this case, we'll be sending 10 samples each second, so we'll<br /> // put the timestamp unit to (1.0/10.0)<br /> sessparams.SetOwnTimestampUnit(1.0/10.0);//设置发送频率 </p> <p> sessparams.SetAcceptOwnPackets(true);//允许接受自身的的数据包<br /> transparams.SetPortbase(portbase);//设置端口用于接受数据或发送数据<br /> status = sess.Create(sessparams,&transparams); //创建RTP任务<br /> checkerror(status);</p> <p> RTPIPv4Address addr(destip,destport);//目标地址</p> <p> status = sess.AddDestination(addr);//将目标地址添加会话中<br /> checkerror(status);</p> <p> for (i = 1 ; i <= num ; i++)<br /> {<br /> printf("/nSending packet %d/%d/n",i,num);</p> <p> // send the packet<br /> status = sess.SendPacket((void *)"1234567890",10,0,false,10);//发送数据包<br /> checkerror(status);<br /> RTPTime::Wait(RTPTime(1,0));<br /> }</p> <p> sess.BYEDestroy(RTPTime(10,0),0,0);</p> <p>#ifdef WIN32<br /> WSACleanup();<br /> #endif // WIN32<br /> c=getchar();<br /> return 0;<br /> }</p> <p>

接受程序

// sample1.cpp : Defines the entry point for the console application.<br /> //</p> <p>#include "stdafx.h"</p> <p>#pragma comment(lib, "jrtplib.lib")<br /> #pragma comment(lib,"jthread.lib")<br /> #pragma comment(lib,"WS2_32.lib")<br /> #include "rtpsession.h"<br /> #include "rtppacket.h"<br /> #include "rtpudpv4transmitter.h"<br /> #include "rtpipv4address.h"<br /> #include "rtpsessionparams.h"<br /> #include "rtperrors.h"<br /> #ifndef WIN32<br /> #include <netinet/in.h><br /> #include <arpa/inet.h><br /> #else<br /> #include <winsock2.h><br /> #endif // WIN32<br /> #include <stdlib.h><br /> #include <stdio.h><br /> #include <iostream><br /> #include <string><br /> char *buf=NULL;;<br /> void checkerror(int rtperr)<br /> {<br /> if (rtperr < 0)<br /> {<br /> std::cout << "ERROR: " << RTPGetErrorString(rtperr) << std::endl;<br /> exit(-1);<br /> }<br /> }<br /> int _tmain(int argc, _TCHAR* argv[])<br /> {<br /> char c;<br /> #ifdef WIN32<br /> WSADATA dat;<br /> WSAStartup(MAKEWORD(2,2),&dat);<br /> #endif // WIN32</p> <p> RTPSession sess;//标示此次会话<br /> uint16_t portbase;<br /> int status;</p> <p> // First, we'll ask for the necessary information</p> <p> std::cout << "Enter local portbase:" << std::endl;<br /> std::cin >> portbase;<br /> std::cout << std::endl;<br /> RTPUDPv4TransmissionParams transparams;<br /> RTPSessionParams sessparams;</p> <p> sessparams.SetOwnTimestampUnit(1.0/10.0);//设置时间戳（发送频率） </p> <p> sessparams.SetAcceptOwnPackets(true);//设置是否允许接受自己的数据包<br /> transparams.SetPortbase(portbase);//设置端口，本地进行接收或发送数据时候所用的端口<br /> status = sess.Create(sessparams,&transparams); //创建RTP任务<br /> checkerror(status);//检查创建RTP任务的状态<br /> while(TRUE)<br /> {<br /> sess.BeginDataAccess();//对访问的数据进行加锁<br /> // check incoming packets<br /> if (sess.GotoFirstSourceWithData())//遍历数据源中的所有数据<br /> {<br /> do<br /> {<br /> RTPPacket *pack;</p> <p> while ((pack = sess.GetNextPacket()) != NULL)<br /> {<br /> // You can examine the data here<br /> printf("Got packet !/n");<br /> buf=(char *)pack->GetPayloadData();//获得数据<br /> int i=pack->GetPayloadLength();<br /> buf[10]='/0';<br /> printf("pack->GetPayloadLength() %d/n",i);<br /> printf("%s/n",buf);//输出数据<br /> //pack-><br /> // we don't longer need the packet, so<br /> // we'll delete it<br /> sess.DeletePacket(pack);//清除<br /> }<br /> } while (sess.GotoNextSourceWithData());<br /> }</p> <p> sess.EndDataAccess();//解锁<br /> #ifndef RTP_SUPPORT_THREAD<br /> status = sess.Poll();//<br /> checkerror(status);<br /> #endif // RTP_SUPPORT_THREAD</p> <p> RTPTime::Wait(RTPTime(1,0));<br /> }<br /> sess.BYEDestroy(RTPTime(10,0),0,0);<br /> #ifdef WIN32<br /> WSACleanup();<br /> #endif // WIN32<br /> c=getchar();<br /> return 0;<br /> }</p> <p>