接收rtp over tcp 负载数据代码

简介:

场景

    在建立RTSP连接之后,通过rtp over tcp接收视频数据,在下面的例子中获取到的数据流,还是存在相隔2个RTP负载的问题,但是从字节来看,RTP的负载非常小,应该对数据没有任何的影响


说明

    m_sock->RecvBuffer(pszOneBytes, nRealReadLen, 1);第二个参数是真实读取到的字节数,第三个参数是指定当前读取多少个字节

代码

struct RTPHeader

{

unsigned char szHeader[4];

};


unsigned short sRTPPayLoadLen = 0;//整个RTP报文的长度,由$ 0x00|0x01 后面的两个字节决定

unsigned char cOneBytes = 0;//保存第一个字节,进行判断是否是$,从而判断是否是RTP负载包,还是RTSP指令包

char* pszOneBytes = (char*)&cOneBytes;//接收数据只能通过符号字符,因此采用强制转换

int nRealReadLen = 0;//保存了每一次读取的字节个数

int nRet = m_sock->RecvBuffer(pszOneBytes, nRealReadLen, 1);//建立rtsp链接之后,开始读取第一个字节

if (nRet <= 0)

{

exit(0);

}

while (true)

{

if ('$' == cOneBytes)

{

nRet = m_sock->RecvBuffer(pszOneBytes, nRealReadLen, 1);

if ((nRet <= 0) || (nRet != 1)) break;


if ('$' == cOneBytes) continue;//两个$$相连也是有可能的,重新循环


if (0x00 == cOneBytes || 0x01 == cOneBytes)//读取到有效的数据

{

nRet = m_sock->RecvBuffer(pszOneBytes, nRealReadLen, 1);//尝试读取高位的负载长度

if ((nRet <= 0) || (nRet != 1)) break;


if ('$' == cOneBytes) continue;


sRTPPayLoadLen = cOneBytes << 8;

if (sRTPPayLoadLen < -1 || sRTPPayLoadLen > 1500) continue;//高位有可能是0,因为有时候多个RTP只是携带格式信息,但是没有携带数据负载

nRet = m_sock->RecvBuffer(pszOneBytes, nRealReadLen, 1);//尝试读取低位的负载长度

if ((nRet <= 0) || (nRet != 1)) break;


//if ('$' == cOneBytes) continue;//有可能低位刚好就是24,所以这一点是不需要担心的


sRTPPayLoadLen = sRTPPayLoadLen + cOneBytes;

if (sRTPPayLoadLen < 0 || sRTPPayLoadLen > 1500) continue;//数据不可能超过1500,局域网传输带宽要求


char szRTPPayLoadContent[1500] = { 0 };

nRealReadLen = 0;

nRet = m_sock->RecvBuffer(szRTPPayLoadContent, nRealReadLen, sRTPPayLoadLen);

RTPHeader* pHeader = (RTPHeader*)szRTPPayLoadContent;


unsigned short sRTPSeq = (pHeader->szHeader[2] << 8) + pHeader->szHeader[3];

//std::cout << "curSeq:" << sRTPSeq << std::endl;

static int nLastSeq = sRTPSeq;

int nGap = sRTPSeq - nLastSeq;

if (nGap != 1)

{

std::cout << "rtp seq gap:" << nGap <<",lastSeq:"<<nLastSeq<<",curSeq:"<<sRTPSeq << std::endl;

}

nLastSeq = sRTPSeq;

//循环读取负载的长度报文,一次可能读取不了完整的一个RTP负载的报文

while (nRealReadLen < sRTPPayLoadLen)

{

memset(szRTPPayLoadContent, 0x00, 1500);

sRTPPayLoadLen = sRTPPayLoadLen - nRealReadLen;

nRealReadLen = 0;

nRet = m_sock->RecvBuffer(szRTPPayLoadContent, nRealReadLen, sRTPPayLoadLen);

}

}

}


nRet = m_sock->RecvBuffer(pszOneBytes, nRealReadLen, 1);

if ((nRet <= 0) || (nRet != 1)) break;

}




     本文转自fengyuzaitu 51CTO博客,原文链接:http://blog.51cto.com/fengyuzaitu/1413014,如需转载请自行联系原作者



