查看: 2514|回复: 0

服务器与客户机互传消息

字体大小: 正常放大

韩冰

823 主题	3 听众	4048 积分

我的地盘我做主

该用户从未签到

电梯直达

1^#

发表于 2005-1-26 01:16 |只看该作者 |正序浏览

|招呼Ta 关注Ta

一、服务器程序

创建一个名为“server" 的项目, 单文档界面。

在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;// 是否连接

在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[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(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";

}

在析构函数中完成必需的清除操作:

CServerView:: ～CServerView()

{ if(m_bInitialized)

WSACleanup();

closesocket(m_sock);

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

}

定义接收和处理消息的线程:

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)

＆saClnt,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);

}

在程序菜单项中添加“ 本机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);

　　}

在程序菜单中添加“ 发送消息"：

　　void CServerView::OnSendmessage()

{// TOD 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)

＆saClnt,saClntLen);

　　m_data[count ＋＋]=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);

& N' j( t6 G3 E: f0 |. r+ C2 r% n0 W
y ＋=20；}
4 o$ \9 U) x Q) I
// TOD add draw code for native data here
+ B v4 a \) ~. u
}
, P* Q# C$ A" s/ Z

# x; A, u& C, r7 r
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
3 i$ ~' {. T. Y: C4 d) b
----最后编译程序, 就可以得到Server.exe 程序。
( w+ L+ ]! n; E3 U8 ?; [: F; Q) S

1 g$ t9 x# D% m5 I, M1 e/ S
二、客户机程序
$ @ c: H$ f/ ~7 ]
创建一个名为“client" 的项目, 单文档界面。
9 q- f" a; o |. @
在clientview.h 中加入代码：
2 Z9 i7 u7 h' K
＃include “winsock.h"
) O: _5 F7 s; [. c- J9 q
添加变量:
& t: j' S" G1 `0 e5 s
CString m_data[1000];
6 ?' x6 n. ?8 x4 G! S5 Q6 ?
HANDLE m_hListenThread;
, v/ Q3 P4 P m# I* Z
SOCKET m_sock;
1 U' o1 L* R$ B
SOCKADDR_IN m_saSrvr;
) n9 C. H, ~" N! m
BOOL Isconnect;
/ f: _) i5 S" R @) k
int count;
6 A' H6 I( r3 `
CSize sizeTotal;
# s1 _* ^* ]5 b* R+ ]+ { p0 G
BOOL flag;
; q7 r# v" E# V% I/ o, Q. m& {4 c

