- 易迪拓培训,专注于微波、射频、天线设计工程师的培养
基于wince的网络音视频通信
//-------------------------音频--------------------------//
audio:
g_pOut = new CWaveOut();
g_pIn = new CWaveIn();
g_pOut-》StartPlay();
g_pIn-》StartRec(OnRecCapAndSend,(DWORD)p);
}
//=====================================================================
// 语法格式: void FreeAV()
// 实现功能: 释放音频、视频
// 参数: 无
// 返回值: 无
//=====================================================================
void FreeAV()
{
//-------------------------视频--------------------------//
if(isCameraEnabled)
capStopCamera(0);
//-------------------------音频--------------------------//
g_pOut-》StopPlay();
g_pIn-》StopRec();
delete g_pOut;
delete g_pIn;
//------------------------UDP------------------------//
m_CEUdp.Close();
}
//=====================================================================
// 语法格式: void RecAndPlay(WPARAM wParam,LPARAM lParam)
// 实现功能: 接收网络传来的音频,以及播放
// 参数: wParam,表示数据;lParam,表示数据长度
// 返回值: 无
//=====================================================================
static void CALLBACK OnUdpCERecv(CWnd * pWnd,char* buf,int nLen,sockaddr * addr)
{
g726_Decode(buf,(unsigned char*)waveout);
g_pOut-》Play(waveout,AudioData_Size);
}
//=====================================================================
// 语法格式: static void OnRecCapAndSend(char *data,int length,DWORD userdata)
// 实现功能: 录音,摄像并且发送
// 参数: data表示数据,length表示数据长度,userdata暂时没用
// 返回值: 无
//=====================================f================================
static void OnRecCapAndSend(char *data,int length,DWORD userdata)
{
//-------------------------音频--------------------------//
memcpy(pin,g_pIn-》buffer,AudioData_Size);
g726_Encode((unsigned char*)pin,pout);
m_CEUdp.SendData(pout,Compr_AudioData_Size);
//-------------------------视频--------------------------//
if(isCameraEnabled==false)//如果程序不能用摄像头
return;
Sleep(15);
int index=0;
memset(lpFrameBuffer, 0, dwSize);
memset(lpJpgBuffer, 0, dwJpg);
dwRtnSize[0] = dwRtnSize[1] = 0;
if (capGetPicture(index, lpFrameBuffer, dwSize, lpJpgBuffer, dwJpg, dwRtnSize) == 0)
{
/// m_CEUdp.SendData((const char *)lpJpgBuffer,dwRtnSize[1]);
char tmp[1440];
int tmp_i=0;
for(int i=0;i《dwRtnSize[1];i++)
{
tmp[tmp_i]=lpJpgBuffer[i];
tmp_i++;
if(tmp_i==1440)
{
m_CEUdp.SendData(tmp,1440);
tmp_i=0;
}
else if(i==dwRtnSize[1]-1)
{
m_CEUdp.SendData(tmp,dwRtnSize[1]-(dwRtnSize[1]/1440)*1440);
tmp_i=0;
}
}
}
}
};
以下是PC部分的关键代码
#pragma once
#include "winsock2.h"
//UDP支持
#include "。.UDPUDP.h"
//音频支持
#include "WaveIn.h"
#include "waveout.h"
//G726支持
#include "g726.h"
//视频支持
#include "Gdiplus.h"
using namespace Gdiplus;
#define VideoData_Size 1440 //每块视频数据包的大小
#define Video_Width 320 //视频宽度
#define Video_Height 240 //视频长度
#define AudioData_Size 960 //每块音频数据包的大小
#define Compr_AudioData_Size 120 //压缩后音频块的大小
//音频输入输出变量
CWaveIn *g_pIn;
CWaveOut *g_pOut;
char pin[AudioData_Size],pout[Compr_AudioData_Size];
char wave_data[AudioData_Size];
//UDP变量
CUDP_CE m_CEUdp;
//视频输入变量
GdiplusStartupInput m_gdiPlusInPut;
ULONG_PTR m_gdiPlusToken;
char video_data[Video_Width*Video_Height];
int index;//视频数据当前索引
class AVClass
{
private:
public:
//=====================================================================
// 语法格式: void InitAV(CWnd * p)
// 实现功能: 初始化音频和视频,用于录音、播放音频,以及播放视频
// 参数: p为窗口类指针
// 返回值: 无
//=====================================================================
void InitAV(CWnd * p,int local_port,CString remote_ip,int remote_port)
{
//-------------------------UDP连接--------------------------//
m_CEUdp.m_OnUdpRecv = OnUdpCERecv;
DWORD nResult = m_CEUdp.Open(p,local_port,remote_ip,remote_port);
if (nResult 《=0)
{
AfxMessageBox(_T("打开端口失败"));
return;
}
//-------------------------音频--------------------------//
g_pOut = new CWaveOut();
g_pIn = new CWaveIn();
g_pOut-》StartPlay();
g_pIn-》StartRec(OnRecording,(DWORD)p);
//-------------------------视频--------------------------//
GdiplusStartup( &m_gdiPlusToken, &m_gdiPlusInPut, NULL ); //初始化GDI+
memset(video_data,0,Video_Width*Video_Height);
index=0;
}
//=====================================================================
// 语法格式: void FreeAV()
// 实现功能: 释放音频、视频
// 参数: 无
// 返回值: 无
//===================================================================== 来源:电子技术应用