博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
RTP Payload Format for Transport of MPEG-4 Elementary Streams over http
阅读量:4677 次
发布时间:2019-06-09

本文共 11546 字,大约阅读时间需要 38 分钟。

1.SDP

(1)Http Request

 

GET /r/n

Host: 58.63.71.90:8011/r/n

Accept: */*/r/n

Accept-Language: */r/n

Accept-Encoding: */r/n

Authorization: Basic NjU0MzIxOjEyMzQ1NgA=/r/n

User-Agent: Streaming Sdk 1.0/r/n

/r/n

(2)Http Response

HTTP/1.0 200 OK/r/n

Content-Length: 372/r/n

Content-type: application/sdp/r/n

/r/n

v=0/r/n

o=- 1 1 IN IP4 0.0.0.0/r/n

s=NWC-Live/r/n

t=0 0/r/n // unbounded and permanent session

m=audio 0 RTP/AVP 99/r/n // submedia1

b=AS:32.00/r/n // Application Specification:32kbps

a=rtpmap:99 G726-32/8000/1/r/n // G726-32,8kHz

a=control:rtpOverHttp?Url=nphMpeg4/g726-nil/r/n // session-level attribute to distinguish submedia(audio channel)

m=video 0 RTP/AVP 96/r/n // submedia2

b=AS:3000.0/r/n // Application Specification:3000kbps(原始码率)

a=rtpmap:96 MP4V-ES/90000/r/n // MP4V-ES(MPEG-4),90kHz

a=control:rtpOverHttp?Url=nphMpeg4/nil-640x480/r/n // session-level attribute to distinguish submedia(vedio channel)

a=fmtp:96 profile-level-id=1;cpresent=0;config=000001b001000001b5090000010000000120008c4007a8a021e0a31f/r/n

/r/n

从以上两个submedia的a=control会话属性知,后面的A-G726、V-MPEG4采用rtp over http的打包方式传输。

 

2.G726-32

(1)Http Request

GET /r/n

Host: 58.63.71.90:8011/r/n

Accept: */*/r/n

Accept-Language: */r/n

Accept-Encoding: */r/n

Authorization: Basic NjU0MzIxOjEyMzQ1NgA=/r/n

User-Agent: Streaming Sdk 1.0/r/n

/r/n

(2)Http Response

HTTP/1.0 200 OK/r/n

Content-type: audio/x-pcc-nwc-rtp/r/n

/r/n

后面为G726-32音频流。

char peer1_1[] = {

0x24, 0x00, 0x03, 0xf4, 0x80, 0xe3, 0x23, 0xa7, 0x00, 0x00, 0x8d, 0x65, 0x54, 0x03, 0xd6, 0x44,

0xd1, 0xae, 0xcf, 0xe2, 0xe4, 0x3d, 0x61, 0xe5, 0x32, 0x35, 0x2e, 0x2e, 0xed, 0xda, 0xfb, 0xae,

……

};

char peer1_2[] = {

0x24, 0x00, 0x03, 0xf4, 0x80, 0xe3, 0x23, 0xa8, 0x00, 0x00, 0x95, 0x35, 0x54, 0x03, 0xd6, 0x44,

0xad, 0x3a, 0xfe, 0x3d, 0x53, 0x12, 0xf1, 0x4e, 0xd3, 0xca, 0x39, 0xf2, 0xcf, 0xf3, 0xf2, 0x46,

……

};

char peer1_3[] = {

0x24, 0x00, 0x03, 0xf4, 0x80, 0xe3, 0x23, 0xa9, 0x00, 0x00, 0x9d, 0x05, 0x54, 0x03, 0xd6, 0x44,

0x12, 0x5e, 0x34, 0xa2, 0x2a, 0xdc, 0x3d, 0x1c, 0x2e, 0xed, 0xd3, 0xfe, 0xe1, 0xbc, 0xe4, 0xe1,

……

};

 