" f1 w$ Z& E$ J p' j* ]
在构造函数中初始化变量:
2 U5 ~) l6 S" [8 J
CClientView::CClientView()
+ I R& g' X6 q
{ // TOD add construction code here
/ `8 [4 c3 K3 }
Isconnect=FALSE;
# `, |# v( e) z+ c% F: |
sizeTotal.cy=350;
* ~9 [3 z2 o1 `* N( A: y/ |
sizeTotal.cx=300;
$ D K5 i i5 T' F! a
flag=FALSE;
) N1 L a6 s+ ]8 j
}
* O( V& i! t j4 O

9 Y* z$ x4 c. c, q. T
在析构函数中完成清除操作，代码如上。
+ Z, A' u! b8 c* Y2 o9 j4 O: p
在菜单中添加“ 拨号" 项:
" y* w* B2 U4 ? c% i
void CClientView::OnDial()
7 ]8 d; \4 c! q* ]& |9 n
{// TOD Add your command handler code here
, o0 H+ }9 P) O4 V5 p
count=5;
0 ^8 G( t b+ T. z: Q7 O
if(m_bInitialized)
% g( d0 |. K5 M( g& N' K$ Q
{ AfxMessageBox(“Already dialing");
0 K. [% n& `0 g; j) @! ]
return;}
! @' {) z h4 v6 O& k' X! k6 ~
Cdial dial;
8 `/ n5 ~: q# f5 v+ {6 X2 Q
if(dial.DoModal()==IDOK
+ W6 I, ^+ F0 E, B* w
＆＆!dial.m_HostAddress.IsEmpty())
) q' b6 v: R3 Z" [* E. S
{m_saSrvr.sin_family=AF_INET;
" q" R' b- G r/ Y
m_saSrvr.sin_addr.S_un.S_addr=htonl
' A- a$ v' E1 B" o# y E
(INADDR_ANY);
. I+ J9 C$ w- ^; E- F. a& [
m_saSrvr.sin_addr.S_un.S_addr=inet_addr
1 X) f0 C" r( q( Q) ^
(dial.m_HostAddress);
H6 }% u! I5 D& `* _
m_saSrvr.sin_port=htons(5050);
. @8 T1 k8 g l: w" {4 k" }2 X
int status;
4 Q! Z* W$ F; R6 b+ E0 }
WSADATA wsaData;
6 W8 h: \3 u# k. p. B
m_data[0]=“initializing Windows Sockets DLL....";
% q( U2 P% p7 X1 p; e; J/ T
if((status=WSAStartup(0x0101, ＆wsaData))==0)
7 x$ ~$ v1 s1 H6 ^1 K
{ m_data[0] ＋=“Succeeded";
) U, J% j! y; m! p8 d
m_bInitialized=TRUE;}
, f6 S# H y5 x/ E
else
6 d. \* q# [& L% J
{ m_bInitialized=FALSE;}
5 ]: c( l7 S X2 `8 q0 Y" O
m_sock=socket(AF_INET,SOCK_DGRAM,0);
4 Z/ O' ]2 ^, Z- o
m_data[1]=“Creating socket....";
0 [: s4 X6 F! m9 {7 p( P' p9 Y, ]8 D
if(m_sock==INVALID_SOCKET)
1 T) r. e+ r& O
{ m_data[1] ＋=“Failed";}
( `6 \/ @3 m6 Y5 Z* O
m_data[1] ＋=“Succeeded";
) ]* `6 J7 w% y& Q- j `
m_data[2]=“Binding socket....";
! }/ V% W8 U; \7 G& @
sockaddr_in sa;
5 r5 h% I+ Y7 {# H7 i( C, H
sa.sin_family=AF_INET;
O1 z7 S( b6 S2 f6 u2 ]0 P
sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
6 o, L% H" W! ]7 @
sa.sin_port=htons(0);
' N$ _! u# R3 i+ h7 w& F
if(bind(m_sock,(PSOCKADDR)
- X* D% S8 T+ v! [% ~0 |# \
＆sa,sizeof(sa))==SOCKET_ERROR)
% q% [ G x% B
{ m_data[2] ＋=“Failed";
7 I8 U6 z4 x5 r6 r; h. V! Z( p
closesocket(m_sock)；}
& o0 m" I1 B) O$ d0 g
m_data[2] ＋=“Succeeded";
+ ~- q! Z: T$ ?$ f
m_data[3]=“Creating listener thread....";
1 a; [3 j+ G3 u1 Q C
unsigned long idThread;
6 ^* h; s8 I& T3 w; [/ `
m_hListenThread=CreateThread(NULL 0,
4 }! K4 w, Z+ Y" |% V1 b% ?5 w
(LPTHREAD_START_ROUTINE)Listen,
2 i8 T; q* o1 O/ e
(void ＊)this,0, ＆idThread);
' {' C5 l1 x, { B
if(m_hListenThread)
% L, Y$ B, y5 h4 C6 L
{ m_data[3] ＋=“Succeeded";
4 D7 R1 i& o o: | T$ H
m_data[4] ＋=“Waiting....";}
+ [3 O& Y/ N! t- e. `
else
4 d# _" }: F: c0 p' R H6 } o& f E2 k
m_data[4] ＋=“Failed";
) G0 L* [0 F+ q5 A
InvalidateRect(NULL);
; y- D5 C/ w+ \6 |% p
}
6 R! @3 h3 y% {; m4 ~4 S' _
}
+ G5 h# n' N7 B u

, l: G, Z0 |1 g0 M, n2 _
添加一个拨号对话框, 名为dial, 有一个文本框用来写IP 地
# Z5 }$ D% r+ Z* J4 x! H
址. 并在clientview.cpp 中添加代码:
3 h- p2 E( w( w# Q6 e
＃include dial.h
% [9 E. c* H, d7 t. R& ~

0 Z- r2 N7 B- M
在拨号项添加一个判断函数:
3 j7 m8 A. A! A4 B- c! F
void CClientView::OnUpdateDial(CCmdUI ＊
1 h- F R V( J
pCmdUI)
3 P: y' B: M+ [
{// TOD Add your command update UI handler code here
8 w# j! _) w6 H; {0 D9 h8 G& Q
pCmdUI －>Enable(TRUE);
/ L7 f5 b- n- o5 F. A3 {
if(Isconnect)
8 K3 F3 N" D9 R# L
pCmdUI －>Enable(FALSE);
- V. ?$ w0 ]- A4 O9 v
}
; K( C( x9 {( v; ?7 w% W6 E6 V. z

* w- I8 U5 _3 u" o7 t
添加接收与发送消息的线程:
% O2 _/ w6 N& `$ m7 A4 ]6 a: X
long WINAPI Listen(CClientView ＊pView)
0 w6 A7 H t8 V* c; l; W- w
{ char msg[2000];
5 L7 C+ A1 X/ W, u4 O: l U
pView －>m_data[5]=“Sending ATTACH command";
8 z. L" l O: b, C
pView －>InvalidateRect(NULL);
4 g- S* Z* H5 h d& o
wsprintf(msg,“A: ");
/ Q5 E; T; q6 s4 K0 n8 O+ W& B; H
sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)
. _+ p2 ]! }+ P" E
＆pView －>m_saSrvr,sizeof(pView －>m_saSrvr));
. ^3 ? M+ c! ~* m. F5 b' l4 l2 Y
int saSrvrLen ,nchar;
# A& a. P% b9 D$ \$ P. G! l. _7 {
while(1)
% [0 e" a3 w7 @2 Q! r, s; g2 I. c2 `
{saSrvrLen=sizeof(pView －>m_saSrvr);
/ w) E7 A' v( ?0 ^1 }- j
nchar=recvfrom(pView －>m_sock,msg,1024,0,
+ g8 \& O2 R$ P3 p7 w" W! d
(PSOCKADDR) ＆pView －>m_saSrvr, ＆saSrvrLen);
) w" ~4 w# k9 }' s7 F4 V
if(nchar<0)
0 k' z- i: x# u6 w* P( }3 K$ u, ?- ?
{ pView －>m_data[pView －>count ＋＋]=
8 ^7 T& u' i Z n
“Error in recvform";
- o: G, e7 N+ D$ ?* H
pView －>InvalidateRect(NULL);}
* B' O- M' j+ C) w; u8 N
else
' $ l' [* _( R9 f% G* O9 o
{ pView －>m_data[pView －>count ＋＋]=msg;
3 n i4 H1 j9 ^% _. t. }/ ~
pView －>Isconnect=TRUE;
0 J& W3 F5 _) q5 ?
pView －>flag=TRUE;
/ m& a( g+ N* P% U
pView －>InvalidateRect(NULL);
. G9 R- U6 Y# y% s5 E# Q8 R" R
}
/ v$ \: {. V0 g) K2 G7 }8 d
}
; w$ E. w% i# F' P2 F, G" o
return(0);
0 W5 F7 Q0 ?, D3 N9 n4 S
}
0 $ s3 r/ B4 [0 U# ~2 w

: E: y- V- e' o3 o( L0 m: i1 `8 f
同主程序一样做一个发送消息项, 代码如上。
! }6 O4 k5 k* B3 d' c
显示程序也与主程序一样, 代码如上。
# j9 {; N! l; W, x. T3 E
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
- n& c5 B& ?5 j4 X7 P4 g- u% V$ q
编译程序便可得到client.exe 程序。
' v- ?; n2 s. B0 r
----server.exe 和 client.exe 做完后, 就可以在具有 TCP/IP 协议
6 K7 W! \" [; O4 `& t; i& |! T$ Y
下的网络中执行。