EasyStreamClient对接海康流媒体V4.X实现无插件播放流程记录

Posted 2021-10-28 TSINGSEE

之前有一位朋友找到我们寻求帮助，需要解决对接海康流媒体的问题，当时对接的是海康流媒体V4.X，因为平台只支持SDK方式对接，无法满足无插件播放的需求，后来经过与海康官方SDK联系后，取得了开发版SDK包，经研究开发文档和项目DEMO，我们用EasyStreamCLient拉流库+nginx解决了这个问题，下面我把整个实现过程做个简单记录，方便后期使用。

实现流程

1、初始化流媒体客户端，把SDK内的初始化函数StreamClient_InitLib()包装到内部：

Easy_API int Easy_APICALL EasyStreamClient_InitModule()
{
	 int errCode = StreamClient_InitLib();
	 if (errCode != 0)
	 {
		 printf("初始化失败.\\n");
		 return -1;
	 }
	 return 0;
}

如果失败了的话就直接返回-1，成功就返回0；

2、创建RTSP会话，CreateSession成功后返回会话句柄大于等于0

int HikStreamClient::Init()
{
	hikStream.sessionHandle = StreamClient_CreateSession();
	if (hikStream.sessionHandle < 0)
	{
		return -2;
	}
	if (NULL == hikStream.psDemuxHandle)
	{
		PSDemux_Init(&hikStream.psDemuxHandle, 1024*512, 1024*1024);
	}
	return 0;
}

3、回调实时预览，设置 PS 封装数据回调函数，从流媒体服务器接收的视频流数据经过转封装操作，回调给调用者。若从流媒体服务器接收的码流不支持转封装，则回调原始码流。

int	HikStreamClient::OpenStream(char *url, int connectType, void *userPtr, int reconn, int timeoutSecs)
{
	if (NULL == url)				return -1;
	if ( (int)strlen(url) < 1)		return -1;
	if (hikStream.sessionHandle < 0)		return -2;
	memset(hikStream.url, 0x00, sizeof(hikStream.url));
	strcpy(hikStream.url, url);
	hikStream.connectType = connectType;
	hikStream.reconnect = reconn;
	hikStream.userPtr		= userPtr;
	hikStream.timeoutSecs = timeoutSecs;
	StreamClient_SetMsgCallBack(hikStream.sessionHandle, __pStreamClientMsgFunc, (void *)&hikStream);
	StreamClient_SetPsDataCallBack(hikStream.sessionHandle,__pStreamClientPsDataFunc,(void*)&hikStream);
	int tranMethod = RTPRTSP_TRANSMODE;
	char username[128] = {0};
	char password[128] = {0};
	int ret = StreamClient_Start( hikStream.sessionHandle,  NULL, url, "StreamClient", tranMethod, username, password);
	if (ret != 0)
	{
		_TRACE(TRACE_LOG_ERROR, (char *)"OpenStream fail. ErrCode[%d]\\n", ret);
		return -10;
	}
	hikStream.playHandle = 1;
	return 0;
}

取得视频流数据后，我们通过RTMP的形式推送给Nginx做处理，进而实现分发HTTP-FLV\\HTTP-HLS协议流。

数据回调

海康流媒体 V4.X客户端消息回调和数据回调实现示例代码如下：

1、消息回调：

int CALLBACK MsgFunc(int sessionhandle, void* userdata, int opt, void* param1, void* param2,
void* param3, void* param4)
{
if (sessionhandle < 0)
{
return 0;
}
if (opt == STREAM_CLIENT_ERR_FROM_SERVER || opt == STREAM_CLIENT_VTM_ERR) // 流媒
体服务器或VTM产生错误信息
{
if (NULL == param1)
{
return -1;
}
PERRORSTACKINFO1 pErrInfo = (PERRORSTACKINFO1)param1;
char errInfo[512] = {0};
sprintf(errInfo, "recv server err info, pinfo count[%d], businessID[%s],
moduleID[%s], timestamp[%I64x], errorCode[%d], errorMsg[%s]", *(pErrInfo->count),
pErrInfo->perrorInfo->businessID,
pErrInfo->perrorInfo->moduleID,pErrInfo->perrorInfo->timestamp,
pErrInfo->perrorInfo->errorCode, pErrInfo->perrorInfo->errorMsg);
AfxMessageBox(errInfo);
}
else // 流媒体客户端
{
char errDescribe[512] = {0};
sprintf(errDescribe, "recv client errCode:%d ", opt);
AfxMessageBox(errDescribe);
}
return 0;
}

2、原始码流或 PS 数据回调：

int CALLBACK DataFunc(int sessionhandle, void* userdata, int datatype, void* pdata, int
ilen)
{
if ((sessionhandle < 0) || (NULL == pdata) || (ilen <= 0))
{
return -1;
}
switch (datatype)
{
case STREAM_HEAD: // 码流头数据
break;
case STREAM_DATA: // 码流数据
break;
case STREAM_PLAYBACK_FINISH: // 回放/下载至结束
break;
default:
break;
}
return 0;
}

海康流媒体 V4.X SDK客户端开发注意事项：

1、在数据回调和消息回调中，不要对当前会话进行操作，比如：不要调用StreamClient_Stop、StreamClient_DestroySession 等接口；
2、在数据回调和消息回调中，不要进行耗时操作，否则会有异常；
3、一个会话句柄只能完成一次流程。例如：每个会话只能完成单一的功能，若调用接口发生失败，需要销毁会话。如果需要多次操作，需要分别对应不同会话；
4、遇到错误返回码，一定要对照错误码表格查找问题，切记不要自己一个劲的钻研代码为什么返回错误，对照错误码查找问题会事半功倍。