3.MP4V-ES

(1)Http Request

GET /r/n

Host: 58.63.71.90:8011/r/n

Accept: */*/r/n

Accept-Language: */r/n

Accept-Encoding: */r/n

Authorization: Basic NjU0MzIxOjEyMzQ1NgA=/r/n

User-Agent: Streaming Sdk 1.0/r/n

/r/n

(2)Http Response

HTTP/1.0 200 OK/r/n

Content-type: video/x-pcc-nwc-rtp/r/n

/r/n

后面为MP4V-ES视频流

char peer1_1[] = {

0x24, 0x00, 0x44, 0xcb, 0x80, 0xe0, 0x37, 0xfa, 0x00, 0x00, 0x63, 0x43, 0x54, 0x03, 0xd6, 0x44

0x00, 0x00, 0x01, 0xb0, 0x01, 0x00, 0x00, 0x01, 0xb5, 0x09, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00,

0x01, 0x20, 0x00, 0x84, 0x40, 0x07, 0xa8, 0xa0, 0x21, 0xe0, 0xa3, 0x1f, 0x00, 0x00, 0x01, 0xb6,

0x3f, 0xff, 0xb3, 0xc2, 0x62, 0x06, 0x1e, 0x5b, 0xe0, 0x30, 0xcd, 0x4c, 0xfb, 0xff, 0xf7, 0x64,

……

};

char peer1_2[] = {

0x24, 0x00, 0x03, 0x39, 0x80, 0xe0, 0x37, 0xfb, 0x00, 0x00, 0xb7, 0xa3, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x5d, 0xf0, 0xe3, 0x72, 0x27, 0x30, 0xf7, 0x96, 0xe6, 0x4e, 0x5b, 0xcd,

……

};

char peer1_3[] = {

0x24, 0x00, 0x02, 0xf9, 0x80, 0xe0, 0x37, 0xfc, 0x00, 0x01, 0x0c, 0x03, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x69, 0x30, 0x71, 0xbc, 0x3f, 0xdc, 0xae, 0x67, 0xbc, 0xf7, 0x93, 0x91,

……

};

char peer1_4[] = {

0x24, 0x00, 0x04, 0x6c, 0x80, 0xe0, 0x37, 0xfd, 0x00, 0x01, 0x60, 0x63, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x55, 0xf0, 0x92, 0xb6, 0x7d, 0xe7, 0x67, 0x46, 0x84, 0x5a, 0x47, 0x5b,

……

};

char peer1_5[] = {

0x24, 0x00, 0x06, 0x00, 0x80, 0xe0, 0x37, 0xfe, 0x00, 0x01, 0xb4, 0xc3, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x59, 0x60, 0x93, 0x79, 0xdb, 0xc6, 0x0f, 0x35, 0xa4, 0x2b, 0x5f, 0x13,

……

};

以上peer1_1à peer1_5为一个GOP,包括1个I-Frame和4个P-Frame。

char peer1_6[] = {

0x24, 0x00, 0x3c, 0xca, 0x80, 0xe0, 0x37, 0xff, 0x00, 0x02, 0x5d, 0x83, 0x54, 0x03, 0xd6, 0x44

0x00, 0x00, 0x01, 0xb6, 0x28, 0xf0, 0xa8, 0x83, 0xfe, 0x5b, 0xe1, 0x71, 0x9d, 0x33, 0xee, 0x9d,

……

};

char peer1_7[] = {

0x24, 0x00, 0x03, 0x8e, 0x80, 0xe0, 0x38, 0x00, 0x00, 0x02, 0xb1, 0xe3, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x55, 0x70, 0xf3, 0x72, 0xef, 0x2d, 0xe5, 0xbc, 0xdc, 0x8b, 0x79, 0x5c,

……

};

