服务器与客户机互传消息

韩冰发表于 2005-1-26 01:16

一、服务器程序 
创建一个名为“server" 的项目, 单文档界面。 
在serverview.h 中加入代码： 
 ＃include “winsock.h" 
 添加变量： 
 CSize sizeTotal;// 控制滚动条 
 int count;// 信息条数 
 CString m_data;// 信息存放 
 char Hostname; 
 char Hostaddress;// 主机IP 地址 
 SOCKET m_sock; 
 HANDLE m_hListenThread;// 线程 
 BOOL m_bInitialized;// 是否初始化 
 WSADATA WSAData; 
 BOOL flag; 
 SOCKADDR_IN saClnt; 
 int saClntLen; 
 BOOL Isconnect;// 是否连接 
 
在serverview.cpp 中重载CServerView() 构造器, 创建并绑定嵌套 
 字： 
 CServerView::CServerView() 
{ // TOD add construction code here 
 Isconnect=FALSE; 
 flag=FALSE; 
 sizeTotal.cy=350; 
 sizeTotal.cx=300; 
 m_hListenThread; 
 count=5; 
 int status; 
 WSADATA wsaData; 
 m_data=“initializing Windows Sockets DLL...."; 
 if((status=WSAStartup(0x0101, ＆wsaData))==0) 
 { m_data ＋=“Succeeded"; 
 m_bInitialized=TRUE; 
 } 
 else 
 { m_bInitialized=FALSE; 
 } 
 m_sock=socket(AF_INET,SOCK_DGRAM,0); 
 m_data=“Creating socket...."; 
 if(m_sock==INVALID_SOCKET) 
 { m_data ＋=“Failed"; 
 } 
 m_data ＋=“Succeeded"; 
 m_data=“Binding socket...."; 
 sockaddr_in sa; 
 sa.sin_family=AF_INET; 
 sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY); 
 sa.sin_port=htons(5050); 
 if(bind(m_sock,(PSOCKADDR) 
 ＆sa,sizeof(sa))==SOCKET_ERROR) 
 { m_data ＋=“Failed"; 
 
 closesocket(m_sock); 
 } 
 m_data ＋=“Succeeded"; 
 m_data=“Creating listener thread...."; 
 unsigned long idThread; 
 m_hListenThread=CreateThread(NULL,0, 
(LPTHREAD_START_ROUTINE)Listen, 
(void if(m_hListenThread) 
 { m_data ＋=“Succeeded"; 
 m_data ＋=“Listening...."; 
 } 
 else 
 m_data ＋=“Failed"; 
} 
 
在析构函数中完成必需的清除操作: 
 CServerView:: ～CServerView() 
{ if(m_bInitialized) 
 WSACleanup(); 
 closesocket(m_sock); 
 if(m_hListenThread) 
 ::TerminateThread(m_hListenThread,0); 
} 
 
定义接收和处理消息的线程: 
 long WINAPI Listen(CServerView ＊pView) 
{ char msg=“"; 
 int nchar; 
 SOCKADDR_IN saClnt; 
 int saClntLen; 
 while(1) 
 { saClntLen=sizeof(saClnt); 
 nchar=recvfrom(pView －>m_sock,msg,1024,0, 
(PSOCKADDR) ＆saClnt, ＆saClntLen); 
 if(nchar<0) 
 { pView －>m_data ＋ 
 =“Error in recvfrom\n"; 
 pView －>InvalidateRect(NULL); 
 } 
 else 
 {switch(msg) 
 { 
 case ‘A': 
 wsprintf(msg,“A:Client from ％s attached\n", 
 inet_ntoa(saClnt.sin_addr)); 
 pView －>m_data=msg; 
 pView －>flag=TRUE; 
 pView －>InvalidateRect(NULL); 
 pView －>Isconnect=TRUE; 
 pView －>saClnt=saClnt; 
 pView －>saClntLen=saClntLen; 
 sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR) 
 ＆saClnt,saClntLen); 
 break; 
 
 case ‘D': 
 wsprintf(msg,“D: Client form ％s detached\n", 
 inet_ntoa(saClnt.sin_addr)); 
 pView －>m_data=msg; 
 pView －>flag=TRUE; 
 pView －>InvalidateRect(NULL); 
 pView －>Isconnect=FALSE; 
 sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR) 
 ＆saClnt,saClntLen); 
 break; 
 
 case ‘R': 
 saClntLen=sizeof(saClnt); 
 pView －>m_data=msg; 
 pView －>flag=TRUE; 
 pView －>InvalidateRect(NULL); 
 break; 
 
 default: 
 break; 
 } 
 } 
 
 } 
 return(0); 
} 
 
