2. 程式人生 > >關於對H264碼流的TS的封裝的相關代碼實現

關於對H264碼流的TS的封裝的相關代碼實現

阿新 • • 發佈：2017-06-26
有效 當前 完成 read ble tco and mark comm

轉自：http://www.cnblogs.com/lidabo/p/6604998.html

1 寫在開始之前

在前段時間有分享一個H264封裝ps流到相關文章的，這次和大家分享下將H264封裝成TS流到相關實現，其實也是工作工作需要。依照上篇一樣，分段說明每個數據頭的封裝情況，當然，一樣也會加上rtp頭，方便以後的這方面到需求，如果開發不需要的話，可 以自行屏蔽掉，當然需要主要buffer指針的移動情況

2 封裝的各個頭到規則要點
整個封裝過程也是和ps類似,但是最大到區別在於TS流到數據長度都是固定188大小來傳輸的，而PS流則是可變包結構，正因為兩者在結構上到差異，導致了它們在傳輸誤碼上的不同抵抗力.TS流由於采用了固定長度的數據包，當傳輸誤碼破壞了某一個TS包的同步信息時，接收端可在固定的位置檢測到下一個TS包到同步信息，從而恢復同步，避免數據丟失,PS流則長度可變到數據包，當某一個ps包同步信息丟失時，接收端就無法進行信息同步，也就無法確認下一步到同步信息，導致了嚴重到信息丟失。因此在環境惡劣的情況下， 傳輸碼丟失比較嚴重，一般都采用TS流來進行避免，當網絡環境比較穩定，傳輸誤碼概率小，這個時候采用PS流進行傳送。
關於TS流需要了解下節目映射表(PAT：Program Associate Table)以及節目映射表(PMT：Program Map Table)，當發送到數據為視頻數據關鍵幀的時候，需要在包頭中添加PAT和PMT

具體結構體如下
封裝組成：(PAT +PMT) + TS + PES + H264 + (TS + H264 + TS + H264 ....)
數據長度：PES包的長度=188字節－TS包頭長度（4字節）－適應域長度(PES長度或者0)

註意：

a 每次數據定長包188個字節，如果不足的則用1填充，這裏填充時值每一個bit位都填充，memset就是最好選擇。
b 因為我個人習慣，在封裝到時候當為關鍵幀的時候，我直接丟了PAM+PMT+TS+PES 然後填充滿188個字節，這樣做提醒大家 是錯誤到，完全錯誤的，PES後必須跟H264數據。

c PES能表示的數據長度只有short, 兩個字節，所以當數據長度超過的話，則需要考慮多個PES頭

3 各個部件到頭的偽代碼實現

