C#调用EasyPusher推送到EasyDarwin流媒体服务器直播方案及示例代码整理

EasyPusher推流类库的.NET调用说明

<code class="cs" data-origin="" [code]    /// <summary>" id="PreCode" style="margin: 0px 2px; padding: 0px 5px; border: 1px solid rgb(204, 204, 204); display: block; font-family: Consolas, Inconsolata, Courier, monospace; font-weight: bold; white-space: pre; border-radius: 3px; word-wrap: break-word; font-size: 1em; letter-spacing: -1px;">    /// <summary>
/// 推流SDK方法封装
/// </summary>
public class EasyPusherSDK
{
public EasyPusherSDK() { }

[StructLayoutAttribute(LayoutKind.Sequential)]
public struct EASY_AV_Frame
{
public uint u32AVFrameFlag;    /* 帧标志  视频 or 音频 */
public uint u32AVFrameLen;     /* 帧的长度 */
public uint u32VFrameType;     /* 视频的类型，I帧或P帧 */
public IntPtr pBuffer;           /* 数据 */
public uint u32TimestampSec;   /* 时间戳(秒)*/
public uint u32TimestampUsec;    /* 时间戳(微秒) */
}

public enum EASY_PUSH_STATE_T
{
EASY_PUSH_STATE_CONNECTING = 1,         /* 连接中 */
EASY_PUSH_STATE_CONNECTED,              /* 连接成功 */
EASY_PUSH_STATE_CONNECT_FAILED,         /* 连接失败 */
EASY_PUSH_STATE_CONNECT_ABORT,          /* 连接异常中断 */
EASY_PUSH_STATE_PUSHING,                /* 推流中 */
EASY_PUSH_STATE_DISCONNECTED,           /* 断开连接 */
EASY_PUSH_STATE_ERROR
}

[StructLayoutAttribute(LayoutKind.Sequential)]
public struct EASY_MEDIA_INFO_T
{
/// <summary>
/// 视频编码类型
/// </summary>
public uint u32VideoCodec;

/// <summary>
/// 视频帧率
/// </summary>
public uint u32VideoFps;

/// <summary>
/// 音频编码类型
/// </summary>
public uint u32AudioCodec;

/// <summary>
/// 音频采样率
/// </summary>
public uint u32AudioSamplerate;

/// <summary>
/// 音频通道数
/// </summary>
public uint u32AudioChannel;

/// <summary>
/// 音频采样精度
/// </summary>
public uint u32AudioBitsPerSample;

/// <summary>
/// 视频sps帧长度
/// </summary>
public uint u32H264SpsLength;

/// <summary>
/// 视频pps帧长度
/// </summary>
public uint u32H264PpsLength;

/// <summary>
/// 视频sps帧内容
/// </summary>
[MarshalAsAttribute(UnmanagedType.ByValArray, SizeConst = 128)]
public char[] u8H264Sps;

/// <summary>
/// 视频sps帧内容
/// </summary>
[MarshalAsAttribute(UnmanagedType.ByValArray, SizeConst = 36)]
public char[] u8H264Pps;
}

[DllImport(@"Lib\RTPusher.dll", CallingConvention = CallingConvention.Cdecl)]

// -1,             /* 无效Key */
// -2,            /* 时间错误 */
// -3,            /* 进程名称长度不匹配 */
// -4,            /* 进程名称不匹配 */
// -5,          /* 有效期校验不一致 */
//-6,            /* 平台不匹配 */
// -7,          /* 授权使用商不匹配 */
// 0,          /* 激活成功 */
public static extern int RTPusher_Activate(string license);

[DllImport(@"Lib\RTPusher.dll")]
/* 创建推送句柄  返回为句柄值 */
public static extern IntPtr RTPusher_Create();

[DllImport(@"Lib\RTPusher.dll", CallingConvention = CallingConvention.Cdecl)]
/* 释放推送句柄 */
public static extern uint RTPusher_Release(IntPtr pushPtr);

[UnmanagedFunctionPointerAttribute(CallingConvention.Cdecl, CharSet = CharSet.Ansi)]
public delegate int RTPusher_Callback(int _id, EASY_PUSH_STATE_T _state, ref EASY_AV_Frame _frame, IntPtr _userptr);

[DllImport(@"Lib\RTPusher.dll"
, CallingConvention = CallingConvention.Cdecl)]
/* 设置流传输事件回调 userptr传输自定义对象指针*/
public static extern uint RTPusher_SetEventCallback(IntPtr handle, RTPusher_Callback callback, int id, IntPtr userptr);

/* 开始流传输 serverAddr:流媒体服务器地址、port:流媒体端口、streamName:流名称<xxx.sdp>、username/password:推送携带的用户名密码、pstruStreamInfo:推送的媒体定义、bufferKSize:以k为单位的缓冲区大小<512~2048之间,默认512> bool createlogfile:创建日志文件*/
[DllImport(@"Lib\RTPusher.dll", CallingConvention = CallingConvention.Cdecl)]
public static extern uint RTPusher_StartStream(IntPtr handle, string serverAddr, uint port,
string streamName, string username, string password, ref EASY_MEDIA_INFO_T pstruStreamInfo, uint bufferKSize, bool createlogfile);

/// <summary>
/// 关闭推流,并释放资源.
/// </summary>
/// <param name="pushPtr">The push PTR.</param>
/// <returns>System.UInt32.</returns>
[DllImport(@"Lib\RTPusher.dll", CallingConvention = CallingConvention.Cdecl)]
/* 停止流传输 */
public static extern uint RTPusher_StopStream(IntPtr pushPtr);

[DllImport(@"Lib\RTPusher.dll", CallingConvention = CallingConvention.Cdecl)]
/* 推流 frame:具体推送的流媒体帧 */
public static extern uint RTPusher_PushFrame(IntPtr pushPtr, ref EASY_AV_Frame frame);
}

