// RecTestDlg.cpp : implementation file
//
#include "stdafx.h"
#include "RecTest.h"
#include "RecTestDlg.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
/////////////////////////////////////////////////////////////////////////////
// CAboutDlg dialog used for App About
class CAboutDlg : public CDialog
{
public:
CAboutDlg();
// Dialog Data
//{{AFX_DATA(CAboutDlg)
enum { IDD = IDD_ABOUTBOX };
//}}AFX_DATA
// ClassWizard generated virtual function overrides
//{{AFX_VIRTUAL(CAboutDlg)
protected:
virtual void DoDataExchange(CDataExchange* pDX); // DDX/DDV support
//}}AFX_VIRTUAL
// Implementation
protected:
//{{AFX_MSG(CAboutDlg)
//}}AFX_MSG
DECLARE_MESSAGE_MAP()
};
CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
//{{AFX_DATA_INIT(CAboutDlg)
//}}AFX_DATA_INIT
}
void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CAboutDlg)
//}}AFX_DATA_MAP
}
BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
//{{AFX_MSG_MAP(CAboutDlg)
// No message handlers
//}}AFX_MSG_MAP
END_MESSAGE_MAP()
/////////////////////////////////////////////////////////////////////////////
// CRecTestDlg dialog
CRecTestDlg::CRecTestDlg(CWnd* pParent /*=NULL*/)
: CDialog(CRecTestDlg::IDD, pParent)
{
//{{AFX_DATA_INIT(CRecTestDlg)
//}}AFX_DATA_INIT
// Note that LoadIcon does not require a subsequent DestroyIcon in Win32
m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}
void CRecTestDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CRecTestDlg)
//}}AFX_DATA_MAP
}
BEGIN_MESSAGE_MAP(CRecTestDlg, CDialog)
//{{AFX_MSG_MAP(CRecTestDlg)
ON_WM_SYSCOMMAND()
ON_WM_PAINT()
ON_WM_QUERYDRAGICON()
ON_BN_CLICKED(IDC_BEGIN, OnBegin)
ON_MESSAGE(MM_WIM_DATA,OnMM_WIM_DATA)
ON_MESSAGE(MM_WIM_CLOSE,OnMM_WIM_CLOSE)
ON_MESSAGE(MM_WOM_OPEN,OnMM_WOM_OPEN)
ON_MESSAGE(MM_WOM_DONE,OnMM_WOM_DONE)
ON_MESSAGE(MM_WOM_CLOSE,OnMM_WOM_CLOSE)
//}}AFX_MSG_MAP
END_MESSAGE_MAP()
/////////////////////////////////////////////////////////////////////////////
// CRecTestDlg message handlers
BOOL CRecTestDlg::OnInitDialog()
{
CDialog::OnInitDialog();
// Add "About..." menu item to system menu.
// IDM_ABOUTBOX must be in the system command range.
ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
ASSERT(IDM_ABOUTBOX < 0xF000);
CMenu* pSysMenu = GetSystemMenu(FALSE);
if (pSysMenu != NULL)
{
CString strAboutMenu;
strAboutMenu.LoadString(IDS_ABOUTBOX);
if (!strAboutMenu.IsEmpty())
{
pSysMenu->AppendMenu(MF_SEPARATOR);
pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
}
}
// Set the icon for this dialog. The framework does this automatically
// when the application's main window is not a dialog
SetIcon(m_hIcon, TRUE); // Set big icon
SetIcon(m_hIcon, FALSE); // Set small icon
// TODO: Add extra initialization here
//allocate memory for wave header
pWaveHdr1=reinterpret_cast<PWAVEHDR>(malloc(sizeof(WAVEHDR)));
pWaveHdr2=reinterpret_cast<PWAVEHDR>(malloc(sizeof(WAVEHDR)));
pWaveHdrOut=reinterpret_cast<PWAVEHDR>(malloc(sizeof(WAVEHDR)));
//***reinterpret_cast **** operation is used to convert any type of
//pointer to other type
//allocate memory for save buffer
for(int i=0;i<InBlocks;i++)
{
m_AudioDataIn[i].dwLength = 0;
m_AudioDataIn[i].lpdata = reinterpret_cast<PBYTE>(malloc(1));
}
for(i =0;i<OutBlocks;i++)
{
m_AudioDataOut[i].dwLength = 0;
m_AudioDataOut[i].lpdata = reinterpret_cast<PBYTE>(malloc(1));
}
nAudioIn = 0;
nAudioOut = 0;
nSend = 0;
nReceive = 0;
return TRUE; // return TRUE unless you set the focus to a control
}
void CRecTestDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
if ((nID & 0xFFF0) == IDM_ABOUTBOX)
{
CAboutDlg dlgAbout;
dlgAbout.DoModal();
}
else
{
CDialog::OnSysCommand(nID, lParam);
}
}
// If you add a minimize button to your dialog, you will need the code below
// to draw the icon. For MFC applications using the document/view model,
// this is automatically done for you by the framework.
void CRecTestDlg::OnPaint()
{
if (IsIconic())
{
CPaintDC dc(this); // device context for painting
SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);
// Center icon in client rectangle
int cxIcon = GetSystemMetrics(SM_CXICON);
int cyIcon = GetSystemMetrics(SM_CYICON);
CRect rect;
GetClientRect(&rect);
int x = (rect.Width() - cxIcon + 1) / 2;
int y = (rect.Height() - cyIcon + 1) / 2;
// Draw the icon
dc.DrawIcon(x, y, m_hIcon);
}
else
{
CDialog::OnPaint();
}
}
// The system calls this to obtain the cursor to display while the user drags
// the minimized window.
HCURSOR CRecTestDlg::OnQueryDragIcon()
{
return (HCURSOR) m_hIcon;
}
UINT Audio_Listen_Thread(LPVOID lParam)
{
CRecTestDlg *pdlg = (CRecTestDlg*)lParam;
CSocket m_Server;
DWORD length;
if(!m_Server.Create(4002))
AfxMessageBox("Listen Socket create error"+pdlg->GetError(GetLastError()));//不可单个运行,重复产生同一端口显然是错误的
if(!m_Server.Listen())
AfxMessageBox("m_server.Listen ERROR"+pdlg->GetError(GetLastError()));
CSocket recSo;
if(! m_Server.Accept(recSo))
AfxMessageBox("m_server.Accept() error"+pdlg->GetError(GetLastError()));
m_Server.Close();
int sendcount=0;//just for test
int ret ;
while(1)
{ //开始循环接收声音文件,首先接收文件长度
ret = recSo.Receive(&length,sizeof(DWORD));
if(ret== SOCKET_ERROR )
AfxMessageBox("服务器端接收声音文件长度出错,原因: "+pdlg->GetError(GetLastError()));
if(ret!=sizeof(DWORD))
{
AfxMessageBox("接收文件头错误,将关闭该线程");
recSo.Close();
return -1;
}//接下来开辟length长的内存空间
pdlg->m_AudioDataOut[pdlg->nReceive].lpdata =(PBYTE)realloc (0,length);
if (pdlg->m_AudioDataOut[pdlg->nReceive].lpdata == NULL)
{
MessageBeep (MB_ICONEXCLAMATION) ;
AfxMessageBox("erro memory_ReceiveAudio");
pdlg->OnOK();
recSo.Close();
return -1;
}
else//内存申请成功,可以进行循环检测接受
{
DWORD dwReceived = 0,dwret;
while(length>dwReceived)
{
dwret = recSo.Receive((pdlg->m_AudioDataOut[pdlg->nReceive].lpdata+dwReceived),(length-dwReceived));
dwReceived +=dwret;
if(dwReceived ==length)
{
pdlg->m_AudioDataOut[pdlg->nReceive].dwLength = length;
break;
}
}
}//本轮声音文件接收完毕
pdlg->nReceive=(pdlg->nReceive+1)%OutBlocks;
}
recSo.Close();
pdlg->OnOK();
return 0;
}
UINT Audio_Send_Thread(LPVOID lParam)//专职的声音文件发送线程
{ // 端口也是专用的
CRecTestDlg *pdlg = (CRecTestDlg*)lParam;
CSocket m_Client;
m_Client.Create();
if( m_Client.Connect("127.0.0.1",4002))
{
DWORD ret, length;
int count=0;
while(1)//循环使用指针nSend
{
length =pdlg->m_AudioDataIn[pdlg->nSend].dwLength;
if(length !=0)
{ //首先发送块的长度
if(((ret = m_Client.Send(&length,sizeof(DWORD)))!=sizeof(DWORD))||(ret==SOCKET_ERROR))
{
AfxMessageBox("声音文件头传输错误!"+pdlg->GetError(GetLastError()));
pdlg->OnOK();
break;
}//其次发送块的内容 ,循环检测发送
DWORD dwSent = 0;//已经发送掉的字节数
while(1)//==============================发送声音文件开始
{
ret = m_Client.Send((pdlg->m_AudioDataIn[pdlg->nSend].lpdata+dwSent),(length-dwSent));
if(ret==SOCKET_ERROR)//检错
{
AfxMessageBox("声音文件传输错误!"+pdlg->GetError(GetLastError()));
pdlg->OnOK();
break;
}
else //发送未发送完的
{
dwSent += ret;
if(dwSent ==length)
{
free(pdlg->m_AudioDataIn[pdlg->nSend].lpdata);
没有合适的资源?快使用搜索试试~ 我知道了~
商业编程-源码-实时语音通信的实现.zip
共17个文件
h:4个
cpp:3个
bmp:1个
1.该资源内容由用户上传,如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
版权申诉
0 下载量 161 浏览量
2022-06-23
12:35:32
上传
评论
收藏 29KB ZIP 举报
温馨提示
商业编程-源码-实时语音通信的实现.zip
资源推荐
资源详情
资源评论
收起资源包目录
商业编程-源码-实时语音通信的实现.zip (17个子文件)
实时语音通信的实现
代码
RecTest.rc 6KB
StdAfx.cpp 209B
resource.h 730B
RecTestDlg.h 2KB
RecTest.h 1KB
RecTest.dsw 539B
RecTest.opt 67KB
RecTest.cpp 2KB
StdAfx.h 1KB
RecTestDlg.cpp 15KB
RecTest.dsp 4KB
RecTest.clw 1KB
res
RecTest.ico 1KB
VCKBASE.bmp 3KB
Thumbs.db 5KB
RecTest.rc2 399B
RecTest.plg 1KB
共 17 条
- 1
资源评论
programxh
- 粉丝: 17
- 资源: 1万+
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功