char peer1_8[] = {

0x24, 0x00, 0x03, 0xf4, 0x80, 0xe0, 0x38, 0x01, 0x00, 0x03, 0x06, 0x43, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x58, 0xe0, 0xd3, 0xef, 0x3b, 0x18, 0xc5, 0xe7, 0xff, 0xe2, 0xce, 0x77,

……

};

char peer1_9[] = {

0x24, 0x00, 0x06, 0x26, 0x80, 0xe0, 0x38, 0x02, 0x00, 0x03, 0x5a, 0xa3, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x5c, 0x70, 0x82, 0x2f, 0x35, 0x6a, 0x61, 0x28, 0x8b, 0x22, 0x54, 0xa6,

……

};

char peer1_10[] = {

0x24, 0x00, 0x07, 0x2c, 0x80, 0xe0, 0x38, 0x03, 0x00, 0x03, 0xaf, 0x03, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x68, 0x70, 0x51, 0xb9, 0x9b, 0x90, 0x6b, 0xcd, 0x69, 0x12, 0x45, 0xc8,

……

};

以上peer1_6à peer1_10为一个GOP,包括1个I-Frame和4个P-Frame。

char peer1_11[] = {

0x24, 0x00, 0x3c, 0x90, 0x80, 0xe0, 0x38, 0x04, 0x00, 0x04, 0x57, 0xc3, 0x54, 0x03, 0xd6, 0x44,

0x00, 0x00, 0x01, 0xb6, 0x18, 0x61, 0x51, 0x07, 0xdc, 0xbf, 0xc2, 0xe3, 0x35, 0x33, 0xfd, 0xef,

……

};

……

 

rtp over http打包方式说明

头16个字节为rtp over http格式头。

第1个字节为’$’(0x24),为RtpOverHttp包头标志;第2个字节在interleave传输方式中为通道号,Panasonic BL-C111摄像头AV输出使用一个端口,此处不用置0;第3个字节和第4个字节合成16进制网络字节顺序(big-endian)的包长度(紫色示意)。

接下来的12个字节为RTP的payload format header:2个字节的头 + 2个字节的序号(绿色示意) + 4个字节的时间戳 + 4个字节的同步源。

从第17个字节开始即为纯AV码流数据。

 

MP4V-ES视频码流分析

关于MPEG-4的概念基础,参考《》。

关于MPEG-4压缩标准及编解码算法,参考,,。

请求后的第一个数据包peer1_1[]中含有MP4V-ES的视频对象起始序列码。

