视频监控系统视频上云解决方案EasyCVR集成海康EHome私有协议系列——通过流媒体服务开启语音对讲

   void main(){
    
    //SMS开启服务
 
    //SMS初始化
    NET_ESTREAM_Init();
 
    //语音对讲监听参数
    NET_EHOME_LISTEN_VOICETALK_CFG struListen = {0};
    memcpy(struListen.struIPAdress.szIP,"10.16.2.123", sizeof("10.16.2.123"));
    struListen.struIPAdress.wPort = 8003; //流媒体服务监听端口
    struListen.fnNewLinkCB = fnVOICETALK_NEWLINK_CB; //语音对讲连接请求回调函数
    struListen.pUser = NULL;
 
    //启动语音对讲监听
    LONG lHandle = NET_ESTREAM_StartListenVoiceTalk(&struListen);
    if(lHandle < -1)
    {
        printf("NET_ESTREAM_StartListenVoiceTalk failed, error code: %dn", NET_ESTREAM_GetLastError());
        NET_ESTREAM_Fini();
        return;
    }
    printf("NET_ESTREAM_StartListenVoiceTalk!n");
    //
 
    
    //CMS注册和语音对讲请求
 
    //CMS注册模块初始化
    NET_ECMS_Init();
 
    //注册监听参数
    NET_EHOME_CMS_LISTEN_PARAM struCMSListenPara = {0};
    memcpy(struCMSListenPara.struAddress.szIP, "0.0.0.0", sizeof("0.0.0.0"));
    struCMSListenPara.struAddress.wPort = 7660;
    struCMSListenPara.fnCB = RegisterCallBack;
 
    //启动监听服务，接收设备注册信息
    LONG lListen = NET_ECMS_StartListen(&struCMSListenPara);
    if(lListen < -1)
    {
        printf("NET_ECMS_StartListen failed, error code: %dn", NET_ECMS_GetLastError());
        NET_ECMS_Fini();
        return;
    }
    printf("NET_ECMS_StartListen!n");
 
    while(1)
    {
        Sleep(1000);  //注册成功之后再做后续操作
        if(lLoginID >= 0)
        {
            break;
        }
    }
 
    //语音对讲请求输入参数
    NET_EHOME_VOICE_TALK_IN struVoiceTalkIn = {0};
    struVoiceTalkIn.dwVoiceChan = 1; //语音对讲通道号
    memcpy(struVoiceTalkIn.struStreamSever.szIP, "10.16.2.123", sizeof("10.16.2.123"));//流媒体服务IP地址
    struVoiceTalkIn.struStreamSever.wPort = 8003; //流媒体服务端口，需要跟服务监听端口一致
 
    //语音对讲请求输出参数
    NET_EHOME_VOICE_TALK_OUT struVoiceTalkOut = {0};
 
    //CMS语音对讲请求
    if(!NET_ECMS_StartVoiceWithStmServer(lLoginID, &struVoiceTalkIn, &struVoiceTalkOut))
    {
        printf("NET_ECMS_StartVoiceWithStmServer failed, error code: %dn", NET_ECMS_GetLastError());
        NET_ECMS_Fini();
        return;
    }
    printf("NET_ECMS_StartVoiceWithStmServer!n");
 
    //CMS请求开始推流
    NET_EHOME_PUSHVOICE_IN struPushVoiceIn = {0};
    struPushVoiceIn.dwSize = sizeof(struPushVoiceIn);
    struPushVoiceIn.lSessionID = struVoiceTalkOut.lSessionID;
    NET_EHOME_PUSHVOICE_OUT struPushVoiceOut = {0};
    struPushVoiceOut.dwSize = sizeof(struPushVoiceOut);
    if (!NET_ECMS_StartPushVoiceStream(lLoginID, &struPushVoiceIn, &struPushVoiceOut))
    {
        printf("NET_ECMS_StartPushVoiceStream failed, error code: %dn", NET_ECMS_GetLastError());
        NET_ECMS_Fini();
        return;
    }
    printf("NET_ECMS_StartPushVoiceStream!n");
 
    //创建线程从文件读取语音数据发送给设备
	DWORD dwThreadId;
	CreateThread(NULL, 0, LPTHREAD_START_ROUTINE(TestVoiceTransThread), (void*)lVoiceLinkHandle, 0, &dwThreadId);
 
    Sleep(50000);
 
    
    //退出
 
    //释放CMS语音对讲请求资源
    if(!NET_ECMS_StopVoiceTalkWithStmServer(lLoginID, struVoiceTalkOut.lSessionID))
    {
        printf("NET_ECMS_StopVoiceTalkWithStmServer failed, error code: %dn", NET_ECMS_GetLastError());
    }
	
    //CMS停止监听服务
    if(!NET_ECMS_StopListen(lListen))
    {
        printf("NET_ECMS_StopListen failed, error code: %dn", NET_ECMS_GetLastError());
    }
 
    //CMS反初始化，释放资源
    NET_ECMS_Fini();
    //
 
    //SMS停止语音对讲
    if(lVoiceHandle >= 0)
    {
		if (!NET_ESTREAM_StopVoiceTalk(lVoiceHandle))
        {
            printf("NET_ESTREAM_StopVoiceTalk failed, error code: %dn", NET_ECMS_GetLastError());
        }
    }
 
    //SMS停止语音对讲监听服务
    if(lVoiceLinkHandle >= 0)
    {
        if (!NET_ESTREAM_StopListenVoiceTalk(lVoiceLinkHandle))
        {
            printf("NET_ESTREAM_StopListenVoiceTalk failed, error code: %dn", NET_ECMS_GetLastError());
        }
    }
    //SMS反初始化，释放资源
    NET_ESTREAM_Fini();
 
    //释放文件资源
    if(AudioTalkfile != NULL)
    {
        fclose(AudioTalkfile);
        AudioTalkfile = NULL;
    }
    
    printf("Exit!n");
}