模板
教程
環境
性能
功能
管理
服務器與客戶機互傳消息
一、服務器程序
1、創建一個名為“server" 的項目, 單文檔界面。
2、在serverview.h 中加入代碼：
＃include "winsock.h"
添加變量：
CSize sizeTotal;// 控制滾動條
int count;// 信息條數
CString m_data[1000];// 信息存放
char Hostname[260];
char Hostaddress[20];// 主機IP 地址
SOCKET m_sock;
HANDLE m_hListenThread;// 線程
BOOL m_bInitialized;// 是否初始化
WSADATA WSAData;
BOOL flag;
SOCKADDR_IN saClnt;
int saClntLen;
BOOL Isconnect;// 是否連接
3、在serverview.cpp 中重載CServerView() 構造器, 創建并綁定嵌套字：
CServerView::CServerView()
{ // TODO: add construction code here
Isconnect=FALSE;
flag=FALSE;
sizeTotal.cy=350;
sizeTotal.cx=300;
m_hListenThread;
count=5;
int status;
WSADATA wsaData;
m_data[0]="initializing Windows Sockets DLL....";
if((status=WSAStartup(0x0101, ＆wsaData))==0)
{ m_data[0] ＋="Suclearcase/" target="_blank" >cceeded";
m_bInitialized=TRUE;
}
else
{ m_bInitialized=FALSE;
}
m_sock=socket(AF_INET,SOCK_DGRAM,0);
m_data[1]="Creating socket....";
if(m_sock==INVALID_SOCKET)
{ m_data[1] ＋="Failed";
}
m_data[1] ＋="Succeeded";
m_data[2]="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[2] ＋="Failed";
closesocket(m_sock);
}
m_data[2] ＋="Succeeded";
m_data[3]="Creating listener thread....";
unsigned long idThread;
m_hListenThread=CreateThread(NULL,0,
(LPTHREAD_START_ROUTINE)Listen,
(void if(m_hListenThread)
{ m_data[3] ＋="Succeeded";
m_data[4] ＋="Listening....";
}
else
m_data[4] ＋="Failed";
}
4、在析構函數中完成必需的清除操作:
CServerView:: ～CServerView()
{ if(m_bInitialized)
WSACleanup();
closesocket(m_sock);
if(m_hListenThread)
::TerminateThread(m_hListenThread,0);
}
5、定義接收和處理消息的線程:
long WINAPI Listen(CServerView ＊pView)
{ char msg[2000]="";
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[pView －>count ＋＋] ＋
="Error in recvfrom\n";
pView －>InvalidateRect(NULL);
}
else
{switch(msg[0])
{
case ‘A':
wsprintf(msg,"A:Client from ％s attached\n",
inet_ntoa(saClnt.sin_addr));
pView －>m_data[pView －>count ＋＋]=msg;
pView －>flag=TRUE;
pView －>InvalidateRect(NULL);
pView －>Isconnect=TRUE;
pView －>saClnt=saClnt;
pView －>saClntLen=saClntLen;
sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)
?。aClnt,saClntLen);
break;
case 'D':
wsprintf(msg,"D: Client form ％s detached\n",
inet_ntoa(saClnt.sin_addr));
pView －>m_data[pView －>count ＋＋]=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[pView －>count ＋＋]=msg;
pView －>flag=TRUE;
pView －>InvalidateRect(NULL);
break;
default:
break;
}
}
}
return(0);
}
6、在程序菜單項中添加“本機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[0][0] ＆0x00ff ),
( pHostEnt －>h_addr_list[0][1] ＆0x00ff ),
( pHostEnt －>h_addr_list[0][2] ＆0x00ff ),
( pHostEnt －>h_addr_list[0][3] ＆0x00ff ) );
CString out;
out.Format(Hostaddress);
AfxMessageBox(out);
}
}
}
7、在程序菜單中添加“發送消息"：
void CServerView::OnSendmessage()
{// TODO: Add your command handler code here
char msg[2000];
Csend Sendmessage;
if(Sendmessage.DoModal()==IDOK
?。Γ?Sendmessage.m_Message.IsEmpty())
{ wsprintf(msg,"R: " ＋Sendmessage.m_Message);
sendto(m_sock,msg,1024,0,(PSOCKADDR)
?。aClnt,saClntLen);
m_data[count ＋＋]=Sendmessage.m_Message;
flag=TRUE;
InvalidateRect(NULL);
}
}
8、為發送消息項添加一個對話框的類, 名為send, 有一個文本框,
用來發送消息，并為文本框添加CString m_Message 變量, 在ServerView.cpp
中添加＃include "send.h"
9、為發送消息項添加一個判斷函數:
void CServerView::OnUpdateSendmessage(CCmdUI ＊
pCmdUI)
{// TODO: Add your command update UI handler code here
pCmdUI －>Enable(FALSE);
if(Isconnect)
pCmdUI －>Enable(TRUE);
}
10、再窗口顯示消息:
void CServerView::OnDraw(CDC ＊pDC)
{ if(flag)
{sizeTotal.cy ＋=20;
for(int j=65;jTextOut(10,y,m_data[i]);
y ＋=20；}
// TODO: add draw code for native data here
}
11、在Project 中點擊Settings 中選擇Link 項添加wsock32.lib。
最后編譯程序, 就可以得到Server.exe 程序。
二、客戶機程序
1、創建一個名為“client" 的項目, 單文檔界面。
2、在clientview.h 中加入代碼：
?。nclude "winsock.h"
添加變量:
CString m_data[1000];
HANDLE m_hListenThread;
SOCKET m_sock;
SOCKADDR_IN m_saSrvr;
BOOL Isconnect;
int count;
CSize sizeTotal;
BOOL flag;
3、在構造函數中初始化變量:
CClientView::CClientView()
{ // TODO: add construction code here
Isconnect=FALSE;
sizeTotal.cy=350;
sizeTotal.cx=300;
flag=FALSE;
}
4、在析構函數中完成清除操作，代碼如上。
5、在菜單中添加“撥號" 項:
void CClientView::OnDial()
{// TODO: 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[0]="initializing Windows Sockets DLL....";
if((status=WSAStartup(0x0101, ＆wsaData))==0)
{ m_data[0] ＋="Succeeded";
m_bInitialized=TRUE;}
else
{ m_bInitialized=FALSE;}
m_sock=socket(AF_INET,SOCK_DGRAM,0);
m_data[1]="Creating socket....";
if(m_sock==INVALID_SOCKET)
{ m_data[1] ＋="Failed";}
m_data[1] ＋="Succeeded";
m_data[2]="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[2] ＋="Failed";
closesocket(m_sock)；}
m_data[2] ＋="Succeeded";
m_data[3]="Creating listener thread....";
unsigned long idThread;
m_hListenThread=CreateThread(NULL 0,
(LPTHREAD_START_ROUTINE)Listen,
(void ＊)this,0, ＆idThread);
if(m_hListenThread)
{ m_data[3] ＋="Succeeded";
m_data[4] ＋="Waiting....";}
else
m_data[4] ＋="Failed";
InvalidateRect(NULL);
}
}
6、添加一個撥號對話框, 名為dial, 有一個文本框用來寫IP 地址.
并在clientview.cpp 中添加代碼:
?。nclude dial.h
7、在撥號項添加一個判斷函數:
void CClientView::OnUpdateDial(CCmdUI ＊
pCmdUI)
{// TODO: Add your command update UI handler code here
pCmdUI －>Enable(TRUE);
if(Isconnect)
pCmdUI －>Enable(FALSE);
}
8、添加接收與發送消息的線程:
long WINAPI Listen(CClientView ＊pView)
{ char msg[2000];
pView －>m_data[5]="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[pView －>count ＋＋]=
"Error in recvform";
pView －>InvalidateRect(NULL);}
else
{ pView －>m_data[pView －>count ＋＋]=msg;
pView －>Isconnect=TRUE;
pView －>flag=TRUE;
pView －>InvalidateRect(NULL);
}
}
return(0);
}
9、同主程序一樣做一個發送消息項, 代碼如上。
10、顯示程序也與主程序一樣, 代碼如上。
11、在Project 中點擊Settings 中選擇Link 項添加wsock32.lib。
12、編譯程序便可得到client.exe 程序。
server.exe 和client.exe 做完后, 就可以在具有TCP/IP
協議下的網絡中執行。