peer1_1[16]~peer1_1[20]的5个字节{

0x00, 0x00, 0x01, 0xb0, 0x01}为Visual Object Sequence,其中profile_and_level_indication = 0x01 (Simple Profile/Level 1。0x000001b0为visual_object_sequence_start_code。

peer1_1[21]~peer1_1[29]的9个字节{

0x00, 0x00, 0x01, 0xb5, 0x09, 0x00, 0x00, 0x01, 0x00}为Visual Object。0x000001b5为visual_object_start_code,0x00000100为video_object_start_code。

peer1_1[30]~peer1_1[43]的14个字节{

0x00, 0x00, 0x01, 0x20, 0x00, 0x84, 0x40, 0x07, 0xa8, 0xa0, 0x21, 0xe0, 0xa3, 0x1f}为Video Object Layer,里面包含有video_object_layer_width = 640,video_object_layer_height = 480等信息。0x00000120为video_object_layer_start_code。

VOL是VO的时间或空间的伸屈性描述,目标的伸屈性即是通过VOL来实现的。VO包含一个或多个VOL分辨层,VOL包括一系列VO在时间上的采样VOP。VOP序列是VO在不同分辨层的时间采样,MPEG-4的视频编码就是基于VOP进行的,它用形状、运动和色彩三组参数描述VOP。

对于解码器而言,码流可以不包含VOS和VO信息,但一般至少包含VOL信息。对于摄像头,其编码参数一般全局配置置,一经配置,其采样频率一般固定。故其后的VOP都是针对一个固定的VOL上的采样。

除去前面28个字节的VOS+VO+VOL信息,后面的即为由VOP(I-Frame、P-Frame、B-Frame)等组成的GOP(Group Of Pictures)了。关于起始码start_code参考-6.2 Visual bitstream syntax-6.2.1 Start codes一节的Table6-3—Start code values。关于MPEG4的头部结构及解析,可参考中libxvidcore/bitstream/bitstream.c中的BitstreamReadHeaders。

从peer1_1[44]开始,0x00, 0x00, 0x01, 0xb6为vop_start_code。视频对象平面(VOP:Visual Object Plane),也就是常说的“帧”。

vop_start_code(0x00, 0x00, 0x01, 0xb6)之后的两位(bit),00表示I-frame,01表示P-frame,10表示B-frame。

peer1_1中,{0x00, 0x00, 0x01, 0xb6}之后的0x3f(00110000)的前两位为00,故接下来为I-Frame。

peer1_2中,{0x00, 0x00, 0x01, 0xb6}之后的0x5d(01011101)的前两位为01,故接下来为P-Frame。

// /xvidcore-1.2.2/xvidcore/src/bitstream/bitstream.h

/* vop coding types  */

/* intra, prediction, backward, sprite, not_coded */

#define I_VOP          0

#define P_VOP          1

#define B_VOP         2

#define S_VOP          3

#define N_VOP         4

通过分析以上抓包可知,网络流传输时,一般只有I帧和P帧,少有B帧。

以上peer1_1à peer1_5为一个GOP,包括1个I-Frame和4个P-Frame。

以上peer1_6à peer1_10为一个GOP,包括1个I-Frame和4个P-Frame。

关键帧I-Frame,保留了一个场景的所有信息,压缩比为1:7。

未来单向预测帧P-frame,只储存与之前一个已解压画面的差值,压缩比为1:20。

双向预测帧B-frame,除了参考之前解压过了的画面外,亦会参考后面一帧中的画面信息,压缩比为1:50。

一个I-Frame后接若干P-Frame和B-Frame 构成一个视频对象平面组GOV(GOP)。

当画面场景呈静态少有变化时,I帧比较大,P帧比较小且GOP持续较长。当画面场景变化较大时,一般将重新构造新的I帧、形成新的GOP。

 

以下为获取松下BB-HCM581的MP4V-ES码流,并将其存储至文件的代码。保存的panasonic.mpeg4文件可通过SMPlayer等播放器播放。

 

[cpp]   
 
 
  1. // WsaInit.h  
  2. #include <winsock.h>  
  3. #pragma comment(lib, "wsock32.lib")  
  4. // #include <WINSOCK2.H>  
  5. // #pragma comment(lib, "WS2_32.LIB") // ws2_32.dll  
  6.   
  7. // class WSAInitializer is a part of the Socket class (on win32)  
  8. // as a static instance - so whenever an application uses a Socket,  
  9. // winsock is initialized  
  10. class WSAInitializer // Winsock Initializer  
  11. {  
  12. public:  
  13.     WSAInitializer()  
  14.     {  
  15.         if (WSAStartup(0x101, &m_wsadata))  
  16.         {  
  17.             exit(-1);  
  18.         }  
  19.     }  
  20.   
  21.     ~WSAInitializer()  
  22.     {  
  23.         WSACleanup();  
  24.     }  
  25.   
  26. private:  
  27.     WSADATA m_wsadata;  
  28. }WsaInit;  
  29.   
  30. // /Panasonic/Mpeg4Proc/mpeg4.cpp  
  31. #include <stdio.h>  
  32. #include <string.h>  
  33. #include "WsaInit.h"  
  34.   
  35. #define MP4V_ES 96 // rtp payload type  
  36.   
  37. // host  
  38. char ip[] = "219.117.194.183";  
  39. unsigned short port = 60151;  
  40. char http_req[] = "GET /rtpOverHttp?Url=nphMpeg4/nil-640x480 HTTP/1.1/r/n/r/n";  
  41.   
  42. int ReadHttpResponse(SOCKET s, char *buf);  
  43. int ReadBuffer(SOCKET s, char *buf, int len);  
  44.   
  45. int main()  
  46. {  
  47.     // Create a socket stands for the client process  
  48.     SOCKET clientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);  
  49.     if(clientSocket == INVALID_SOCKET) // Socket creation failure  
  50.     {  
  51.         printf("Error #%d in socket()!/n", WSAGetLastError());  
  52.         return 1;  
  53.     }  
  54.       
  55.     // Fill the sockaddr_in structure  
  56.     sockaddr_in servAddr;  
  57.     servAddr.sin_family = AF_INET;  
  58.     servAddr.sin_port = htons(port);  
  59.     servAddr.sin_addr.S_un.S_addr = inet_addr(ip);  
  60.       
  61.     // Establishes a connection to the clientSocket.  
  62.     if(connect(clientSocket, (sockaddr*)&servAddr, sizeof(servAddr)) == SOCKET_ERROR)  
  63.     {  
  64.         printf("Error #%d in connect()!/n", WSAGetLastError());  
  65.         return 1;  
  66.     }  
  67.   
  68.     // Send http request  
  69.     send(clientSocket, http_req, strlen(http_req), 0);  
  70.   
  71.     // Receive some echo data from the server  
  72.     char header[128];  
  73.       
  74.     // http response  
  75.     ReadHttpResponse(clientSocket, header);  
  76.     printf(header);  
  77.       
  78.     // data stream  
  79.     bool bRightHeader;  
  80.     unsigned char firstByte;  
  81.     unsigned char TrackId; // channel track id  
  82.     unsigned short Mpeg4FrameLen; // RTP packet len  
  83.     unsigned char RtpHeader[12];  
  84.     unsigned char Mpeg4Frame[36*1024]; //  
  85.     int nRecv = 0;  
  86.     FILE *fpPanasonicMpeg4 = fopen("panasonic.mpeg4", "w+b");  
  87.   
  88.     for (int i=0; i<200; i++)  
  89.     {  
  90.         bRightHeader = false;  
  91.         Mpeg4FrameLen = 0;  
  92.           
  93.         do {  
  94.             // (1) read and analyze the rtp over http header (16 byte)  
  95.             if (recv(clientSocket, (char*)&firstByte, 1, 0)!=1 || firstByte!='$') // packet header flag  
  96.                 break;  
  97.               
  98.             if (recv(clientSocket, (char*)&TrackId, 1, 0) != 1)  
  99.                 break;  
  100.               
  101.             if (recv(clientSocket, (char*)&Mpeg4FrameLen, 2, 0) != 2)  
  102.                 break;  
  103.               
  104.             nRecv = recv(clientSocket, (char*)RtpHeader, 12, 0);  
  105.             if (nRecv>0 && ((RtpHeader[1]&0x7F)==MP4V_ES)) // check the payload type  
  106.             {  
  107.                 Mpeg4FrameLen = htons(Mpeg4FrameLen)-12;  
  108.                 bRightHeader = true;  
  109.             }  
  110.         } while (0);  
  111.           
  112.         // (2) read the following mpeg4 stream  
  113.         if (bRightHeader)  
  114.         {  
  115.             nRecv = ReadBuffer(clientSocket, (char*)Mpeg4Frame, Mpeg4FrameLen);  
  116.   
  117.             if (nRecv > 0)  
  118.             {  
  119.                 printf("Mpeg4FrameLen = %d, nRecv = %d/n", Mpeg4FrameLen, nRecv);  
  120.                 fwrite(Mpeg4Frame, 1, nRecv, fpPanasonicMpeg4);  
  121.             }  
  122.         }  
  123.     }  
  124.   
  125.     fclose(fpPanasonicMpeg4);  
  126.   
  127.     // closes client socket  
  128.     if (closesocket(clientSocket) == SOCKET_ERROR)  
  129.     {  
  130.         printf("Error #%d in closesocket()!/n", WSAGetLastError());  
  131.         return 1;  
  132.     }  
  133.       
  134.     return 0;  
  135. }  
  136.   
  137. int ReadHttpResponse(SOCKET s, char *buf)  
  138. {     
  139.     bool done = false;  
  140.     int nRecv = 0;  
  141.     char c;  
  142.     int i = 0;  
  143.     int chars = 0; // count chars in a line  
  144.       
  145.     // read response hader, until see "/n/n" or "/r/n/r/n"  
  146.     while(!done)  
  147.     {  
  148.         nRecv = recv(s, &c, 1, 0);  
  149.         if (nRecv <= 0)  
  150.         {  
  151.             break;  
  152.         }  
  153.           
  154.         if (c == '/n')  
  155.         {  
  156.             if (chars == 0)  
  157.             {  
  158.                 done = true; // empty line  
  159.             }  
  160.             else  
  161.             {  
  162.                 chars = 0;  
  163.             }             
  164.         }  
  165.         else if (c != '/r')  
  166.         {  
  167.             chars++;  
  168.         }  
  169.           
  170.         buf[i++] = c;  
  171.     }  
  172.       
  173.     buf[i] = 0; // fill a null-terminated flag for the C string  
  174.       
  175.     return i;  
  176. }  
  177.   
  178. int ReadBuffer(SOCKET s, char *buf, int len)  
  179. {  
  180.     int nBytesToRead = len; // bytes to be read  
  181.     int nBytesRead = 0;     // bytes read already  
  182.     int nCurBytesRead = 0;  // bytes read everytime, return by recv()  
  183.       
  184.     while ((nCurBytesRead = recv(s, buf+nBytesRead, nBytesToRead, 0)) > 0)  
  185.     {  
  186.         nBytesRead += nCurBytesRead;  
  187.           
  188.         if (nBytesRead >= len)  
  189.         {  
  190.             break;  
  191.         }  
  192.           
  193.         nBytesToRead -= nCurBytesRead;  
  194.     }  
  195.       
  196.     return nBytesRead;  
  197. }  

 

 