相关文章
|
网络协议 物联网 开发者
NB-IoT 通信之 TCP 收发数据 | 学习笔记
快速学习 NB-IoT 通信之 TCP 收发数据
NB-IoT 通信之 TCP 收发数据 | 学习笔记
|
传感器 数据采集 JSON
RS232/RS485转4G DTU 上传基于Modbus协议的温湿度传感器数据到远程TCP服务器
RS232/RS485转4G DTU 上传基于Modbus协议的温湿度传感器数据到远程TCP服务器
716 0
RS232/RS485转4G DTU 上传基于Modbus协议的温湿度传感器数据到远程TCP服务器
|
7月前
|
网络协议 开发者 Python
tcp/ip模型中,帧是第几层的数据单元?
在网络通信的世界中,TCP/IP模型以其高效和可靠性而著称。这个模型是现代互联网通信的基石,它定义了数据在网络中如何被传输和接收。其中,一个核心的概念是数据单元的层级,特别是“帧”在这个模型中的位置。今天,我们就来说一下TCP/IP模型中帧的概念,以及它作为数据单元在哪一层中扮演着关键角色。
|
网络协议 Java
Java BIO tcp服务端向客户端消息群发代码教程实战
java BIO tcp服务端向客户端消息群发代码教程实战
169 0
Java BIO tcp服务端向客户端消息群发代码教程实战
|
存储 监控 网络协议
搞了半天,终于弄懂了TCP Socket数据的接收和发送,太难
本文将从上层介绍Linux上的TCP/IP栈是如何工作的,特别是socket系统调用和内核数据结构的交互、内核和实际网络的交互。写这篇文章的部分原因是解释监听队列溢出(listen queue overflow)是如何工作的,因为它与我工作中一直在研究的一个问题相关。 建好的连接怎么工作 先从建好的连接开始介绍,稍后将解释新建连接是如何工作的。
搞了半天,终于弄懂了TCP Socket数据的接收和发送,太难
|
JSON 网络协议 Android开发
【Android 逆向】Android 逆向通用工具开发 ( Android 端远程命令工具 | Android 端可执行程序的 main 函数操作 | TCP 协议服务器建立 | 接收客户端数据 )
【Android 逆向】Android 逆向通用工具开发 ( Android 端远程命令工具 | Android 端可执行程序的 main 函数操作 | TCP 协议服务器建立 | 接收客户端数据 )
218 0
【Android 逆向】Android 逆向通用工具开发 ( Android 端远程命令工具 | Android 端可执行程序的 main 函数操作 | TCP 协议服务器建立 | 接收客户端数据 )
|
网络协议 Java
【Java 网络编程】TCP 传输机制 ( 数据拆分 | 排序 | 顺序发送 | 顺序组装 | 超时重发 )
【Java 网络编程】TCP 传输机制 ( 数据拆分 | 排序 | 顺序发送 | 顺序组装 | 超时重发 )
273 0
【Java 网络编程】TCP 传输机制 ( 数据拆分 | 排序 | 顺序发送 | 顺序组装 | 超时重发 )
|
SQL 网络协议 关系型数据库
TCP性能和发送接收Buffer的关系
# 前言 本文希望解析清楚,当我们在代码中写下 socket.setSendBufferSize 和 sysctl 看到的rmem/wmem系统参数以及最终我们在TCP常常谈到的接收发送窗口的关系,以及他们怎样影响TCP传输的性能。 先明确一下:**文章标题中所说的Buffer指的是sysctl中的 rmem或者wmem,如果是代码中指定的话对应着SO_SNDBUF或者SO_RCVB
6042 0
|
网络协议
tcp回显客户端发送的数据
客户端: import socket tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) tcp_socket.connect(('127.
974 0