查看: 2515|回复: 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);

# q& v$ B8 P5 i
y ＋=20；}
# {. q: I7 o$ P: w; x0 ^/ N7 |
// TOD add draw code for native data here
{% k5 a4 ?2 Z" ]% f
}
7 x4 b* e4 ]- ^, X) b k6 _

8 _% p' m% D7 ]+ G( Y
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
7 o+ M* R( \+ ]/ t; u
----最后编译程序, 就可以得到Server.exe 程序。
; x) |% B8 h# r# d" g0 E c

7 b1 S% _6 t( d( M- q k
二、客户机程序
2 C( m: p$ f/ K2 e5 `) j( D" t0 i
创建一个名为“client" 的项目, 单文档界面。
) q6 r" N v5 F3 c& y- G9 Z
在clientview.h 中加入代码：
- ^9 h: v) U* _) v, i* `
＃include “winsock.h"
3 k/ s' D/ [7 Y$ C% Q; a
添加变量:
* J, v/ G% S) ^7 J
CString m_data[1000];
+ n& k0 Q+ a+ g( u; T
HANDLE m_hListenThread;
3 m: |' D) S; g X6 P7 @ j) N
SOCKET m_sock;
' f. T1 T/ T. j
SOCKADDR_IN m_saSrvr;
) L7 B" y2 r( `' Y+ u! ]( U- c+ o
BOOL Isconnect;
& w0 D( x( P1 t+ j
int count;
0 d1 j. G" X. k2 a0 g" s6 V
CSize sizeTotal;
4 y% M* l; L9 u, T) k7 Q
BOOL flag;
# C" s `6 f7 V+ F1 p1 e7 {1 M, }

# u0 E: o5 F5 r5 i
在构造函数中初始化变量:
$ I1 i& \, v; j; C: M
CClientView::CClientView()
5 e- [/ L3 J2 x7 S3 f
{ // TOD add construction code here
3 n: o. X+ ~( o4 Y+ }
Isconnect=FALSE;
) o0 t3 x; D) Z* x
sizeTotal.cy=350;
2 B D, H4 |/ H! D4 i2 c
sizeTotal.cx=300;
0 D U( j& x, `7 M6 V/ E
flag=FALSE;
: ^; x/ r: d9 E1 k) `
}
2 U; I( I( `+ `+ G6 B

( ?/ j) e6 h% w0 }2 v! j
在析构函数中完成清除操作，代码如上。
6 X( V0 a, ~" W1 n" ?, k
在菜单中添加“ 拨号" 项:
# x1 N0 ^/ P' `7 j5 \
void CClientView::OnDial()
g0 A8 D# ]6 W1 P: Z& c6 |
{// TOD Add your command handler code here
. l$ ]* R5 v' l3 a( T" y
count=5;
! F# Z3 E$ t( Q6 Z: |
if(m_bInitialized)
5 z- H9 ?7 ~9 ~
{ AfxMessageBox(“Already dialing");
' w+ u9 U: {7 M E
return;}
+ P6 a/ A# G+ e
Cdial dial;
- u5 X, Q4 B/ @# v* P( T& q- S
if(dial.DoModal()==IDOK
: ^- z, w$ ?; M$ [( L$ i
＆＆!dial.m_HostAddress.IsEmpty())
y( g* u6 J G; z; Q* I5 f
{m_saSrvr.sin_family=AF_INET;
s% D5 W+ \1 g" u5 }( e: J
m_saSrvr.sin_addr.S_un.S_addr=htonl
' v% E7 e, L+ U! t- ~
(INADDR_ANY);
) I* O0 B. d$ ` c
m_saSrvr.sin_addr.S_un.S_addr=inet_addr
' N4 ^& m7 k8 a; E" T
(dial.m_HostAddress);
2 ~) c' ^6 H; P$ Z! A
m_saSrvr.sin_port=htons(5050);
: S! S9 W* c j1 h5 K& u
int status;
' R& _$ F2 i5 W U+ [
WSADATA wsaData;
3 c$ V T0 W J2 t
m_data[0]=“initializing Windows Sockets DLL....";
) x. s% C" M+ o: J/ ~, l2 T
if((status=WSAStartup(0x0101, ＆wsaData))==0)
4 |/ a- D$ i' m7 m0 ^6 T
{ m_data[0] ＋=“Succeeded";
. @6 d: [; e! S0 {3 y+ H! p
m_bInitialized=TRUE;}
, Q; X4 q$ _: Z! Z
else
; l0 b* Z5 g/ D! V4 f" G
{ m_bInitialized=FALSE;}
* ?3 N2 Y) N5 s3 I( X' b3 h/ y3 a4 z
m_sock=socket(AF_INET,SOCK_DGRAM,0);
: e0 W- t' r# K$ b A
m_data[1]=“Creating socket....";
# R) F: v4 ?" Y3 b" H; R
if(m_sock==INVALID_SOCKET)
' i; J9 @4 \0 s+ l- Q- v
{ m_data[1] ＋=“Failed";}
/ m( Z2 u1 M- s1 ^
m_data[1] ＋=“Succeeded";
. b& C& ^" l' ?/ R# a7 P( D
m_data[2]=“Binding socket....";
/ S7 `5 x _0 h C; J, e* L/ {1 o
sockaddr_in sa;
; Q4 t" x+ ~! z0 N) z$ K: y# V# d
sa.sin_family=AF_INET;
) k! q- F" C5 @% k! I
sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
: i, X- \# r) _( u# o8 k
sa.sin_port=htons(0);
- W1 {! V/ i0 X
if(bind(m_sock,(PSOCKADDR)
+ E% Y6 |7 w. a1 {3 ~, K; r8 m* N
＆sa,sizeof(sa))==SOCKET_ERROR)
: ^ Y$ U/ E* v0 S3 V
{ m_data[2] ＋=“Failed";
& b! @ }% F: V+ n5 l
closesocket(m_sock)；}
" y, {- y; \8 `# Z D
m_data[2] ＋=“Succeeded";
" T- I* m5 k6 A: J- H
m_data[3]=“Creating listener thread....";
! @4 o2 I! G0 Q2 q7 E, W
unsigned long idThread;
$ |( ?' R$ x8 H8 A+ R. g
m_hListenThread=CreateThread(NULL 0,
- I) M1 k& S! f w6 D6 `
(LPTHREAD_START_ROUTINE)Listen,
( j* T# }: U) v
(void ＊)this,0, ＆idThread);
9 V9 S* W1 m2 N- v) _
if(m_hListenThread)
; j! a- I% T5 \6 W
{ m_data[3] ＋=“Succeeded";
4 X4 _$ j8 q' D2 Z8 C
m_data[4] ＋=“Waiting....";}
+ ~6 j0 J2 }. k( g" P
else
1 `9 s/ A% I6 \4 w5 c0 F
m_data[4] ＋=“Failed";
7 J' Y4 r! [4 H3 y6 i2 S
InvalidateRect(NULL);
( E0 s p3 y* J( g& _
}
5 F" a- t( `" O* l1 ]: O% T
}
" T% ^9 u% ~$ K' H t4 @4 A. `

! e, ?1 z) z$ X) W5 ^8 U4 s; o; Y
添加一个拨号对话框, 名为dial, 有一个文本框用来写IP 地
: I9 {* v4 e3 z" c$ ~
址. 并在clientview.cpp 中添加代码:
: L3 M- t- C5 q9 ]- f$ B+ p
＃include dial.h
6 K+ b7 f$ r7 ?0 d; M; x% e

& G* {# A0 `8 `
在拨号项添加一个判断函数:
& W6 a# d. f5 _. z: _; p0 U
void CClientView::OnUpdateDial(CCmdUI ＊
3 X& n2 V2 G& [7 O7 Q
pCmdUI)
' g! k5 R' B' E t1 J; }
{// TOD Add your command update UI handler code here
1 y( Y* a" }2 p8 |+ O2 S# x
pCmdUI －>Enable(TRUE);
8 E6 P K/ [4 i) v# v4 F/ ^
if(Isconnect)
) Z4 w9 Z% F, |
pCmdUI －>Enable(FALSE);
7 d' |( Q: l1 L9 G6 _ U
}
7 m2 ?& m% P8 U( Q1 Z+ K

* R8 h+ }$ A8 m ?- f( v& u/ A
添加接收与发送消息的线程:
1 `1 Q+ A+ K$ w, e7 @% g2 S0 X
long WINAPI Listen(CClientView ＊pView)
9 a8 `. J3 {) W3 ? @$ y: e" Q7 \( f1 ^
{ char msg[2000];
* d! m* ^/ E1 c7 Z9 ~% ]
pView －>m_data[5]=“Sending ATTACH command";
( K# O4 s0 u" j$ D
pView －>InvalidateRect(NULL);
% H- u/ [6 W2 M, p/ P
wsprintf(msg,“A: ");
) Q# j, E+ [4 a% z7 z
sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)
9 x+ [6 y. {6 S2 Q; E
＆pView －>m_saSrvr,sizeof(pView －>m_saSrvr));
, H9 _( Z6 l9 N1 m1 P" V7 a
int saSrvrLen ,nchar;
+ P# z5 l9 c. W- X; E G
while(1)
5 U7 C! p: m, z9 G1 S* H' \
{saSrvrLen=sizeof(pView －>m_saSrvr);
# v: w# h4 `* ~$ @0 {
nchar=recvfrom(pView －>m_sock,msg,1024,0,
" g# u8 B; `( F0 i- k. w1 x
(PSOCKADDR) ＆pView －>m_saSrvr, ＆saSrvrLen);
7 @2 ?# t9 B' }* a3 }
if(nchar<0)
+ P8 i' \% Q1 R4 B
{ pView －>m_data[pView －>count ＋＋]=
# l0 S! N+ t g6 ~; {; I% u: g
“Error in recvform";
, ^% J0 E: W/ B* R" r. N
pView －>InvalidateRect(NULL);}
( A6 Z3 F- h G, o, q
else
; U7 y. D$ V1 R' n0 A5 s5 ~. }* k
{ pView －>m_data[pView －>count ＋＋]=msg;
! w, Z% d& j- z# f, R0 c6 H( I8 j
pView －>Isconnect=TRUE;
1 G* m9 |0 s& U# P1 p7 M
pView －>flag=TRUE;
5 x7 H# t4 Z+ K3 L$ r
pView －>InvalidateRect(NULL);
) g4 s! `/ o* m6 s) x7 Z* l; ]
}
^( d( o( w4 h% V8 Z
}
\4 a- Y: o- Q4 {5 s. B
return(0);
" o! Y- D* p s2 T: X, s
}
: G3 b" O- {8 D# W5 v2 D) F) `

1 l- U1 k' M8 n* Q
同主程序一样做一个发送消息项, 代码如上。
3 ?' L% i4 m2 }" P R2 |
显示程序也与主程序一样, 代码如上。
. i! I5 _! h6 W% b% q# y6 R; l$ W
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
) ?- K/ y8 N8 `1 L- K4 u& G) T
编译程序便可得到client.exe 程序。
; I: D8 F& t- C5 s* K
----server.exe 和 client.exe 做完后, 就可以在具有 TCP/IP 协议
) | m2 R; B7 Y" m7 w) s
下的网络中执行。