[cpp] view plain copy
  1. /*
  2. [email protected]
/* */: 整體發送數據的抽象邏輯處理函數接口
  • */
  • int rtsp_RTPPackage( RTP_SESSION_S *pRtpSender, int nFrameLen, StreamType_E enStreamType)
  • {
  • int nRet = 0;
  • int bVideo = 1 ;
  • int nSendDataOff = 0;
  • int nSendSize = 0;
  • int nPayLoadSize = 0;
  • int nHasSend = 0;
  • int IFrameFlag = 0;
  • char TSFrameHdr[1024];
  • int nHead = 0;
  • memset(TSFrameHdr, 0, 1024);
  • memset(pRtpSender->stRtpPack, 0, RTP_MAX_PACKET_BUFF);
  • bVideo = ((enStreamType == VIDEO_STREAM ) ? 1 : 0);
  • // @remark: 判斷數據是否為I幀，如果為I幀的話，加上PAT和PMT
  • if( (bVideo == 1) && pRtpSender->stAvData.u8IFrame == 1)
  • {
  • if((nRet = mk_ts_pat_packet(TSFrameHdr +nSendDataOff,
  • pRtpSender->hHdlTs)) <= 0)
  • {
  • DBG_INFO(" mk_ts_pat_packet failed!\n");
  • return -1;
  • }
  • // @remark: 每次添加一個頭的時候，必須註意指針到偏移量
  • nSendDataOff += nRet;
  • if((nRet = mk_ts_pmt_packet(TSFrameHdr + nSendDataOff,
  • pRtpSender->hHdlTs)) <= 0)
  • {
  • DBG_INFO(" mk_ts_pmt_packet failed!\n");
  • return -1;
  • }
  • nSendDataOff += nRet;
  • }
  • // @remark: 添加PS頭，需要註意ps裏也有一個計數的字段
  • if((nRet = mk_ts_packet(TSFrameHdr + nSendDataOff, pRtpSender->hHdlTs,
  • 1, bVideo, pRtpSender->stAvData.u8IFrame, pRtpSender->stAvData.u64TimeStamp)) <= 0 )
  • {
  • DBG_INFO(" mk_ts_packet failed!\n");
  • return -1;
  • }
  • nSendDataOff += nRet;
  • //此字段是用來計算ts長度，因為ts包是固定188字節長度
  • nHead = nRet;
  • // @remark: 添加PES頭，後面就必須接H264數據了，不能通過1來填充
  • if((nRet = mk_pes_packet(TSFrameHdr + nSendDataOff, bVideo, nFrameLen, 1,
  • pRtpSender->stAvData.u64TimeStamp, pRtpSender->stAvData.u64TimeStamp)) <= 0 )
  • {
  • DBG_INFO(" mk_pes_packet failed!\n");
  • return -1;
  • }
  • nSendDataOff += nRet;
  • nHead += nRet;
  • // @remark: 如果第一次發送的數據長度大於剩余長度，則先發送ts包剩余長度的數據
  • if( nFrameLen > (TS_LOAD_LEN - nHead))
  • {
  • memcpy(TSFrameHdr + nSendDataOff, pRtpSender->stAvData.data, TS_LOAD_LEN - nHead);
  • nSendDataOff += (TS_LOAD_LEN - nHead);
  • nHasSend = (TS_LOAD_LEN - nHead);
  • if( rtsp_send_rtppack(TSFrameHdr, &nSendDataOff, pRtpSender->stAvData.u64TimeStamp, 0, (pRtpSender->stAvData.u8IFrame?1:0), bVideo, 1, pRtpSender) != 0 )
  • {
  • DBG_INFO(" rtsp_send_pack failed!\n");
  • return -1;
  • }
  • }
  • // @remark: 如果第一次發送數據長度小於ts頭剩余長度，則，發送數據幀長度，剩余沒有188長度的用1填充
  • else
  • {
  • memcpy(TSFrameHdr + nSendDataOff, pRtpSender->stAvData.data, nFrameLen);
  • nSendDataOff += nFrameLen;
  • nHasSend = nFrameLen;
  • memset(TSFrameHdr +nSendDataOff, 0xFF, (TS_LOAD_LEN-nHead - nFrameLen));
  • nSendDataOff += (TS_LOAD_LEN -nHead- nFrameLen);
  • if( rtsp_send_rtppack(TSFrameHdr, &nSendDataOff, pRtpSender->stAvData.u64TimeStamp, 1, (pRtpSender->stAvData.u8IFrame?1:0), bVideo, 1, pRtpSender) != 0 )
  • {
  • DBG_INFO(" rtsp_send_rtppack failed!\n");
  • return -1;
  • }
  • }
  • // 對應的數據便宜長度，因為我處理的時候時固定1460到rtp包發送數據，所以這裏會處理偏移，方便添加rtp頭
  • nPayLoadSize = RTP_MAX_PACKET_BUFF - 4 - RTP_HDR_LEN - (4+6) * 7; // 減去rtp頭，ts頭 ,一個rtp包最多7個ts包
  • nFrameLen -= (TS_LOAD_LEN - nHead);
  • // @remark: 第二次發送數據了，此時發送數據時候，就需要外再添加ps頭了
  • while(nFrameLen > 0 )
  • {
  • nSendSize = (nFrameLen > nPayLoadSize) ? nPayLoadSize : nFrameLen;
  • if( rtsp_send_rtppack(pRtpSender->stAvData.data + nHasSend, &nSendSize, pRtpSender->stAvData.u64TimeStamp,
  • ((nSendSize == nFrameLen) ? 1 : 0), IFrameFlag, bVideo, 0, pRtpSender) != 0 )
  • {
  • DBG_INFO(" rtsp_send_rtppack failed!\n");
  • return -1;
  • }
  • nFrameLen -= nSendSize;
  • nHasSend += nSendSize;
  • memset(pRtpSender->stRtpPack, 0, RTP_MAX_PACKET_BUFF);
  • IFrameFlag = 0;
  • }
  • return 0;
  • }

    • [cpp] view plain copy
    1. /*
    2. [email protected] : 添加pat頭
    3. */
    4. int mk_ts_pat_packet(char *buf, int handle)
    5. {
    6. int nOffset = 0;
    7. int nRet = 0;
    9. if (!buf)
    10. {
    11. return 0;
    12. }
    14. if (0 >= (nRet = ts_header(buf, handle, TS_TYPE_PAT, 1)))
    15. {
    16. return 0;
    17. }
    18. nOffset += nRet;
    20. if (0 >= (nRet = ts_pointer_field(buf + nOffset)))
    21. {
    22. return 0;
    23. }
    24. nOffset += nRet;
    26. if (0 >= (nRet = ts_pat_header(buf + nOffset)))
    27. {
    28. return 0;
    29. }
    30. nOffset += nRet;
    32. // 每一個pat都會當成一個ts包來處理，所以每次剩余部分用1來充填完
    33. memset(buf + nOffset, 0xFF, TS_PACKET_SIZE - nOffset);
    34. return TS_PACKET_SIZE;
    35. }
    36. int ts_pat_header(char *buf)
    37. {
    38. BITS_BUFFER_S bits;
    40. if (!buf)
    41. {
    42. return 0;
    43. }
    44. bits_initwrite(&bits, 32, (unsigned char *)buf);
    46. bits_write(&bits, 8, 0x00); // table id, 固定為0x00
    48. bits_write(&bits, 1, 1); // section syntax indicator, 固定為1
    49. bits_write(&bits, 1, 0); // zero, 0
    50. bits_write(&bits, 2, 0x03); // reserved1, 固定為0x03
    51. bits_write(&bits, 12, 0x0D); // section length, 表示這個字節後面有用的字節數, 包括CRC32
    53. bits_write(&bits, 16, 0x0001); // transport stream id, 用來區別其他的TS流
    55. bits_write(&bits, 2, 0x03); // reserved2, 固定為0x03
    56. bits_write(&bits, 5, 0x00); // version number, 範圍0-31
    57. bits_write(&bits, 1, 1); // current next indicator, 0 下一個表有效, 1當前傳送的PAT表可以使用
    59. bits_write(&bits, 8, 0x00); // section number, PAT可能分為多段傳輸，第一段為00
    60. bits_write(&bits, 8, 0x00); // last section number
    62. bits_write(&bits, 16, 0x0001); // program number
    63. bits_write(&bits, 3, 0x07); // reserved3和pmt_pid是一組，共有幾個頻道由program number指示
    64. bits_write(&bits, 13, TS_PID_PMT); // pmt of pid in ts head
    66. bits_write(&bits, 8, 0x9F); // CRC_32 先暫時寫死
    67. bits_write(&bits, 8, 0xC7);
    68. bits_write(&bits, 8, 0x62);
    69. bits_write(&bits, 8, 0x58);
    71. bits_align(&bits);
    72. return bits.i_data;
    73. }

    [cpp] view plain copy
    1. /*
    2. [email protected]: 添加PMT頭
    3. */
    4. int mk_ts_pmt_packet(char *buf, int handle)
    5. {
    6. int nOffset = 0;
    7. int nRet = 0;
    9. if (!buf)
    10. {
    11. return 0;
    12. }
    14. if (0 >= (nRet = ts_header(buf, handle, TS_TYPE_PMT, 1)))
    15. {
    16. return 0;
    17. }
    18. nOffset += nRet;
    20. if (0 >= (nRet = ts_pointer_field(buf + nOffset)))
    21. {
    22. return 0;
    23. }
    24. nOffset += nRet;
    26. if (0 >= (nRet = ts_pmt_header(buf + nOffset)))
    27. {
    28. return 0;
    29. }
    30. nOffset += nRet;
    32. // 每一個pmt都會當成一個ts包來處理，所以每次剩余部分用1來充填完
    33. memset(buf + nOffset, 0xFF, TS_PACKET_SIZE - nOffset);
    34. return TS_PACKET_SIZE;
    35. }
    36. int ts_pmt_header(char *buf)
    37. {
    38. BITS_BUFFER_S bits;
    40. if (!buf)
    41. {
    42. return 0;
    43. }
    45. bits_initwrite(&bits, 32, (unsigned char *)buf);
    47. bits_write(&bits, 8, 0x02); // table id, 固定為0x02
    49. bits_write(&bits, 1, 1); // section syntax indicator, 固定為1
    50. bits_write(&bits, 1, 0); // zero, 0
    51. bits_write(&bits, 2, 0x03); // reserved1, 固定為0x03
    52. bits_write(&bits, 12, 0x1C); // section length, 表示這個字節後面有用的字節數, 包括CRC32
    54. bits_write(&bits, 16, 0x0001); // program number, 表示當前的PMT關聯到的頻道號碼
    56. bits_write(&bits, 2, 0x03); // reserved2, 固定為0x03
    57. bits_write(&bits, 5, 0x00); // version number, 範圍0-31
    58. bits_write(&bits, 1, 1); // current next indicator, 0 下一個表有效, 1當前傳送的PAT表可以使用
    60. bits_write(&bits, 8, 0x00); // section number, PAT可能分為多段傳輸，第一段為00
    61. bits_write(&bits, 8, 0x00); // last section number
    63. bits_write(&bits, 3, 0x07); // reserved3, 固定為0x07
    64. bits_write(&bits, 13, TS_PID_VIDEO); // pcr of pid in ts head, 如果對於私有數據流的節目定義與PCR無關，這個域的值將為0x1FFF
    65. bits_write(&bits, 4, 0x0F); // reserved4, 固定為0x0F
    66. bits_write(&bits, 12, 0x00); // program info length, 前兩位bit為00
    68. bits_write(&bits, 8, TS_PMT_STREAMTYPE_H264_VIDEO); // stream type, 標誌是Video還是Audio還是其他數據
    69. bits_write(&bits, 3, 0x07); // reserved, 固定為0x07
    70. bits_write(&bits, 13, TS_PID_VIDEO); // elementary of pid in ts head
    71. bits_write(&bits, 4, 0x0F); // reserved, 固定為0x0F
    72. bits_write(&bits, 12, 0x00); // elementary stream info length, 前兩位bit為00
    74. bits_write(&bits, 8, TS_PMT_STREAMTYPE_11172_AUDIO); // stream type, 標誌是Video還是Audio還是其他數據
    75. bits_write(&bits, 3, 0x07); // reserved, 固定為0x07
    76. bits_write(&bits, 13, TS_PID_AUDIO); // elementary of pid in ts head
    77. bits_write(&bits, 4, 0x0F); // reserved, 固定為0x0F
    78. bits_write(&bits, 12, 0x00); // elementary stream info length, 前兩位bit為00
    80. bits_write(&bits, 8, 0xA4); // stream type, 標誌是Video還是Audio還是其他數據
    81. bits_write(&bits, 3, 0x07); // reserved, 固定為0x07
    82. bits_write(&bits, 13, 0x00A4); // elementary of pid in ts head
    83. bits_write(&bits, 4, 0x0F); // reserved, 固定為0x0F
    84. bits_write(&bits, 12, 0x00); // elementary stream info length, 前兩位bit為00
    86. bits_write(&bits, 8, 0x34); //CRC_32 先暫時寫死
    87. bits_write(&bits, 8, 0x12);
    88. bits_write(&bits, 8, 0xA3);
    89. bits_write(&bits, 8, 0x72);
    91. bits_align(&bits);
    92. return bits.i_data;
    93. }



    [cpp] view plain copy
    1. /*
    2. [email protected]: ts頭的封裝
    3. */
    4. int mk_ts_packet(char *buf, int handle, int bStart, int bVideo, int bIFrame, unsigned long long timestamp)
    5. {
    6. int nOffset = 0;
    7. int nRet = 0;
    9. if (!buf)
    10. {
    11. return 0;
    12. }
    14. if (0 >= (nRet = ts_header(buf, handle, bVideo ? TS_TYPE_VIDEO : TS_TYPE_AUDIO, bStart)))
    15. {
    16. return 0;
    17. }
    18. nOffset += nRet;
    20. if (0 >= (nRet = ts_adaptation_field(buf + nOffset, bStart, bVideo && (bIFrame), timestamp)))
    21. {
    22. return 0;
    23. }
    24. nOffset += nRet;
    26. return nOffset;
    27. }
    29. /* [email protected]: ts頭相關封裝
    30. * PSI 包括了PAT、PMT、NIT、CAT
    31. * PSI--Program Specific Information, PAT--program association table, PMT--program map table
    32. * NIT--network information table, CAT--Conditional Access Table
    33. * 一個網絡中可以有多個TS流(用PAT中的ts_id區分)
    34. * 一個TS流中可以有多個頻道(用PAT中的pnumber、pmt_pid區分)
    35. * 一個頻道中可以有多個PES流(用PMT中的mpt_stream區分)
    36. */
    37. int ts_header(char *buf, int handle, TS_TYPE_E type, int bStart)
    38. {
    39. BITS_BUFFER_S bits;
    40. TS_MNG_S *pMng = (TS_MNG_S *)handle;
    42. if (!buf || !handle || TS_TYPE_BEGIN >= type || TS_TYPE_END <= type)
    43. {
    44. return 0;
    45. }
    47. bits_initwrite(&bits, 32, (unsigned char *)buf);
    49. bits_write(&bits, 8, 0x47); // sync_byte, 固定為0x47,表示後面的是一個TS分組
    51. // payload unit start indicator根據TS packet究竟是包含PES packet還是包含PSI data而設置不同值
    52. // 1. 若包含的是PES packet header, 設為1, 如果是PES packet余下內容, 則設為0
    53. // 2. 若包含的是PSI data, 設為1, 則payload的第一個byte將是point_field, 0則表示payload中沒有point_field
    54. // 3. 若此TS packet為null packet, 此flag設為0
    55. bits_write(&bits, 1, 0); // transport error indicator
    56. bits_write(&bits, 1, bStart); // payload unit start indicator
    57. bits_write(&bits, 1, 0); // transport priority, 1表示高優先級
    58. if (TS_TYPE_PAT == type)
    59. {
    60. bits_write(&bits, 13, 0x00); // pid, 0x00 PAT, 0x01 CAT
    61. }
    62. else if (TS_TYPE_PMT == type)
    63. {
    64. bits_write(&bits, 13, TS_PID_PMT);
    65. }
    66. else if (TS_TYPE_VIDEO == type)
    67. {
    68. bits_write(&bits, 13, TS_PID_VIDEO);
    69. }
    70. else if (TS_TYPE_AUDIO == type)
    71. {
    72. bits_write(&bits, 13, TS_PID_AUDIO);
    73. }
    75. bits_write(&bits, 2, 0); // transport scrambling control, 傳輸加擾控制
    76. if (TS_TYPE_PAT == type || TS_TYPE_PMT == type)
    77. {
    78. // continuity counter, 是具有同一PID值的TS包之間的連續計數值
    79. // 當分組的adaption_field_control字段為00話10時，該字段不遞增
    80. bits_write(&bits, 2, 0x01); // adaptation field control, 00 forbid, 01 have payload, 10 have adaptation, 11 have payload and adaptation
    81. bits_write(&bits, 4, pMng->nPatCounter); // continuity counter, 0~15
    83. if (TS_TYPE_PAT != type)
    84. {
    85. pMng->nPatCounter++;
    86. pMng->nPatCounter &= 0x0F;
    87. }
    88. }
    89. else
    90. {
    91. bits_write(&bits, 2, 0x03); // 第一位表示有無調整字段，第二位表示有無有效負載
    92. bits_write(&bits, 4, pMng->nContinuityCounter);
    93. pMng->nContinuityCounter++;
    94. pMng->nContinuityCounter &= 0x0F;
    95. }
    97. bits_align(&bits);
    98. return bits.i_data;
    99. }



    [cpp] view plain copy
    1. /*
    2. *remark:添加pes頭
    3. */
    4. int mk_pes_packet(char *buf, int bVideo, int length, int bDtsEn, unsigned long long pts, unsigned long long dts)
    5. {
    6. PES_HEAD_S pesHead;
    7. PES_OPTION_S pesOption;
    8. PES_PTS_S pesPts;
    9. PES_PTS_S pesDts;
    11. if (!buf)
    12. {
    13. return 0;
    14. }
    16. if( bVideo == 1)
    17. {
    18. // 視頻的采樣頻率為90kHZ,則增量為3600
    19. pts = pts * 9 / 100; // 90000Hz
    20. dts = dts * 9 / 100; // 90000Hz
    21. }
    22. else
    23. {
    24. // 音頻的話，則需要按照8000HZ來計算增量[需要的話]
    25. pts = pts * 8 / 1000; // 8000Hz
    26. dts = dts * 8 / 1000; // 8000Hz
    28. }
    30. memset(&pesHead, 0, sizeof(pesHead));
    31. memset(&pesOption, 0, sizeof(pesOption));
    32. memset(&pesPts, 0, sizeof(pesPts));
    33. memset(&pesDts, 0, sizeof(pesDts));
    35. pesHead.startcode = htonl(0x000001) >> 8;
    36. pesHead.stream_id = bVideo ? 0xE0 : 0xC0;
    37. if (PES_MAX_SIZE < length)
    38. {
    39. pesHead.pack_len = 0;
    40. }
    41. else
    42. {
    43. pesHead.pack_len = htons(length + sizeof(pesOption) + sizeof(pesPts) + (bDtsEn ? sizeof(pesDts) : 0));
    44. }
    46. pesOption.fixed = 0x02;
    47. pesOption.pts_dts = bDtsEn ? 0x03 : 0x02;
    48. pesOption.head_len = sizeof(pesPts) + (bDtsEn ? sizeof(pesDts) : 0);
    50. pesPts.fixed2 = pesPts.fixed3 = pesPts.fixed4 = 0x01;
    51. pesPts.fixed1 = bDtsEn ? 0x03 : 0x02;
    52. pesPts.ts1 = (pts >> 30) & 0x07;
    53. pesPts.ts2 = (pts >> 22) & 0xFF;
    54. pesPts.ts3 = (pts >> 15) & 0x7F;
    55. pesPts.ts4 = (pts >> 7) & 0xFF;
    56. pesPts.ts5 = pts & 0x7F;
    58. pesDts.fixed1 = pesDts.fixed2 = pesDts.fixed3 = pesDts.fixed4 = 0x01;
    59. pesDts.ts1 = (dts >> 30) & 0x07;
    60. pesDts.ts2 = (dts >> 22) & 0xFF;
    61. pesDts.ts3 = (dts >> 15) & 0x7F;
    62. pesDts.ts4 = (dts >> 7) & 0xFF;
    63. pesDts.ts5 = dts & 0x7F;
    65. char *head = buf;
    66. memcpy(head, &pesHead, sizeof(pesHead));
    67. head += sizeof(pesHead);
    68. memcpy(head, &pesOption, sizeof(pesOption));
    69. head += sizeof(pesOption);
    70. memcpy(head, &pesPts, sizeof(pesPts));
    71. head += sizeof(pesPts);
    72. if (bDtsEn)
    73. {
    74. memcpy(head, &pesDts, sizeof(pesDts));
    75. head += sizeof(pesPts);
    76. }
    78. return (head - buf);
    79. }



    [cpp] view plain copy
    1. /*
    2. [email protected]: 最後封裝rtp頭並發送最終封裝好到完整的數據包
    3. */
    4. int rtsp_send_rtppack(char *Databuf, int *datalen, unsigned long curtimestamp, int mark_flag, int IFrameFlag, int bVideo, int nFrameStart, RTP_SESSION_S *pRtpSender)
    5. {
    6. int nHasSend = 0;
    7. int nRet = 0;
    8. int nTsHeadNum = 0;
    9. int nHadDataLen = 0;
    10. int nTcpSendLen = 0;
    11. static unsigned short cSeqnum;
    14. // @remark：表示為數據的第一次發送，所以不需要額外再添加ts頭
    15. if( nFrameStart == 1 )
    16. {
    17. nRet = mk_rtp_packet(pRtpSender->stRtpPack + nHasSend, mark_flag, IFrameFlag, bVideo, ++cSeqnum, (curtimestamp * 9/100));
    18. nHasSend += nRet;
    19. memcpy(pRtpSender->stRtpPack + nHasSend, Databuf, *datalen);
    20. nHasSend += *datalen;
    21. }
    22. else // 不是第一次發送此幀數據的話，則需要添加封裝新的ts包，並添加ts頭
    23. {
    24. // rtp+ rtp_ext + ts +data
    25. nRet = mk_rtp_packet(pRtpSender->stRtpPack + nHasSend, mark_flag, IFrameFlag, bVideo, ++cSeqnum, (curtimestamp * 9/100));
    26. nHasSend += nRet;
    27. while(*datalen > 0 && nTsHeadNum < 7)
    28. {
    29. nRet = mk_ts_packet(pRtpSender->stRtpPack + nHasSend , pRtpSender->hHdlTs, 0, bVideo, (IFrameFlag > 0 ? 1:0), curtimestamp);
    30. nHasSend += nRet;
    31. if(*datalen < (TS_LOAD_LEN- nRet))
    32. {
    33. memcpy(pRtpSender->stRtpPack + nHasSend, Databuf + nHadDataLen, *datalen);
    34. nHasSend += *datalen;
    35. nHadDataLen += *datalen;
    37. //不夠Ts188用1補充
    38. memset(pRtpSender->stRtpPack + nHasSend, 0xFF, TS_LOAD_LEN- nRet - (*datalen));
    39. nHasSend += (TS_LOAD_LEN - nRet - *datalen);
    40. }
    41. else
    42. {
    43. memcpy(pRtpSender->stRtpPack + nHasSend, Databuf + nHadDataLen, TS_LOAD_LEN - nRet);
    44. nHasSend += (TS_LOAD_LEN - nRet);
    45. *datalen -= (TS_LOAD_LEN - nRet);
    46. nHadDataLen += (TS_LOAD_LEN - nRet);
    47. }
    48. nTsHeadNum ++;
    49. }
    50. *datalen = nHadDataLen; //實際發送裸數據到長度
    51. }
    54. if(pRtpSender->RtspsockFd <= 0 )
    55. {
    56. DBG_INFO("send rtp packet socket error\n");
    57. return -1;
    58. }
    60. nTcpSendLen = hi_tcp_noblock_send(pRtpSender->RtspsockFd, pRtpSender->stRtpPack, nHasSend, NULL,1500);
    61. if(nTcpSendLen != nHasSend )
    62. {
    63. DBG_INFO("send rtp packet failed:%s\n",strerror(errno));
    64. return -1;
    65. }
    66. return 0;
    67. }



    [cpp] view plain copy
    1. /*
    2. *remark: 上面用到的一些宏定義和一些關於字節操作的函數，很多一些開源到視頻處理的庫都能看到，
    3. 為了方便也都將貼出來分享，當然也可以參考下vlc裏面的源碼
    4. */
    6. [email protected]: 常量定義 */
    7. #define TS_PID_PMT (0x62)
    8. #define TS_PID_VIDEO (0x65)
    9. #define TS_PID_AUDIO (0x84)
    10. #define TS_PMT_STREAMTYPE_11172_AUDIO (0x03)
    11. #define TS_PMT_STREAMTYPE_13818_AUDIO (0x04)
    12. #define TS_PMT_STREAMTYPE_AAC_AUDIO (0x0F)
    13. #define TS_PMT_STREAMTYPE_H264_VIDEO (0x1B)
    15. /* @remark: 結構體定義 */
    16. typedef struct
    17. {
    18. int i_size; // p_data字節數
    19. int i_data; // 當前操作字節的位置
    20. unsigned char i_mask; // 當前操作位的掩碼
    21. unsigned char *p_data; // bits buffer
    22. } BITS_BUFFER_S;
    24. typedef struct
    25. {
    26. unsigned int startcode : 24; // 固定為00 00 01
    27. unsigned int stream_id : 8; // 0xC0-0xDF audio stream, 0xE0-0xEF video stream, 0xBD Private stream 1, 0xBE Padding stream, 0xBF Private stream 2
    28. unsigned short pack_len; // PES packet length
    29. } __attribute__ ((packed)) PES_HEAD_S;
    31. typedef struct
    32. {
    33. #if (BYTE_ORDER == LITTLE_ENDIAN)
    34. unsigned char original : 1; // original or copy, 原版或拷貝
    35. unsigned char copyright : 1; // copyright flag
    36. unsigned char align : 1; // data alignment indicator, 數據定位指示符
    37. unsigned char priority : 1; // PES priority
    38. unsigned char scramb : 2; // PES Scrambling control, 加擾控制
    39. unsigned char fixed : 2; // 固定為10
    41. unsigned char exten : 1; // PES extension flag
    42. unsigned char crc : 1; // PES CRC flag
    43. unsigned char acopy : 1; // additional copy info flag
    44. unsigned char trick : 1; // DSM(Digital Storage Media) trick mode flag
    45. unsigned char rate : 1; // ES rate flag, ES流速率標誌
    46. unsigned char escr : 1; // ESCR(Elementary Stream Clock Reference) flag, ES流時鐘基準標誌
    47. unsigned char pts_dts : 2; // PTS DTS flags, 00 no PTS and DTS, 01 forbid, 10 have PTS, 11 have PTS and DTS
    48. #elif (BYTE_ORDER == BIG_ENDIAN)
    49. unsigned char fixed : 2; // 固定為10
    50. unsigned char scramb : 2; // PES Scrambling control, 加擾控制
    51. unsigned char priority : 1; // PES priority
    52. unsigned char align : 1; // data alignment indicator, 數據定位指示符
    53. unsigned char copyright : 1; // copyright flag
    54. unsigned char original : 1; // original or copy, 原版或拷貝
    56. unsigned char pts_dts : 2; // PTS DTS flags, 00 no PTS and DTS, 01 forbid, 10 have PTS, 11 have PTS and DTS
    57. unsigned char escr : 1; // ESCR(Elementary Stream Clock Reference) flag, ES流時鐘基準標誌
    58. unsigned char rate : 1; // ES rate flag, ES流速率標誌
    59. unsigned char trick : 1; // DSM(Digital Storage Media) trick mode flag
    60. unsigned char acopy : 1; // additional copy info flag
    61. unsigned char crc : 1; // PES CRC flag
    62. unsigned char exten : 1; // PES extension flag
    63. #endif
    65. unsigned char head_len; // PES header data length
    66. } __attribute__ ((packed)) PES_OPTION_S;
    68. typedef struct
    69. {// ts total 33 bits
    70. #if (BYTE_ORDER == LITTLE_ENDIAN)
    71. unsigned char fixed2 : 1; // 固定為1
    72. unsigned char ts1 : 3; // bit30-32
    73. unsigned char fixed1 : 4; // DTS為0x01, PTS為0x02, PTS+DTS則PTS為0x03
    75. unsigned char ts2; // bit22-29
    76. unsigned char fixed3 : 1; // 固定為1
    77. unsigned char ts3 : 7; // bit15-21
    79. unsigned char ts4; // bit7-14
    80. unsigned char fixed4 : 1; // 固定為1
    81. unsigned char ts5 : 7; // bit0-6
    82. #elif (BYTE_ORDER == BIG_ENDIAN)
    83. unsigned char fixed1 : 4; // DTS為0x01, PTS為0x02, PTS+DTS則PTS為0x03
    84. unsigned char ts1 : 3; // bit30-32
    85. unsigned char fixed2 : 1; // 固定為1
    87. unsigned char ts2; // bit22-29
    88. unsigned char ts3 : 7; // bit15-21
    89. unsigned char fixed3 : 1; // 固定為1
    91. unsigned char ts4; // bit7-14
    92. unsigned char ts5 : 7; // bit0-6
    93. unsigned char fixed4 : 1; // 固定為1
    94. #endif
    95. } __attribute__ ((packed)) PES_PTS_S;
    98. /* remark:接口函數定義 */
    99. int bits_initwrite(BITS_BUFFER_S *p_buffer, int i_size, unsigned char *p_data)
    100. {
    101. if (!p_data)
    102. {
    103. return -1;
    104. }
    105. p_buffer->i_size = i_size;
    106. p_buffer->i_data = 0;
    107. p_buffer->i_mask = 0x80;
    108. p_buffer->p_data = p_data;
    109. p_buffer->p_data[0] = 0;
    110. return 0;
    111. }
    113. void bits_align(BITS_BUFFER_S *p_buffer)
    114. {
    115. if (p_buffer->i_mask != 0x80 && p_buffer->i_data < p_buffer->i_size)
    116. {
    117. p_buffer->i_mask = 0x80;
    118. p_buffer->i_data++;
    119. p_buffer->p_data[p_buffer->i_data] = 0x00;
    120. }
    121. }
    123. inline void bits_write(BITS_BUFFER_S *p_buffer, int i_count, unsigned long i_bits)
    124. {
    125. while (i_count > 0)
    126. {
    127. i_count--;
    129. if ((i_bits >> i_count ) & 0x01)
    130. {
    131. p_buffer->p_data[p_buffer->i_data] |= p_buffer->i_mask;
    132. }
    133. else
    134. {
    135. p_buffer->p_data[p_buffer->i_data] &= ~p_buffer->i_mask;
    136. }
    137. p_buffer->i_mask >>= 1;
    138. if (p_buffer->i_mask == 0)
    139. {
    140. p_buffer->i_data++;
    141. p_buffer->i_mask = 0x80;
    142. }
    143. }
    144. }
    147. int bits_initread(BITS_BUFFER_S *p_buffer, int i_size, unsigned char *p_data)
    148. {
    149. if (!p_data)
    150. {
    151. return -1;
    152. }
    153. p_buffer->i_size = i_size;
    154. p_buffer->i_data = 0;
    155. p_buffer->i_mask = 0x80;
    156. p_buffer->p_data = p_data;
    157. return 0;
    158. }
    160. inline int bits_read(BITS_BUFFER_S *p_buffer, int i_count, unsigned long *i_bits)
    161. {
    162. if (!i_bits)
    163. {
    164. return -1;
    165. }
    166. *i_bits = 0;
    168. while (i_count > 0)
    169. {
    170. i_count--;
    172. if (p_buffer->p_data[p_buffer->i_data] & p_buffer->i_mask)
    173. {
    174. *i_bits |= 0x01;
    175. }
    177. if (i_count)
    178. {
    179. *i_bits = *i_bits << 1;
    180. }
    182. p_buffer->i_mask >>= 1;
    183. if(p_buffer->i_mask == 0)
    184. {
    185. p_buffer->i_data++;
    186. p_buffer->i_mask = 0x80;
    187. }
    188. }
    190. return 0;
    191. }

    5 寫在最後
    看過我上一篇的關於ps封裝的可能會註意的，關於壓字節的處理，兩篇博文到處理方式有些差異。關於我這個我簡單說兩點
    第一次是這個ts的處理裏面封裝是另外一個同事實現的，我因為用到所以拿來使用，但是上次調用封裝都是自己完成。第二個就是
    ps和ts的處理方式不一樣。一個定長，一個不定長。所以這樣處理，也挺好的，我也有點懶，所以沒有改過來。

    關於對H264碼流的TS的封裝的相關代碼實現

    相關推薦

    關於對H264碼流的TS的封裝的相關代碼實現

    有效 當前 完成 read ble tco and mark comm 轉自：http://www.cnblogs.com/lidabo/p/6604998.html 1 寫在開始之前 在前段時間有分享一個H264封裝ps流到相關文章的，這次和

    關於對H264碼流的PS的封裝的相關代碼實現

    真心 clip gef 但是 占用 udp 大致 結果 方法 轉自：http://www.cnblogs.com/lidabo/p/6604988.html 1、寫在開始之前： 最近因為新工作要維護別人留下的GB模塊代碼，先熟悉了流程，然後也試著封裝

    【轉載】對一致性Hash算法，Java代碼實現的深入研究

    困難 之前 存在 itl ger 正常 我不 操作 算法實現 原文地址：http://www.cnblogs.com/xrq730/p/5186728.html 一致性Hash算法 關於一致性Hash算法，在我之前的博文中已經有多次提到了，MemCache超詳細解讀一

    對一致性Hash算法，Java代碼實現的深入研究

    memcach 還原 情況 () 實用 target 強人 最壞情況 一致性hash 一致性Hash算法 關於一致性Hash算法，在我之前的博文中已經有多次提到了，MemCache超詳細解讀一文中"一致性Hash算法"部分，對於為什麽要使用一致性Hash算法、一致性Has

    對“使用MyEclipse，寫的jsp代碼因有漢字而無法保存”問題的解決

    編輯 window eclipse 保存 data 文本 myeclips gen trac 使用MyEclipse編輯jsp時。有時會出現“使用MyEclipse，寫的jsp代碼因有漢字而無法保存”的現象，怎樣解決呢？ Window——&g

    項目受源代碼管理。向源代碼管理註冊此項目時出錯。建議不要對此項目進行任何更改

    provide win 建議 進行 work 打開 name 內容 源代碼管理 編譯Rocket.Windows.Framework項目的時候提示如題的錯誤， 用記事本打開出錯的幾個項目的.csproj文件，把下面幾行內容刪掉就行了。

    使用MyBatisGenerator自動生成Mybatis的相關代碼

    args pool mage ransac http manage build values 令行 一、構建一個環境： 1. 首先創建一個表： Sql代碼 CREATE TABLE pet (name VARCHAR(20), owner VARCHAR(

    你真的對java static了解嗎，代碼優化可能更加簡單

    block 就會 找到 java 加載類 兩個 一個 位置 有一個 static修飾的成員變量和成員方法獨立於該類的任何對象。也就是說，它不依賴類特定的實例，被類的所有實例共享。 只要這個類被加載，Java虛擬機就能根據類名在運行時數據區的方法區內定找到他們。因此，st

    調接口省市區三級聯動相關代碼

    arch on() tle spa post area splay mat user //加載省份 $.ajax({ type: ‘GET‘, url: "/cifcogroup/application/web/index.php?r=s

    簡單二叉樹相關代碼

    \n include reat oid 結構 存儲空間 root node branch 1 #include <stdio.h> 2 3 typedef struct tagBinaryTree* Node; 4 typedef s

    類的封裝源代碼

    return 實例 聲明 打印 etc wan 類的屬性 私有 class package com.aaa.base;/** 定義一個類：Dog @author 張晨光 */public class Dog {//成員變量;private:私有;類的屬性應該是私有的；p

    上傳圖片的相關代碼

    ict eas return load bst pat ret data 註冊 1 if (upload1.HasFile)//判斷控件是否有文件路徑 2 { 3 strin

    客戶端浮動的相關代碼學習

    clear ali oat 內容 直接 邊框 客戶 set 水平 <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <met

    利用mp4v2實現H.264裸碼流實時封裝

    1. mp4v2庫配置、交叉編譯 mp4v2 庫是一個專用於處理mp4容器的開源專案，其使用c++編寫，並提供c語言介面。 下載mp4v2庫的最新程式碼以後，使用標準linux configure

    Github 大牛封裝 Python 代碼，實現自動發送郵件只需三行代碼

    常見 from 自動 mime mp3 fff 如何使用 utf html *註意：全文代碼可左右滑動觀看 在運維開發中，使用 Python 發送郵件是一個非常常見的應用場景。今天一起來探討一下，GitHub 的大牛門是如何使用 Python 封裝發送郵件代碼的。 一般發郵

    Layout-2相關代碼:3列布局

    文檔 width text right ati eight pre 1.0 body <!doctype html> <html> <head> <meta charset="utf-8"> <title&g

    Object-C iOS純代碼布局 一堆代碼可以放這裏！

    objective 是我 cti blog 今天 object 1-1 擴展 類的屬性 前言： 最近寫的文章都是創業類，好吧，今天好好寫寫技術類的文章！ 不過分享的不是IOS相關的文章，畢竟這幾天在速成IOS，看的是objective-c，由於速成的很快，好累！ 好在

    讓你的eclipse實現寫JAVA代碼，HTML,CSS,JAVASCRIPT代碼提示

    css ref win imp center asc java代碼 char 保存文件 　　1.打開eclipse→Windows→Preferences→Java→Editor→Content Assist 　　改動Auto Activation triggers f

    通過Webstorm上傳代碼到Github、更新代碼後同步到github及克隆github代碼到本地的方法

    成了 ron 成功 commit 簡單 tps 命令行 是個 所有 導讀： Github做為IT愛好者分享代碼的一個知名的平臺，廣受大家喜歡，那麽我們平時該怎麽將自己寫的代碼上傳到github上面保存並且提供給其他人參考？ 我想方法不外乎如下幾個： 1、直接在github網

    靜態代碼塊--》非靜態代碼塊--》構造方法

    println int span string ring system new str 對象初始化 class ccc1 { static { System.out.println("ccc1---1"); } public ccc1() { System.out.pri