工具方法

<code class="cs" data-origin="" [code]        /// <summary>" id="PreCode" style="margin: 0px 2px; padding: 0px 5px; border: 1px solid rgb(204, 204, 204); display: block; font-family: Consolas, Inconsolata, Courier, monospace; font-weight: bold; white-space: pre; border-radius: 3px; word-wrap: break-word; font-size: 1em; letter-spacing: -1px;">        /// <summary>
/// Determines whether [is i frame] [the specified buf].
/// </summary>
/// <param name="buf">The buf.</param>
/// <returns><c>true</c> if [is i frame] [the specified buf]; otherwise, <c>false</c>.</returns>
public static bool IsIFrame(byte[] buf)
{
int naltype = (buf[4] & 0x1F);
switch (naltype)
{
case 7: //sps
case 8: // pps
case 6: // i
case 5: //idr
return true;
case 1: // slice
case 9: // unknown ???
default:
return false;
}
}

/// <summary>
/// Gets the H246 from ps.
/// </summary>
/// <param name="pBuffer">PS 流数据</param>
/// <param name="pH264">转换后的H264流数据(音视频)</param>
/// <param name="bVideo">if set to <c>true</c> [b video].</param>
/// <param name="bAudio">if set to <c>true</c> [b audio].</param>
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
public static bool GetH246FromPS(byte[] pBuffer, ref byte[] pH264, out bool bVideo, out bool bAudio)
{
var _nBufLenth = (int)pBuffer.Length;
if (pBuffer == null || _nBufLenth <= 0)
{
bVideo = bAudio = false;
return false;
}
int nHerderLen = 0;

if (pBuffer != null
&& pBuffer[0] == 0x00
&& pBuffer[1] == 0x00
&& pBuffer[2] == 0x01
&& pBuffer[3] == 0xE0)//E==视频数据(此处E0标识为视频)
{
bVideo = true;
bAudio = false;
nHerderLen = 9 + (int)pBuffer[8];//9个为固定的数据包头长度，pBuffer[8]为填充头部分的长度

var nH264Lenth = _nBufLenth - nHerderLen;
if (pH264 == null)
{
pH264 = new byte[nH264Lenth];
}
if (pH264 != null && nH264Lenth > 0)
{
pH264 = pBuffer.Skip(nHerderLen).Take(nH264Lenth).ToArray();
}
return true;
}
else if (pBuffer != null
&& pBuffer[0] == 0x00
&& pBuffer[1] == 0x00
&& pBuffer[2] == 0x01
&& pBuffer[3] == 0xC0) //C==音频数据？
{
pH264 = null;
bVideo = false;
bAudio = true;
var nH264Lenth = _nBufLenth - nHerderLen;
nHerderLen = 9 + (int)pBuffer[8];//9个为固定的数据包头长度，pBuffer[8]为填充头部分的长度

if (pH264 == null)
{
pH264 = new byte[nH264Lenth];
}
if (pH264 != null && nH264Lenth > 0)
{
pH264 = pBuffer.Skip(nHerderLen).Take(nH264Lenth).ToArray();
}
return true;
}
else if (pBuffer != null
&& pBuffer[0] == 0x00
&& pBuffer[1] == 0x00
&& pBuffer[2] == 0x01
&& pBuffer[3] == 0xBA)//视频流数据包 包头
{
bVideo = true;
bAudio = false;
pH264 = null;
return false;
}
bVideo = bAudio = false;
return false;
}

参考链接

从海康7816的ps流里获取数据h264数据

海康SDK编程指南(C#二次开发版本)

获取更多信息