说明:

本文网络抓包工具为,码流分析工具为中的。

 

RtpOverHttp参考:

《》

SDP参考:

《》

《》

G726参考:

《》

《》

MPEG4参考:

《》

《》

《》

《》

RFC参考:

《》

《》

《》

《》

 

转载于:https://www.cnblogs.com/jiangzhaowei/p/8351437.html

你可能感兴趣的文章
Java UDP网络编程 - 最简单示例
查看>>
区块链在零售业和银行业的广泛应用
查看>>
Hibernate or JPA Annotation中BLOB、CLOB注解写法
查看>>
[翻译]JWA(JEDI Windows API Headers)库的readmefirst.txt文件翻译
查看>>
秒杀系统(二)
查看>>
day23---ajax跨域解决---JSONP
查看>>
redis封装 get查询/删除key/keys查询
查看>>
移动端自适应js
查看>>
Pro Android学习笔记(三二):Menu(3):Context菜单
查看>>
java中用StringBuffer写文件换行
查看>>
c#ASP.NET中页面传值共有这么几种方式
查看>>
ios 截屏
查看>>
vue2.0 路由学习笔记
查看>>
甲骨文发布JSR 356 针对WebSocket的Java API
查看>>
[转]JAVA回调机制(CallBack)详解
查看>>
vue组件库(五):icon管理
查看>>
Apache Hadoop 和Hadoop生态圈
查看>>
Ctrl+Enter 选中文本提交
查看>>
android WIFI
查看>>
常用的匹配正则表达式和实例
查看>>