2. 程式人生 > >基於c++實現RTSP/RTMP推流元件PushStream簡介

基於c++實現RTSP/RTMP推流元件PushStream簡介

阿新 • • 發佈：2018-12-01

技術在於交流、溝通，轉載請註明出處並保持作品的完整性。

原文：https://blog.csdn.net/hiwubihe/article/details/84639975 

[本系列相關文章]

 

本篇介紹一個基於C++開發的RTSP/RTMP推流元件PushStream，PushStream推流基礎元件是一款推送流媒體音/視訊流給標準RTSP流媒體伺服器 (如EasyDarwin、Wowza) 或者RTMP流媒體伺服器 (如Nginx) 的流媒體推送庫，目前開發版本支援(Windows/Linux(32 & 64)等平臺，針對該元件進行二次開發可以避免了稍顯複雜的RTSP,RTMP流程，及H264，AAC，FLV等音視訊編解碼，封裝格式，以及如何把這些編碼格式的音視訊打包等細節處理，只需要呼叫結構API介面，即可非常輕鬆穩定的把音視訊推送到流媒體，以便流媒體進行進行處理和轉發。

總體架構

                                                         

                                     

PushStream元件呼叫方便性

 1.不需要了解和流媒體伺服器信令互動過程，RTSP/RTMP協議是怎麼信令互動的，而且不同伺服器信令還有所不同，如EasyDarwin和Wowza伺服器信令有細微區別，搞清楚這些都是需要時間成本的。

2.不需要了解H264,AAC,G711A/U等常見的編碼格式，是怎麼打包成RTP/RTCP。

3.上送流如果是通過其他協議還需要解封裝，如果音視訊流是通過GB28182上送的PS流，還需要了解PS流封裝格式，需要解封裝。

4.上送RTMP伺服器，需要了解RTMP信令互動過程，RTMP協議上送流是通過封裝成FLV格式，需要了解FLV格式。

5.多軌道上送音視訊給伺服器，還需要在上送的時候做好音視訊同步問題。

 

 

介面呼叫流程

 

                                            

API介面介紹

  1. PSTREAM_SetLogCallBack 設定日誌回撥，把PushStream庫日誌反饋在使用者程式的日誌裡，方便除錯庫。

/**************************************************************************
* Function Name  : PSTREAM_SetLogCallBack
* Description    : 設定庫日誌回撥
* Parameters     : pLogFunc	(日誌回撥函式)	
* Parameters     : pUserData(日誌回撥使用者資料)
* Return Type    : void
* Last Modified  : wubihe
***************************************************************************/

DLLEXPORT void  WINAPI PSTREAM_SetLogCallBack(PSTREAM_LogCBFun pLogFunc,	void* pUserData);

  2. PSTREAM_CreatePushHandle 建立推流控制代碼，應用程式需要推送一路流就需要建立一個推流控制代碼，返回控制代碼標誌該路流，傳入後續API中。需要傳入引數流轉發型別，這裡有三種PSTREAM_RTSP_RTP_TCP(RTSP/RTP OVER TCP)，PSTREAM_RTSP_RTP_UDP(RTSP/RTP OVER UDP),和PSTREAM_RTMP_FLV(RTMP/FLV)傳輸協議。

/**************************************************************************
* Function Name  : PSTREAM_CreatePushHandle
* Description    : 建立推流流控制代碼
* Parameters     : eType 流傳輸型別
* Return Type    : 0 非法
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT PSTREAM_HANDLE  WINAPI  PSTREAM_CreatePushHandle(PSTREAM_TRANS_TYPE eType);

3. PSTREAM_SetMsgCallBack設定某路流訊息回撥，用於判斷視訊流傳輸是否出現異常，進行相關處理。 

/**************************************************************************
* Function Name  : PSTREAM_SetMsgCallBack
* Description    : 設定訊息回撥
* Parameters     : pMsgFunc	(訊息回撥函式)	
* Parameters     : pUserData(訊息回撥使用者資料)
* Return Type    : voidp
* Last Modified  : wubihe
***************************************************************************/

DLLEXPORT void  WINAPI PSTREAM_SetMsgCallBack(PSTREAM_HANDLE hHandle ,PSTREAM_MsgCBFun pMsgFunc,	void* pUserData);

4. PSTREAM_AddStream推流器中新增軌道如音訊軌道，視訊軌道，可以是單軌道也可以是雙軌道，需要給點軌道編碼型別。傳入引數需要軌道的編碼型別，目前支援H264/G711A/G711U/AAC，後續有新要求編碼型別可以新增。H265由於目前RTP協議支援不夠，所以沒有新增。 

/**************************************************************************
* Function Name  : PSTREAM_AddStream
* Description    : 推流器新增流
* Parameters     : iHandle	   推流器控制代碼
* Parameters     : eCodeType   流編碼型別
* Return Type    : int 流控制代碼 >=0 為合法控制代碼，<0非法 最大支援2路
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT int  WINAPI  PSTREAM_AddStream(PSTREAM_HANDLE iHandle,	PSTREAM_ENCODE_TYPE eCodeType);

5.  PSTREAM_DataInput 使用者從編碼器或者網路流中接受到資料，需要不斷的呼叫該介面把資料送給PushStream,PushStream內部會對資料流的結構進行分析，這樣使用者完全不需要知道資料流的格式，快速完成開發。 傳入引數需要傳入推流器控制代碼，軌道控制代碼和編碼資料。

/**************************************************************************
* Function Name  : PSTREAM_DataInput
* Description    : 推流器資料輸入
* Parameters     : iHandle		控制代碼
* Parameters     : iStream		流控制代碼
* Parameters     : pDate		幀資訊
* Parameters     : iLen			幀長度
* Return Type    : bool 
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT bool  WINAPI PSTREAM_DataInput(PSTREAM_HANDLE iHandle,int iStream,unsigned char *pDate,int iLen);

6.  PSTREAM_StartPush呼叫該介面，程式向知道URL推送資料，在該介面呼叫之前使用者需要 PSTREAM_DataInput資料給PushStream，PushStream內部完成結構探測，如儲存SPS/PPS資訊等。所以這個介面可能需要呼叫多次，失敗在迴圈呼叫即可。 傳入引數需要URL，URL需要和建立的推流器一致，RTSP推流器必須傳入RTSP的URL,RTMP同樣道理。 

/**************************************************************************
* Function Name  : PSTREAM_StartPush
* Description    : 推流器開始推流，呼叫該介面成功前提是本地資料探測準備好
* Parameters     : iHandle			控制代碼
* Parameters     : pUrl				推流URL
* Parameters     : eTransProtocal	推流傳輸格式(RTMP/FLV,RTSP/TCP等)
* Return Type    : int				依據錯誤程式碼 E_PUSH_NOTREADY需要等待一會呼叫
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT int  WINAPI PSTREAM_StartPush(PSTREAM_HANDLE iHandle,unsigned char *pUrl);

7. PSTREAM_StopPush推流器停止推流。 

/**************************************************************************
* Function Name  : PSTREAM_StopPush
* Description    : 推流器停止推流
* Parameters     : iHandle			控制代碼
* Return Type    : bool 
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT bool  WINAPI PSTREAM_StopPush(PSTREAM_HANDLE iHandle);

 8. PSTREAM_DestroyPushHandle銷燬推流器控制代碼。 

/**************************************************************************
* Function Name  : PSTREAM_DestroyMuxHandle
* Description    : 推流器銷燬
* Parameters     : iHandle		推流器控制代碼
* Return Type    : void 
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT void WINAPI  PSTREAM_DestroyPushHandle(PSTREAM_HANDLE iHandle);

介面標頭檔案

/*******************************************************************************
Copyright (c) wubihe Tech. Co., Ltd. All rights reserved.
--------------------------------------------------------------------------------
 
Date Created:	2014-10-25
Author:	        wubihe QQ:1269122125 Email:[email protected]
Description:	推流工具庫，協議支援RTMP/RTSP

--------------------------------------------------------------------------------
Modification History
DATE          AUTHOR          DESCRIPTION
--------------------------------------------------------------------------------

********************************************************************************/
#ifndef IPUSHSTREAM_H_
#define IPUSHSTREAM_H_

#ifdef WIN32
#include <windows.h>
#include <windef.h>
#ifdef PUSHSTREAM_EXPORTS
#define DLLEXPORT __declspec(dllexport)
//#define   DLLEXPORT
#else
#define DLLEXPORT
#endif
#else
#define DLLEXPORT
#define WINAPI
#endif //WIN32

#include <string>
///////////////////////////////////////////////////////////////////////////
#ifdef __cplusplus
extern "C"
{
#endif

/******************************************************************************
PushSteam.dll巨集定義
*******************************************************************************/





/******************************************************************************
PushSteam.dll錯誤碼定義,PushSteam.dll庫錯誤碼的範圍：0-255
*******************************************************************************/
#define E_PUSH_SUCCESS		(0)				//成功
#define E_PUSH_NOTREADY		(1)				//初始化資料未準備好
#define E_PUSH_CONN_FAILURE	(2)				//連線失敗




/******************************************************************************
PushSteam.dll資料結構定義
*******************************************************************************/
///日誌級別型別
typedef enum _PSTREAM_LOG_LEVEL
{
	PSTREAM_LOG_TRACE =		0,
	PSTREAM_LOG_DEBUG =		1,                      
	PSTREAM_LOG_INFO  =		2,                      
	PSTREAM_LOG_WARN  =		3,                      
	PSTREAM_LOG_ERROR =		4, 
	PSTREAM_LOG_FATAL =		5
} PSTREAM_LOG_LEVEL;

//流編碼型別
typedef enum _PSTREAM_ENCODE_TYPE
{
	PSTREAM_VIDEO_TYPE_H264		=		0,
	PSTREAM_VIDEO_TYPE_H265		=		1,                      
	PSTREAM_AUDIO_TYPE_G711A	=		2,   
	PSTREAM_AUDIO_TYPE_AAC		=		3,
	PSTREAM_STREAM_SUPPORT_NUM	=		4
} PSTREAM_ENCODE_TYPE;

//流傳輸型別
typedef enum _PSTREAM_TRANS_TYPE
{
	PSTREAM_RTSP_RTP_TCP		=		0,
	PSTREAM_RTSP_RTP_UDP		=		1,                      
	PSTREAM_RTMP_FLV		=		2,   
	PSTREAM_TRANS_SUPPORT_NUM	=		3
} PSTREAM_TRANS_TYPE;


//訊息回撥型別
typedef enum _PSTREAM_MSG_TYPE
{
	PSTREAM_MSG_TYPE_OFFLINE	=		0,                      
	PSTREAM_MSG_SUPPORT_NUM		=		1
} PSTREAM_MSG_TYPE;

//幀資訊
typedef struct tagPStremFrameInfo
{
	//幀資料
	unsigned char * pFrame		;
	//幀大小
	int		iFrameLen	;
	//幀PTS
	LONG64		lPts		; 
	//幀DTS
	LONG64		lDts            ;           
} PStremFrameInfo;

//推流器控制代碼
typedef LONG64	PSTREAM_HANDLE;

/****************************************************************************
                        General Callback
                          通用回撥介面
****************************************************************************/
typedef void(CALLBACK *PSTREAM_LogCBFun)(PSTREAM_LOG_LEVEL nLogLevel, const char *szMessage, void* pUserData );  
typedef void(CALLBACK *PSTREAM_MsgCBFun)(PSTREAM_HANDLE lHandle, PSTREAM_MSG_TYPE eType,void* pUserData );  

/****************************************************************************
                        General System Interface
                            通用系統介面
****************************************************************************/

/**************************************************************************
* Function Name  : PSTREAM_SetLogCallBack
* Description    : 設定庫日誌回撥
* Parameters     : pLogFunc	(日誌回撥函式)	
* Parameters     : pUserData(日誌回撥使用者資料)
* Return Type    : void
* Last Modified  : wubihe
***************************************************************************/

DLLEXPORT void  WINAPI PSTREAM_SetLogCallBack(PSTREAM_LogCBFun pLogFunc,	void* pUserData);


/**************************************************************************
* Function Name  : PSTREAM_CreateMuxHandle
* Description    : 建立推流流控制代碼
* Parameters     : eType 流傳輸型別
* Return Type    : 0 非法
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT PSTREAM_HANDLE  WINAPI  PSTREAM_CreatePushHandle(PSTREAM_TRANS_TYPE eType);


/**************************************************************************
* Function Name  : PSTREAM_SetMsgCallBack
* Description    : 設定訊息回撥
* Parameters     : pMsgFunc	(訊息回撥函式)	
* Parameters     : pUserData(訊息回撥使用者資料)
* Return Type    : voidp
* Last Modified  : wubihe
***************************************************************************/

DLLEXPORT void  WINAPI PSTREAM_SetMsgCallBack(PSTREAM_HANDLE hHandle ,PSTREAM_MsgCBFun pMsgFunc,	void* pUserData);



/**************************************************************************
* Function Name  : PSTREAM_AddStream
* Description    : PS流複用器中新增流
* Parameters     : iHandle	   推流器控制代碼
* Parameters     : eCodeType   流編碼型別
* Return Type    : int 流控制代碼 >=0 為合法控制代碼，<0非法 最大支援2路
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT int  WINAPI  PSTREAM_AddStream(PSTREAM_HANDLE iHandle,	PSTREAM_ENCODE_TYPE eCodeType);

/**************************************************************************
* Function Name  : PSTREAM_DataInput
* Description    : 推流器資料輸入
* Parameters     : iHandle		控制代碼
* Parameters     : iStream		流控制代碼
* Parameters     : pDate		幀資訊
* Parameters     : iLen			幀長度
* Return Type    : bool 
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT bool  WINAPI PSTREAM_DataInput(PSTREAM_HANDLE iHandle,int iStream,unsigned char *pDate,int iLen);
/**************************************************************************
* Function Name  : PSTREAM_StartPush
* Description    : 推流器開始推流，呼叫該介面成功前提是本地資料探測準備好
* Parameters     : iHandle			控制代碼
* Parameters     : pUrl				推流URL
* Parameters     : eTransProtocal	推流傳輸格式(RTMP/FLV,RTSP/TCP等)
* Return Type    : int				依據錯誤程式碼 E_PUSH_NOTREADY需要等待一會呼叫
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT int  WINAPI PSTREAM_StartPush(PSTREAM_HANDLE iHandle,unsigned char *pUrl);


/**************************************************************************
* Function Name  : PSTREAM_StopPush
* Description    : 推流器停止推流
* Parameters     : iHandle			控制代碼
* Return Type    : bool 
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT bool  WINAPI PSTREAM_StopPush(PSTREAM_HANDLE iHandle);

/**************************************************************************
* Function Name  : PSTREAM_DestroyMuxHandle
* Description    : 推流器銷燬
* Parameters     : iHandle		推流器控制代碼
* Return Type    : void 
* Last Modified  : wubihe
***************************************************************************/
DLLEXPORT void WINAPI  PSTREAM_DestroyPushHandle(PSTREAM_HANDLE iHandle);
#ifdef __cplusplus
}
#endif



#endif /* IPUSHSTREAM_H_ */

 

                                           

 

 

 

                                               

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

                                    

 

 

 

 

相關推薦

基於c++實現RTSP/RTMP推流元件PushStream簡介

技術在於交流、溝通，轉載請註明出處並保持作品的完整性。 原文：https://blog.csdn.net/hiwubihe/article/details/84639975  [本系列相關文章]   本篇介紹一個基於C++開發的RTSP/RTMP推流元件Pus

java封裝FFmpeg命令，支援原生ffmpeg全部命令，實現FFmpeg多程序處理與多執行緒輸出控制(開啟、關閉、查詢)，rtsp/rtmp推流、拉流

前言： 之前已經對FFmpeg命令進行了封裝http://blog.csdn.net/eguid_1/article/details/51787646，但是當時沒有考慮到擴充套件性，所以總體設計不是太好，需要改動的地方也比較多，也不支援原生ffmpeg命令，所以本次版本推翻

EasyRTMP實現的rtmp推流的基本協議流程

EasyRTMP介紹 EasyRTMP是結合了多種音視訊快取及網路技術的一個rtmp直播推流端，包括：圓形緩衝區(circular buffer)、智慧丟幀、自動重連、rtmp協議等等多種技術，能夠非常有效地適應各種平臺（Windows、Linux、ARM、A

javaCV開發詳解之4：轉流器實現（也可作為本地收流器、推流器，新增新增圖片及文字水印，視訊影象幀儲存），實現rtsp/rtmp/本地檔案轉發到rtmp流媒體伺服器(基於javaCV-FFMPEG)

javaCV系列文章： 補充篇： 歡迎大家積極開心的加入討論群 javacpp-ffmpeg: 前言： 本章基於javaCV實現轉流器和收流器功能，測試採用監控rtsp地址轉發至rtmp伺服器地址 新增openCV儲存圖片功能。 補充：

基於LFLive實現rtmp推流到本地nginx伺服器

基於之前搭建的nginx + rtmp伺服器,現在結合LFLivekit,編碼獲取攝像頭視屏,麥克風音訊編碼推流 首先先將需要準備的東西下載下來整合到你的工程中去 在github上下載LFLivekit整合到你的工程中去 需要在工程中新增相應的frame

day122:MoFang:OSSRS流媒體直播伺服器&基於APICloud的acLive直播推流模組實現RTMP直播推流

目錄 1.docker安裝OSSRS流媒體直播伺服器 2.基於APICloud的acLive直播推流模組實現RTMP直播推流 3.直播流管理 1.docker安裝OSSRS流媒體直播伺服器 1.OSSRS簡介 在外界開發中, 如果要實現直播功能.常用的方式有: 1. 通過第三方介面來實現. 可以申請阿里雲

如何實現RTSP/RTMP流接入到RTSP閘道器

好多企業或開發者給我們反映，他們期望能把外網的rtsp或rtmp流，直接拉取注入到內網流媒體伺服器，保證內網使用者，無需訪問，直接連結到內網伺服器就可以觀看到公網rtmp/rtsp流。 優勢如下： 1. 內網使用者無需訪問外網，拉取公網轉發的rtmp/rtsp流，節省了企

視訊監控安防平臺-國標GB28181轉RTSP和RTMP推流進行H5(RTMP/HLS)直播（支援GB28181-2016版本、支援公網碼流傳輸）

          視訊監控安防平臺-國標GB28181轉RTSP、RTMP和HLS管理平臺（支援GB28181-2016版本、支援公網碼流傳輸）       最近抽了點時間把國標GB28181轉RTSP、RTMP和HLS管理平臺做了簡單的整理，把相應的Demo也整理好了，

基於C#實現的自動化測試框架：發布自動觸發自動化回歸測試

exc 時間流 測試用例 出現 服務器 text types filter txt 接口自動化測試用例完成以後，以前都是發布以後手動運行測試用例。雖然手動運行下腳本也就是一個F5的事情，但是離自動化測試的標準差得很遠。這兩天有了個大膽的想法，想要實現以下發布時直接觸發自動化

Android直播實現 Android端推流、播放

size input 準備 預覽 不必要 targe height 不出 oar 最近想實現一個Android直播，但是對於這方面的資料都比較零碎，一開始是打算用ffmpeg來實現編碼推流，在搜集資料期間，找到了幾個強大的開源庫，直接避免了jni的代碼，集成後只用少量的ja

基於C#實現的多生產者多消費者同步問題實例

ado text current 消費 加鎖 time 字符 msl ins 本文實例講述了基於C#實現的多生產者多消費者同步問題，分享給大家供大家參考之用。具體代碼如下：// 多個生產者和多個消費者，能生產n個產品的情況 using System; using Syst

基於C實現Word Count 將字符數、單詞數、行數，統計結果以指定格式輸出到默認文件中

計算 具體實現 post 及其 sp2 註釋 程序設計 cnblogs 基本 基於C實現Word Count ---系統分析與設計課程個人項目作業 1. 項目地址： [gitee地址] (https://gitee.com/little-baby/WordCount-by-

Nginx-RTMP推流（video）

Camera 採集資料 Camera負責採集資料，把採集來的資料交給 X264進行編碼打包給RTMP進行推流， Camera採集來的資料是NV21， 而X264編碼的輸入資料格式為I420格式。 NV21和I420都是屬於YUV420格式。而NV21是一種two-plane模式，即Y和UV分為兩個Pla

Nginx-RTMP推流（audio）

需要文中完整程式碼的可以前往Github上獲取，順便給個star唄。 AAC編碼 ​ 推送音訊跟推送視訊差不多，經過資料採集，編碼，然後通過RTMP推流。資料採集通常有兩種方式，一種是Java層的AudioRecord，另一種是native層opensl es；採集完後就是編碼，相比視訊比較簡單，編碼庫這

基於C#實現的簡單的隨機抽號器

由於老師需要，讓我寫一個隨機抽號器，，就很簡單的寫一個，用C#寫的。主要依靠random來實現一個隨機數以及list可變長陣列實現的。 由於專案難度不大，我就直接放程式碼了。 using System; using System.Collections.Generic; using

基於C#實現串列埠通訊Demo

https://www.cnblogs.com/Zed-H/p/8651882.html 1.基本概念   2.前端winForm佈局如下（僅僅為了實現功能，佈局略醜）   3.程式碼實現如下 1 nam

基於C++實現HTTP的封裝

因為在專案中有和java後臺對接的http介面，所以在此學習和總結了一下，c++如何實現Http協議的post\get\put等請求方式，通過蒐集一些資料發現，有現成的封裝庫可以實現，如curl、boost、libcurl等.大家可以直接做http應用開發。而本文是基於c/c

[原始碼和文件分享]基於C++實現的LZW壓縮演算法

1 特點 基於C++實現的LZW壓縮演算法，特點如下所示： 使用stl::map鍵值對作為字典儲存 感覺算是簡單的檔案操作 字典無限長，字典自生長。但是字典只能解析儲存ascii編碼之類存在，中文符號之類的碰到就掛 2 邏輯設計 2.1 總體思路

基於C#的WinForm中DataGridView控制元件操作彙總

基於C#的WinForm中DataGridView控制元件操作彙總 一、單元格內容的操作  *****// 取得當前單元格內容         Console.WriteLine(DataGridView1.CurrentCell.Value); // 取

[原始碼和文件分享]基於C++實現的二叉排序樹

一、使用說明 1.1 專案簡介 依次輸入關鍵字並建立二叉排序樹，實現二叉排序樹的插入和查詢功能。 1.2 專案功能要求 二叉排序樹就是指將原來已有的資料根據大小構成一棵二叉樹，二叉樹中的所有結點資料滿足一定的大小關係，所有的左子樹中的結點均比根結點小，所有的右子樹的結點均比根結點大。