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

之前有一位朋友找到我们寻求帮助,需要解决对接海康流媒体的问题,当时对接的是海康流媒体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, intilen){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、遇到错误返回码,一定要对照错误码表格查找问题,切记不要自己一个劲的钻研代码为什么返回错误,对照错误码查找问题会事半功倍。