开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 网络编程 > 查看源码
SpeakDlg.cpp
资源名称：多功能聊天程序.rar　[点击查看]
上传用户：onsales
上传日期：2010-01-31
资源大小：224k
文件大小：11k
源码类别：

网络编程

开发平台：

Visual C++

SpeakDlg.cpp：源码内容
  1. // SpeakDlg.cpp : implementation file
  2. //
  4. #include "stdafx.h"
  5. #include "Speak.h"
  6. #include "SpeakDlg.h"
  8. #ifdef _DEBUG
  9. #define new DEBUG_NEW
  10. #undef THIS_FILE
  11. static char THIS_FILE[] = __FILE__;
  12. #endif
  15. /////////////////////////////////////////////////////////////////////////////
  16. // CAboutDlg dialog used for App About
  18. class CAboutDlg : public CDialog
  19. {
  20. public:
  21. CAboutDlg();
  23. // Dialog Data
  24. //{{AFX_DATA(CAboutDlg)
  25. enum { IDD = IDD_ABOUTBOX };
  26. //}}AFX_DATA
  28. // ClassWizard generated virtual function overrides
  29. //{{AFX_VIRTUAL(CAboutDlg)
  30. protected:
  31. virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV support
  32. //}}AFX_VIRTUAL
  34. // Implementation
  35. protected:
  36. //{{AFX_MSG(CAboutDlg)
  37. //}}AFX_MSG
  38. DECLARE_MESSAGE_MAP()
  39. };
  41. CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
  42. {
  43. //{{AFX_DATA_INIT(CAboutDlg)
  44. //}}AFX_DATA_INIT
  45. }
  47. void CAboutDlg::DoDataExchange(CDataExchange* pDX)
  48. {
  49. CDialog::DoDataExchange(pDX);
  50. //{{AFX_DATA_MAP(CAboutDlg)
  51. //}}AFX_DATA_MAP
  52. }
  54. BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
  55. //{{AFX_MSG_MAP(CAboutDlg)
  56. // No message handlers
  57. //}}AFX_MSG_MAP
  58. END_MESSAGE_MAP()
  60. /////////////////////////////////////////////////////////////////////////////
  61. // CSpeakDlg dialog
  63. CSpeakDlg::CSpeakDlg(CWnd* pParent /*=NULL*/)
  64. : CDialog(CSpeakDlg::IDD, pParent)
  65. {
  66. //{{AFX_DATA_INIT(CSpeakDlg)
  67. m_Name = _T("");
  68. //}}AFX_DATA_INIT
  69. // Note that LoadIcon does not require a subsequent DestroyIcon in Win32
  70. m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
  71. }
  73. void CSpeakDlg::DoDataExchange(CDataExchange* pDX)
  74. {
  75. CDialog::DoDataExchange(pDX);
  76. //{{AFX_DATA_MAP(CSpeakDlg)
  77. DDX_Control(pDX, IDC_IPADDRESS, m_IPADDRESS);
  78. DDX_Text(pDX, IDC_Name, m_Name);
  79. //}}AFX_DATA_MAP
  80. }
  82. BEGIN_MESSAGE_MAP(CSpeakDlg, CDialog)
  83. //{{AFX_MSG_MAP(CSpeakDlg)
  84. ON_WM_SYSCOMMAND()
  85. ON_WM_PAINT()
  86. ON_WM_QUERYDRAGICON()
  87. ON_BN_CLICKED(IDC_ConnectBTN, OnConnectBTN)
  88. ON_BN_CLICKED(IDC_CUTUPBTN, OnCutupbtn)
  89. ON_WM_TIMER()
  90. ON_BN_CLICKED(IDC_TestBTN, OnTestBTN)
  91. //}}AFX_MSG_MAP
  92. ON_MESSAGE(WM_READREADY,OnReadReady)
  93. END_MESSAGE_MAP()
  95. /////////////////////////////////////////////////////////////////////////////
  96. // CSpeakDlg message handlers
  98. BOOL CSpeakDlg::OnInitDialog()
  99. {
  100. CDialog::OnInitDialog();
  102. // Add "About..." menu item to system menu.
  104. // IDM_ABOUTBOX must be in the system command range.
  105. ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
  106. ASSERT(IDM_ABOUTBOX < 0xF000);
  108. CMenu* pSysMenu = GetSystemMenu(FALSE);
  109. if (pSysMenu != NULL)
  110. {
  111. CString strAboutMenu;
  112. strAboutMenu.LoadString(IDS_ABOUTBOX);
  113. if (!strAboutMenu.IsEmpty())
  114. {
  115. pSysMenu->AppendMenu(MF_SEPARATOR);
  116. pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
  117. }
  118. }
  120. // Set the icon for this dialog.  The framework does this automatically
  121. //  when the application's main window is not a dialog
  122. SetIcon(m_hIcon, TRUE); // Set big icon
  123. SetIcon(m_hIcon, FALSE); // Set small icon
  124. CFile MyFile;
  125. MyFile.Open("voice.txt",CFile::modeRead);
  126.     int filelong=0;
  127. filelong=MyFile.GetLength();
  129. char pbuf[500];
  130. MyFile.Read( pbuf, sizeof( pbuf ) ); 
  131. pbuf[filelong]='';
  133. MyFile.Close(); 
  134. strIP="";
  135. m_Name="";
  136. int i=2;
  137. char sign=pbuf[0];
  138. while(pbuf[i]!='#')
  139. {
  140. strIP+=pbuf[i];
  141. i++;
  142. }
  143. i++;
  144. while(pbuf[i]!='#')
  145. {
  146. m_Name+=pbuf[i];
  147. i++;
  148. }
  149. // MessageBox(strIP);
  150. //else exit(0);
  151. //strIP="192.168.1.98";
  152. this->UpdateData(false);
  153. m_IPADDRESS.SetWindowText(strIP);
  154. // TODO: Add extra initialization here
  155. if (WSAStartup(WINSOCK_VERSION,&wsaData))
  156. {
  157. MessageBeep(MB_ICONSTOP);
  158. MessageBox("Winsock could not be initialized!", AfxGetAppName(), MB_OK|MB_ICONSTOP);
  159.     WSACleanup();
  160.     return(FALSE);
  161. }
  162. m_bWaiting=TRUE;
  163. m_bPassive=TRUE;
  164. m_bClose=TRUE;
  165. m_RemoteIP=0;
  166. m_nBlockSize=BLOCK;
  167. nID=0;
  169. chSndOut=(unsigned char*)malloc(BLOCK);
  171. Openserver();
  172. sndIn.SetBits(8);
  173. sndIn.SetBlockProp(m_nBlockSize,MAX);
  174. sndIn.SetSampleRate(11025);
  175. sndOut.SetBits(8);
  176. sndOut.SetBlockProp(m_nBlockSize,MAX);
  177. sndOut.SetSampleRate(11025);
  178. sndIn.SetTestProp(TRUE);
  179. sndIn.SetSoundOut(&sndOut);
  180. sndIn.SetCompressionObject(&cmpSend);
  182. cmpSend.SelectMethod(3);
  183. cmpReceive.SelectMethod(3);
  184. cmpReceive.SetWaveFormat(1,11025,8);
  185. cmpReceive.Initialize();
  186. cmpReceive.SetDstSamples(BLOCK/2,(unsigned char*)chRecv);
  187. cmpReceive.PrepareSpace(FALSE);
  188. if(sign=='3')
  189. {
  190. (CEdit *)GetDlgItem(IDC_ConnectBTN)->EnableWindow(FALSE);
  191. this->OnConnectBTN();
  192. }
  193. return TRUE;  // return TRUE  unless you set the focus to a control
  194. }
  196. void CSpeakDlg::OnSysCommand(UINT nID, LPARAM lParam)
  197. {
  198. if ((nID & 0xFFF0) == IDM_ABOUTBOX)
  199. {
  200. CAboutDlg dlgAbout;
  201. dlgAbout.DoModal();
  202. }
  203. else
  204. {
  205. CDialog::OnSysCommand(nID, lParam);
  206. }
  207. }
  209. // If you add a minimize button to your dialog, you will need the code below
  210. //  to draw the icon.  For MFC applications using the document/view model,
  211. //  this is automatically done for you by the framework.
  213. void CSpeakDlg::OnPaint() 
  214. {
  215. if (IsIconic())
  216. {
  217. CPaintDC dc(this); // device context for painting
  219. SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);
  221. // Center icon in client rectangle
  222. int cxIcon = GetSystemMetrics(SM_CXICON);
  223. int cyIcon = GetSystemMetrics(SM_CYICON);
  224. CRect rect;
  225. GetClientRect(&rect);
  226. int x = (rect.Width() - cxIcon + 1) / 2;
  227. int y = (rect.Height() - cyIcon + 1) / 2;
  229. // Draw the icon
  230. dc.DrawIcon(x, y, m_hIcon);
  231. }
  232. else
  233. {
  234. CDialog::OnPaint();
  235. }
  236. }
  238. // The system calls this to obtain the cursor to display while the user drags
  239. //  the minimized window.
  240. HCURSOR CSpeakDlg::OnQueryDragIcon()
  241. {
  242. return (HCURSOR) m_hIcon;
  243. }
  245. void CSpeakDlg::OnConnectBTN() 
  246. {
  247. // TODO: Add your control notification handler code here
  248. m_bPassive=FALSE;
  249. Connect(TRUE);
  250. }
  252. void CSpeakDlg::OnCutupbtn() 
  253. {
  254. // TODO: Add your control notification handler code here
  255. char *chClose=(char*)malloc(12);
  256. wsprintf(chClose,"CLOSE");
  257. m_bClose=TRUE;
  258. sendto(m_sSend,chClose,sizeof(chClose),0,(LPSOCKADDR)&m_RemoteAddr,sizeof(m_RemoteAddr));
  259. sndIn.CloseMic();
  260. sndOut.CloseSpk();
  261. m_RemoteIP=0;
  262.     m_bWaiting=TRUE;
  263. m_bPassive=TRUE;
  264. free(chClose);
  265. }
  267. void CSpeakDlg::Openserver()
  268. {
  269. m_sSend=socket(AF_INET,SOCK_DGRAM,0); 
  270. m_sRecv=socket(AF_INET,SOCK_DGRAM,0); 
  271. m_sAccept=socket(AF_INET,SOCK_STREAM,0);
  272. char chName[64];
  274. gethostname(chName,sizeof(chName));
  276. addrSend.sin_family=AF_INET;
  277. addrSend.sin_addr.S_un.S_addr=INADDR_ANY;//inet_addr(m_chLocalIp);
  278. addrSend.sin_port=htons(SENDPORT);
  279. if (bind(m_sSend,(LPSOCKADDR)&addrSend,sizeof(addrSend))== SOCKET_ERROR)
  280. {
  281. ReportWinsockErr("Could not bind server socket.");
  282. }
  284. addrRecv.sin_family=AF_INET;
  285. addrRecv.sin_addr.S_un.S_addr=INADDR_ANY;//inet_addr(m_chLocalIp);
  286. addrRecv.sin_port=htons(RECEIVEPORT);
  287. if (bind(m_sRecv,(LPSOCKADDR)&addrRecv,sizeof(addrRecv))==SOCKET_ERROR)
  288. {
  289. ReportWinsockErr("Could not bind server socket.");
  290. }
  292. int iError=WSAAsyncSelect(m_sRecv,m_hWnd,WM_READREADY,FD_READ|FD_CLOSE);
  293. if(iError==SOCKET_ERROR)
  294. {
  295. ReportWinsockErr("Could not Select server socket.");
  296. }
  297. }
  299. BOOL CSpeakDlg::Connect(BOOL b)
  300. {
  301. unsigned long ip;
  302. char* str=new char[64];
  303. char chQuery[64];
  304. SOCKADDR_IN to;
  306. m_bClose=FALSE;
  307. if(b){
  308. //CIPAddress dlg;
  309. //if(dlg.DoModal()==IDCANCEL)
  310. // return FALSE;
  311. //else{
  312. m_RemoteIP=inet_addr(strIP);
  313. nID=SetTimer(1,10000,NULL);
  314. //}
  315. }
  316. int i=GetLocalIP(&ip,1);
  317. in_addr t;
  318. t.S_un.S_addr=ip;
  319. if(i!=0)
  320. str=inet_ntoa(t);
  321. wsprintf(chQuery,"PHONE %s",str);
  323. to.sin_family=AF_INET;
  324. to.sin_port=htons(RECEIVEPORT);
  325. to.sin_addr.S_un.S_addr=m_RemoteIP;//inet_addr("210.32.151.247"); 
  327. int iError=sendto(m_sSend,chQuery,sizeof(chQuery),0,(LPSOCKADDR)&to,sizeof(to));
  328. if(iError==SOCKET_ERROR)
  329. {
  330. ReportWinsockErr("无法建立连接.");
  331. return FALSE;
  332. }
  333. return TRUE;
  334. }
  336. int CSpeakDlg::GetLocalIP(unsigned long *ip, int len)
  337. {
  338. char chName[128];
  340. gethostname(chName,sizeof(chName));
  341. struct hostent* pHost;
  342. pHost = gethostbyname(chName); 
  343. CString str;
  344. int i=0;
  345. for(i=0; pHost!=NULL && pHost->h_addr_list[i]!=NULL; i++ ){
  346.  int j;  
  347.  for(j = 0;j<pHost->h_length;j++ ){
  348.  CString addr;
  349.  if( j > 0 )
  350.  str += "."; 
  351.   addr.Format("%u", (unsigned int)((unsigned char*)pHost->h_addr_list[i])[j]);
  352. str += addr;
  353.  }
  354.  if(i>len)
  355.  return 0;
  356. ip[i]=inet_addr(str);
  357. str.Empty();
  358.   }
  359. return i;
  360. }
  362. void CSpeakDlg::ReportWinsockErr(LPSTR lpszErrorMsg)
  363. {
  364. char chMsgBuffer[100];
  365. wsprintf(chMsgBuffer, "nWinsock error %d: %snn", WSAGetLastError(), lpszErrorMsg);
  366. MessageBox(chMsgBuffer,  AfxGetAppName(), MB_OK|MB_ICONSTOP);
  367. return;   
  368. }
  370. void CSpeakDlg::OnTimer(UINT nIDEvent) 
  371. {
  372. // TODO: Add your message handler code here and/or call default
  373. switch(nIDEvent){
  374. case 1:
  375. if(m_bPassive==FALSE){
  376. AfxMessageBox("对方不同意或者不在同一个协议下!");
  377. m_bPassive=TRUE;
  378. }
  379. case 2:{
  380.    }
  381. }
  382. CDialog::OnTimer(nIDEvent);
  383. }
  385. void CSpeakDlg::OnTestBTN() 
  386. {
  387. // TODO: Add your control notification handler code here
  388. m_nBlockSize=BLOCK;
  390. sndIn.SetBits(8);
  391. sndIn.SetBlockProp(m_nBlockSize,MAX);
  392. sndIn.SetSampleRate(11025);
  394. sndOut.SetBits(8);
  395. sndOut.SetBlockProp(m_nBlockSize,MAX);
  396. sndOut.SetSampleRate(11025);
  397. sndIn.SetTestProp(TRUE);
  398. sndIn.SetSoundOut(&sndOut);
  399. sndIn.OpenMic();
  400. sndOut.OpenSpk();
  401. }
  403. LRESULT CSpeakDlg::OnReadReady(WPARAM wParam, LPARAM lParam)
  404. {
  405. int iRecievedNum;
  406. char* ip=(char*)malloc(64);
  408. if(m_bWaiting){
  409. iRecievedNum=recv(m_sRecv,chRecv,sizeof(chRecv),0);
  410. if(iRecievedNum==SOCKET_ERROR)
  411. {
  412. ReportWinsockErr("Could not Receive the Data.");
  413. return 0L;
  414. }
  415. if(chRecv[0]=='P' && chRecv[1]=='H' ){
  416. m_bWaiting=FALSE;
  417. sscanf(chRecv,"PHONE %s",ip);
  418. m_RemoteIP=inet_addr(ip);
  419. m_RemoteAddr.sin_addr.S_un.S_addr=m_RemoteIP;
  420. m_RemoteAddr.sin_family=AF_INET; 
  421. m_RemoteAddr.sin_port=htons(RECEIVEPORT);
  422. if(m_bPassive){
  423. char *call=(char*)malloc(128);
  424. wsprintf(call,"请求语音聊天%sn, 接受么?",ip); 
  425. if(1==AfxMessageBox(call,MB_OKCANCEL))
  426. Connect(FALSE);
  427. else
  428. return 0L;
  429. free(call);
  430. }
  431. m_bPassive=TRUE;
  432. sndIn.SetTestProp(FALSE);
  433. sndIn.SetSocketParam(m_sSend,m_RemoteAddr);
  434. sndIn.OpenMic();
  435. sndOut.OpenSpk();
  436. }
  437. else{
  438. // MessageBox("Error On the Buffer");
  439. return 0L;
  440. }
  441. }
  442. else{
  443. int tmp=sizeof(m_RemoteAddr);
  444. iRecievedNum=recvfrom(m_sRecv,chRecv,BLOCK,0,(LPSOCKADDR)&m_RemoteAddr,&tmp);
  445. if((chRecv[0]=='P' && chRecv[1]=='H'))
  446. return 0L;
  447. if(chRecv[0]=='C' && chRecv[1]=='O'){
  448. if(!m_bClose)
  449. OnCutupbtn();
  450. return 0L;
  451. }
  452. if(iRecievedNum==SOCKET_ERROR)
  453. {
  454. ReportWinsockErr("无法接收数据");
  455. return 0L;
  456. }
  457. cmpReceive.SetDstSamples(iRecievedNum,(unsigned char*)chRecv);
  458. long temp=cmpReceive.UnConvert(TRUE,NULL,0);
  459. if(temp<BLOCK){
  460. cmpReceive.UnConvert(FALSE,chSndOut,temp);
  461. sndOut.WriteData((char *)chSndOut,temp);
  462. }
  463. else{
  464. cmpReceive.UnConvert(FALSE,chSndOut,BLOCK);
  465. sndOut.WriteData((char *)chSndOut,BLOCK);
  466. }
  467. }
  468. free(ip);
  469. return 0L;
  470. }