在程序菜单项中添加“ 本机IP 地址": 
 　　void CServerView::OnIp() 
{int WSAReturn; 
 WSAReturn=WSAStartup( 0x0101, ＆WSAData ); 
 if( WSAReturn == 0 ){ 
 gethostname( Hostname, 260 ); 
 struct hostent ＊pHostEnt; 
 pHostEnt = gethostbyname( Hostname); 
 if( pHostEnt != NULL ){ 
 wsprintf( Hostaddress, “ ％d. ％d. ％d. ％d", 
( pHostEnt －>h_addr_list ＆ 0x00ff ), 
( pHostEnt －>h_addr_list ＆ 0x00ff ), 
( pHostEnt －>h_addr_list ＆ 0x00ff ), 
( pHostEnt －>h_addr_list ＆ 0x00ff ) ); 
 　　CString out; 
 　　out.Format(Hostaddress); 
 　　AfxMessageBox(out); 
 　　} 
 } 
} 
 
在程序菜单中添加“ 发送消息"： 
 　　void CServerView::OnSendmessage() 
{// TOD Add your command handler code here 
 char msg; 
 Csend Sendmessage; 
 if(Sendmessage.DoModal()==IDOK 
 ＆＆!Sendmessage.m_Message.IsEmpty()) 
 　　{ wsprintf(msg,“R: " ＋Sendmessage.m_Message); 
 　　sendto(m_sock,msg,1024,0,(PSOCKADDR) 
 ＆saClnt,saClntLen); 
 　　m_data=Sendmessage.m_Message; 
 　　flag=TRUE; 
 　　InvalidateRect(NULL); 
 　　} 
} 
 
为发送消息项添加一个对话框的类, 名为send, 有一个文 
本框, 用来发送消息，并为文本框添加CString m_Message 变量 
, 在ServerView.cpp 中添加＃include “send.h" 
为发送消息项添加一个判断函数: 
 void CServerView::OnUpdateSendmessage(CCmdUI ＊ 
pCmdUI) 
{// TOD Add your command update UI handler code here 
 pCmdUI －>Enable(FALSE); 
 if(Isconnect) 
 pCmdUI －>Enable(TRUE); 
} 
 
再窗口显示消息: 
 void CServerView::OnDraw(CDC ＊ pDC) 
{ if(flag) 
 {sizeTotal.cy ＋=20; 
 for(int j=65;j 
TextOut(10,y,m_data); 
 y ＋=20；} 
 // TOD add draw code for native data here 
} 
 
在Project 中点击Settings 中选择Link 项添加wsock32.lib。 
----最后编译程序, 就可以得到Server.exe 程序。 
 
二、客户机程序 
创建一个名为“client" 的项目, 单文档界面。 
在clientview.h 中加入代码： 
 ＃include “winsock.h" 
 添加变量: 
 CString m_data; 
 HANDLE m_hListenThread; 
 SOCKET m_sock; 
 SOCKADDR_IN m_saSrvr; 
 BOOL Isconnect; 
 int count; 
 CSize sizeTotal; 
 BOOL flag; 
 
在构造函数中初始化变量: 
 CClientView::CClientView() 
{ // TOD add construction code here 
 Isconnect=FALSE; 
 sizeTotal.cy=350; 
 sizeTotal.cx=300; 
 flag=FALSE; 
} 
 
在析构函数中完成清除操作，代码如上。 
在菜单中添加“ 拨号" 项: 
 void CClientView::OnDial() 
{// TOD Add your command handler code here 
 count=5; 
 if(m_bInitialized) 
 { AfxMessageBox(“Already dialing"); 
 return;} 
 Cdial dial; 
 if(dial.DoModal()==IDOK 
 ＆＆!dial.m_HostAddress.IsEmpty()) 
 {m_saSrvr.sin_family=AF_INET; 
 m_saSrvr.sin_addr.S_un.S_addr=htonl 
(INADDR_ANY); 
 m_saSrvr.sin_addr.S_un.S_addr=inet_addr 
(dial.m_HostAddress); 
 m_saSrvr.sin_port=htons(5050); 
 int status; 
 WSADATA wsaData; 
 m_data=“initializing Windows Sockets DLL...."; 
 if((status=WSAStartup(0x0101, ＆wsaData))==0) 
 { m_data ＋=“Succeeded"; 
 m_bInitialized=TRUE;} 
 else 
 { m_bInitialized=FALSE;} 
 m_sock=socket(AF_INET,SOCK_DGRAM,0); 
 m_data=“Creating socket...."; 
 if(m_sock==INVALID_SOCKET) 
 { m_data ＋=“Failed";} 
 m_data ＋=“Succeeded"; 
 m_data=“Binding socket...."; 
 sockaddr_in sa; 
 sa.sin_family=AF_INET; 
 sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY); 
 sa.sin_port=htons(0); 
 if(bind(m_sock,(PSOCKADDR) 
 ＆sa,sizeof(sa))==SOCKET_ERROR) 
 { m_data ＋=“Failed"; 
 closesocket(m_sock)；} 
 m_data ＋=“Succeeded"; 
 m_data=“Creating listener thread...."; 
 unsigned long idThread; 
 m_hListenThread=CreateThread(NULL 0, 
(LPTHREAD_START_ROUTINE)Listen, 
(void ＊)this,0, ＆idThread); 
 if(m_hListenThread) 
 { m_data ＋=“Succeeded"; 
 m_data ＋=“Waiting....";} 
 else 
 m_data ＋=“Failed"; 
 InvalidateRect(NULL); 
 } 
} 
 
添加一个拨号对话框, 名为dial, 有一个文本框用来写IP 地 
 址. 并在clientview.cpp 中添加代码: 
 ＃include dial.h 
 
在拨号项添加一个判断函数: 
 void CClientView::OnUpdateDial(CCmdUI ＊ 
pCmdUI) 
{// TOD Add your command update UI handler code here 
 pCmdUI －>Enable(TRUE); 
 if(Isconnect) 
 pCmdUI －>Enable(FALSE); 
} 
 
添加接收与发送消息的线程: 
 long WINAPI Listen(CClientView ＊pView) 
{ char msg; 
 pView －>m_data=“Sending ATTACH command"; 
 pView －>InvalidateRect(NULL); 
 wsprintf(msg,“A: "); 
 sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR) 
 ＆pView －>m_saSrvr,sizeof(pView －>m_saSrvr)); 
 int saSrvrLen ,nchar; 
 while(1) 
 {saSrvrLen=sizeof(pView －>m_saSrvr); 
 nchar=recvfrom(pView －>m_sock,msg,1024,0, 
 (PSOCKADDR) ＆pView －>m_saSrvr, ＆saSrvrLen); 
 if(nchar<0) 
 { pView －>m_data= 
 “Error in recvform"; 
 pView －>InvalidateRect(NULL);} 
 else 
 { pView －>m_data=msg; 
 pView －>Isconnect=TRUE; 
 pView －>flag=TRUE; 
 pView －>InvalidateRect(NULL); 
 } 
 } 
 return(0); 
} 
 
同主程序一样做一个发送消息项, 代码如上。 
显示程序也与主程序一样, 代码如上。 
在Project 中点击Settings 中选择Link 项添加wsock32.lib。 
编译程序便可得到client.exe 程序。 
----server.exe 和 client.exe 做完后, 就可以在具有 TCP/IP 协议 
 下的网络中执行。

页: [1]

数学建模社区-数学中国's Archiver

服务器与客户机互传消息