人脸识别/车牌识别系统安防视频云服务EasyCVR支持大华SDK语音对讲功能流程介绍

TSINGSEE青犀视频平台EasyCVR内，已经能够通过国标GB28181协议实现语音对讲功能，在大华SDK的研发方面，也开发了该功能，本文和大家分享下。

EasyCVR语音对讲主要用于实现本地平台与前端设备所处环境间的语音交互，解决本地平台需要与现场环境语音交流的需求。

调用流程图：

流程说明：

1. 完成SDK初始化流程。
2. 初始化成功后，调用 CLIENT_LoginEx2 登录设备。
3. 调用 CLIENT_SetDeviceMode 参数 emType 为 DH_TALK_SERVER_MODE 将对讲模式设置为服务器对讲模式。
4. 调用 CLIENT_SetDeviceMode 参数 emType 为 DH_TALK_ENCODE_TYPE，设置语音对讲编码信息。
5. 调用 CLIENT_SetDeviceMode 参数 emType 为 DH_TALK_SPEAK_PARAM，设置语音对讲参数。
6. 调用CLIENT_SetDeviceMode 参数emType为DH_TALK_TRANSFER_MODE，设置语音对讲转发模式。非转发模式，即本地PC与登录的设备之间实现语音对讲；转发模式，即本地PC与登录设备相应通道上连接的前端设备之间实现语音对讲。
7. 调用 CLIENT_StartTalkEx，设置回调函数并开始语音对讲。在回调函数中，对于设备发过来的音频数据，用户自行处理，可以转发也可以解码播放。
8. 用户自行将原始音频数据编码成与对讲编码类型一致的数据，并在编码后的数据前添加8个相应的私有协议字节，最后调用 CLIENT_TalkSendData，发送音频数据。
9. 对讲功能使用完毕后，调用 CLIENT_StopTalkEx，停止语音对讲。
10. 调用 CLIENT_Logout，注销用户。
11. SDK 功能使用完后，调用 CLIENT_Cleanup 释放 SDK资源。

参考代码：

