rtp.rar_RTP-076c-好久_rtp_rtp协议_rtsp_rtspC源码资源-CSDN下载

共1个文件

c：1个

版权申诉

179 浏览量 2022-09-20 19:10:25 上传评论收藏 1KB RAR 举报

实时传输协议（RTP）和实时流控制协议（RTSP）是互联网上用于音视频流媒体传输的重要协议，尤其在多媒体通信和网络直播等领域中扮演着核心角色。在这个压缩包中，我们关注的是一个名为“rtp.c”的C语言源代码文件，这可能是实现RTP协议的一个基本框架或部分功能的代码。让我们深入了解RTP协议。RTP是一种面向数据包的传输协议，设计用于高效传输实时或近实时的音频、视频和其他时间敏感数据。RTP通常与RTCP（实时传输控制协议）一起使用，RTCP负责提供质量反馈、同步信息以及参与者统计信息，确保数据的可靠传输。 RTP的核心特点包括： 1. **时间戳和序列号**：每个RTP数据包都包含一个时间戳，用于指示数据的采样时间，以及一个序列号，用于检测丢失或乱序的数据包。 2. **负载格式多样性**：RTP可以承载多种不同的负载类型，如PCM音频、H.264视频等，通过负载类型字段来标识。 3. **多路复用和分用**：多个独立的媒体流可以在同一个UDP端口上多路复用，然后在接收端通过负载类型和SSRC（同步源标识符）进行分用。 4. **适应性**：RTP协议本身不提供重传或错误校正机制，这些功能通常由更高层次的协议（如SRTP或FEC）或应用程序实现。接下来，我们转向RTSP协议。RTSP是一种应用层控制协议，用于远程控制媒体服务器的播放、暂停、快进、快退等操作。它为用户提供了交互式的控制能力，允许在流媒体传输过程中进行动态调整，比如改变播放速率、选择不同视图等。 RTSP的主要特性包括： 1. **会话管理**：RTSP创建、修改和终止媒体会话，每个会话可以包含一个或多个媒体流。 2. **命令集**：RTSP定义了一套命令，如DESCRIBE、SETUP、PLAY、PAUSE、TEARDOWN等，用于控制媒体流的传输。 3. **实时性**：RTSP支持实时传输，允许用户即时开始观看或监听，而无需等待整个文件下载。 4. **可扩展性**：RTSP允许添加新的命令和头字段，以支持新的功能或特性。在提供的“rtp.c”源代码中，可能包含了RTP数据包的封装和解封装、时间戳和序列号的处理、负载类型识别、多路复用/分用等功能。同时，如果代码涉及RTSP，可能会有会话管理、命令处理以及与RTP协同工作的逻辑。学习和理解RTP和RTSP协议，以及相关的C语言源代码实现，对于开发网络音视频应用、多媒体通信系统或者网络直播平台来说是至关重要的。通过分析和研究“rtp.c”源代码，开发者可以深入理解这两个协议的工作原理，并能根据实际需求进行定制和优化。

资源详情

资源评论

资源推荐

收起资源包目录

rtp.rar （1个子文件）

rtp.c 4KB

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