基于wince的网络音视频通信

void FreeAV（）

{

//-------------------------音频--------------------------//

g_pOut-》StopPlay（）;

g_pIn-》StopRec（）;

delete g_pOut;

delete g_pIn;

//-------------------------视频--------------------------//

GdiplusShutdown（m_gdiPlusToken）; //销毁GDI+

//------------------------UDP--------------------------//

m_CEUdp.Close（）;

}

//=====================================================================

// 语法格式： void RecAndPlay（WPARAM wParam，LPARAM lParam，HWND hwnd）

// 实现功能： 接收网络传来的音频，以及播放

// 参数： wParam，表示数据；lParam，表示数据长度；hwnd，表示显示视频的窗口句柄

// 返回值： 无

//=====================================================================

static void CALLBACK OnUdpCERecv（CWnd *pWnd，char* buf，int nLen，sockaddr * addr）

{

/*测试收到的数据大小

CString tmp;

tmp.Format（L"%d"，nLen）;

MessageBox（0，tmp，0，0）;

return;*/

//-------------------------如果是音频数据--------------------------//

if（nLen==Compr_AudioData_Size）

{

g726_Decode（buf，（unsigned char*）wave_data）;

g_pOut-》Play（wave_data，AudioData_Size）;

return;

}

//-------------------------如果是视频数据--------------------------//

if（nLen==VideoData_Size）//完整的视频数据块

{

for（int i=0;i《nLen;i++）

{

video_data［index］=buf［i］;

index++;

}

return;

}

//视频数据块的最后一块

for（int i=0;i《nLen;i++）

{

video_data［index］=buf［i］;

index++;

}

//如果JPEG图像特别大，则肯定是出错，则抛弃

if（index》Video_Width*Video_Height）

{

//MessageBox（0，"缓冲区出错"，"错误信息"，0）;

return;

}

try{

IPicture *pPic;

IStream *pStm ;

//分配全局存储空间

HGLOBAL hGlobal=GlobalAlloc（GMEM_MOVEABLE，index）;

LPVOID pvData=NULL ;

//锁定分配内存块

pvData=GlobalLock（hGlobal）;

//复制数据包video_data到pvData

memcpy（pvData，video_data，index）;

GlobalUnlock（hGlobal）;

CreateStreamOnHGlobal（hGlobal，TRUE，&pStm）;

ULARGE_INTEGER pSeek;

LARGE_INTEGER dlibMove ={ 0 } ;

pStm-》Seek（dlibMove，STREAM_SEEK_SET ，&pSeek）;

// Sleep（15）;

//装入图形文件

if（FAILED（OleLoadPicture（pStm，index，TRUE，IID_IPicture，（LPVOID*）&pPic）））

{//附：如果video_data这个数组包含的图像有错，则OleLoadPicture 容易产生读写内存错误

// pPic-》Release（）;

// pStm-》Release（）;

return ;

}

Image img（pStm，0）;

Graphics mGraphics（GetDC（pWnd-》m_hWnd））;

mGraphics.DrawImage（&img， 0， 0， Video_Width， Video_Height）;

img.~Image（）;//会出错

mGraphics.~Graphics（）;

pPic-》Release（）;

pStm-》Release（）;

}

catch（CException * e）

{}

memset（video_data，0，Video_Width*Video_Height）;

index=0;

}

//=====================================================================

// 语法格式： static void OnRecording（char *data，int length，DWORD userdata）

// 实现功能： 释放音频

// 参数： data表示数据，length表示数据长度，userdata暂时没用

// 返回值： 无

//=====================================================================

static void OnRecording（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）;

}

};