#include <windows.h> 
#include <stdio.h> 
#include "dhplay.h" 
#include "Alaw_encoder.h" 
#include "dhnetsdk.h" 
#pragma comment(lib , "dhplay.lib") // 第三方编解码库，示例中以大华编解码库为例 
#pragma comment(lib , "dhnetsdk.lib") 
static BOOL g_bNetSDKInitFlag = FALSE; 
static LLONG g_lLoginHandle = 0L; 
static LLONG g_lTalkHandle = 0L; 
static BOOL g_bOpenAudioRecord = FALSE; 
static char g_szDevIp[32] = "172.23.1.27"; 
static WORD g_nPort = 37777; // tcp 连接端口，需与期望登录设备页面 tcp 端口配置一 
致 
static char g_szUserName[64] = "admin"; 
static char g_szPasswd[64] = "admin"; 
static DHDEV_TALKDECODE_INFO g_curTalkMode; 
//************************************************************************* 
******** 
// 常用回调集合声明 
103 // 设备断线回调函数 
// 不建议在该回调函数中调用 SDK 接口 
// 通过 CLIENT_Init 设置该回调函数，当设备出现断线时，SDK 会调用该函数。 
void CALLBACK DisConnectFunc(LLONG lLoginID, char *pchDVRIP, LONG nDVRPort, 
DWORD dwUser); 
// 断线重连成功回调函数 
// 不建议在该回调函数中调用 SDK 接口 
// 通过 CLIENT_SetAutoReconnect 设置该回调函数，当已断线的设备重连成功时，SDK 会 
调用该函数。 
void CALLBACK HaveReConnect(LLONG lLoginID, char *pchDVRIP, LONG nDVRPort, 
LDWORD dwUser); 
// 语音对讲的音频数据回调函数 
// 在服务器模式下只会收到设备端发来的音频数据 
// 不建议在该回调函数中调用 SDK 接口，但该回调函数可以调用 CLIENT_TalkSendData 和 
CLIENT_AudioDec SDK 接口 
// 通过 CLIENT_StartTalkEx 中设置该回调函数，当收到本地 PC 端检测到的声卡数据，或 
者收到设备端发送过来的语音数据时，SDK 会调用该函数 
void CALLBACK AudioDataCallBack(LLONG lTalkHandle, char *pDataBuf, DWORD 
dwBufSize, BYTE byAudioFlag, DWORD dwUser); 
// PC 端音频编码发送回调函数 
// pDataBuffer 为原始音频数据, DataLength 为有效数据长度 
// 通过大华编解码库的 PLAY_OpenAudioRecord 接口设置，当检测到声卡数据后，大华编解 
码库会调用该函数 
void CALLBACK AudioCallFunction(LPBYTE pDataBuffer, DWORD DataLength, void* 
pUser); 
//************************************************************************* 
******** 
// 函数前向声明 
// 该接口为调用大华编解码库实现语音对讲音频采集的示例，使用大华编解码库获取 PC 端原 
104 始音频码流 
BOOL StartAudioRecord(); 
BOOL StopAudioRecord(); 
//************************************************************************* 
******** 
void InitTest() 
{ 
// 初始化 SDK 
g_bNetSDKInitFlag = CLIENT_Init(DisConnectFunc, 0); 
if (FALSE == g_bNetSDKInitFlag) 
{ 
printf("Initialize client SDK fail; 
"); 
return; 
} 
else 
{ 
printf("Initialize client SDK done; 
"); 
} 
// 获取 SDK 版本信息 
// 此操作为可选操作 
DWORD dwNetSdkVersion = CLIENT_GetSDKVersion(); 
printf("NetSDK version is [%d]
", dwNetSdkVersion); 
// 设置断线重连回调接口，设置过断线重连成功回调函数后，当设备出现断线情况，SDK 
内部会自动进行重连操作 
// 此操作为可选操作，但建议用户进行设置 
CLIENT_SetAutoReconnect(&HaveReConnect, 0); 
// 设置登录超时时间和尝试次数 
105 106 
// 此操作为可选操作 
int nWaitTime = 5000; // 登录请求响应超时时间设置为 5s 
int nTryTimes = 3; // 登录时尝试建立链接 3 次 
CLIENT_SetConnectTime(nWaitTime, nTryTimes); 
// 设置更多网络参数，NET_PARAM 的 nWaittime，nConnectTryNum 成员与 
CLIENT_SetConnectTime 接口设置的登录设备超时时间和尝试次数意义相同 
// 此操作为可选操作 
NET_PARAM stuNetParm = {0}; 
stuNetParm.nConnectTime = 3000; // 登录时尝试建立链接的超时时间 
CLIENT_SetNetworkParam(&stuNetParm); 
NET_DEVICEINFO_Ex stDevInfoEx = {0}; 
int nError = 0; 
while(0 == g_lLoginHandle) 
{ 
// 登录设备 
g_lLoginHandle = CLIENT_LoginEx2(g_szDevIp, g_nPort, g_szUserName, 
g_szPasswd, EM_LOGIN_SPEC_CAP_TCP, NULL, &stDevInfoEx, &nError); 
if(0 == g_lLoginHandle) 
{ 
// 根据错误码，可以在 dhnetsdk.h 中找到相应的解释，此处打印的是 16 进制， 
头文件中是十进制，其中的转换需注意 
// 例如： 
// #define NET_NOT_SUPPORTED_EC(23) // 当前 SDK 未支持该功能，对应的 
错误码为 0x80000017, 23 对应的 16 进制为 0x17 
printf("CLIENT_LoginEx2 %s[%d]Failed!Last Error[%x]
" , g_szDevIp , 
g_nPort , CLIENT_GetLastError()); 
} 
else { 
printf("CLIENT_LoginEx2 %s[%d] Success
" , g_szDevIp , g_nPort); 
} 
// 用户初次登录设备，需要初始化一些数据才能正常实现业务功能，建议登录后等待 
一小段时间，具体等待时间因设备而异。 
Sleep(1000); 
printf("
"); 
} 
} 
void RunTest() 
{ 
if (FALSE == g_bNetSDKInitFlag) 
{ 
return; 
} 
if (0 == g_lLoginHandle) 
{ 
return; 
} 
// 设置为服务器对讲模式 
BOOL bSuccess = CLIENT_SetDeviceMode(g_lLoginHandle, DH_TALK_SERVER_MODE, 
NULL); 
if (FALSE == bSuccess) 
{ 
printf("CLIENT_SetDeviceMode cmd[%d] Failed!Last Error[%x]
" , 
DH_TALK_SERVER_MODE, CLIENT_GetLastError()); 
return; 
} 
107 108 
// 设置语音对讲编码信息 
g_curTalkMode = DH_TALK_PCM; 
bSuccess = CLIENT_SetDeviceMode(g_lLoginHandle, DH_TALK_ENCODE _TYPE, 
&g_curTalkMode); 
if (FALSE == bSuccess) 
{ 
printf("CLIENT_SetDeviceMode cmd[%d] Failed!Last Error[%x]
" , 
DH_TALK_ENCODE_TYPE, CLIENT_GetLastError()); 
return; 
} 
// 设置对讲参数 
NET_SPEAK_PARAM stuSpeak = {sizeof(stuSpeak)}; 
stuSpeak.nMode = 0; // 0：对讲（默认模式），1：喊话；从喊话切换到对讲要重新设 
置 
stuSpeak.nSpeakerChannel = 0; // 语音对讲通道号，默认为 0 
bSuccess = CLIENT_SetDeviceMode(g_lLoginHandle, DH_TALK_SPEAK_PARAM, 
&stuSpeak); 
if (FALSE == bSuccess) 
{ 
printf("CLIENT_SetDeviceMode cmd[%d] Failed!Last Error[%x]
" , 
DH_TALK_SPEAK_PARAM, CLIENT_GetLastError()); 
return; 
} 
// 设置转发模式 
NET_TALK_TRANSFER_PARAM stuTransfer = {sizeof(stuTransfer)}; 
stuTransfer.bTransfer = FALSE; // 由于是对登录设备对讲，关闭转发模式 
bSuccess = CLIENT_SetDeviceMode(g_lLoginHandle, DH_TALK_TRANSFER_MODE, 
&stuTransfer); 
if (FALSE == bSuccess) 
{ 109 
printf("CLIENT_SetDeviceMode cmd[%d] Failed!Last Error[%x]
" , 
DH_TALK_TRANSFER_MODE, CLIENT_GetLastError()); 
return; 
} 
g_lTalkHandle = CLIENT_StartTalkEx(g_lLoginHandle, AudioDataCallBack, 
(DWORD)NULL); 
if(0 != g_lTalkHandle) 
{ 
bSuccess = StartAudioRecord(); 
if(TRUE == bSuccess) 
{ 
g_bOpenAudioRecord = TRUE; 
} 
else 
{ 
printf("StartAudioRecord Failed!
"); 
CLIENT_StopTalkEx(g_lTalkHandle); 
g_lTalkHandle = 0; 
} 
} 
else 
{ 
printf("CLIENT_StartTalkEx Failed!Last Error[%x]
", 
CLIENT_GetLastError()); 
} 
} 
void EndTest() 
{ 
printf("input any key to quit!
"); 110 
getchar(); 
// 清理大华编解码库对讲资源 
if(TRUE == g_bOpenAudioRecord) 
{ 
if (TRUE == StopAudioRecord()) 
{ 
g_bOpenAudioRecord = FALSE; 
} 
} 
// 停止语音对讲 
if (0 != g_lTalkHandle) 
{ 
if(FALSE == CLIENT_StopTalkEx(g_lTalkHandle)) 
{ 
printf("CLIENT_StopTalkEx Failed!Last Error[%x]
", 
CLIENT_GetLastError()); 
} 
else 
{ 
g_lTalkHandle = 0; 
} 
} 
// 退出设备 
if (0 != g_lLoginHandle) 
{ 
if(FALSE == CLIENT_Logout(g_lLoginHandle)) 
{ 
printf("CLIENT_Logout Failed!Last Error[%x]
", 
CLIENT_GetLastError());111 
} 
else 
{ 
g_lLoginHandle = 0; 
} 
} 
// 清理初始化资源 
if (TRUE == g_bNetSDKInitFlag) 
{ 
CLIENT_Cleanup(); 
g_bNetSDKInitFlag = FALSE; 
} 
return; 
} 
int main() 
{ 
InitTest(); 
RunTest(); 
EndTest(); 
return 0; 
}