服务器与客户机互传消息

韩冰

一、 服 务 器 程 序

) I8 [ W# K9 N

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

在serverview.h 中 加 入 代 码：

* r6 ~+ P3 U P& o- ^& Z- S

＃include “winsock.h"

. I7 u& w% ?8 w0 K4 j. g+ Z' T

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

" }! ?6 \8 m# N$ v3 ]; p: F1 P

int count;// 信 息 条 数

7 x" v8 ]/ g, A+ t9 y

CString m_data[1000];// 信 息 存 放

char Hostname[260];

char Hostaddress[20];// 主 机IP 地 址

8 f8 n9 k1 d; L

SOCKET m_sock;

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

BOOL flag;

SOCKADDR_IN saClnt;

int saClntLen;

9 ]6 M# c% z2 N' m) c

BOOL Isconnect;// 是 否 连 接

" H: c5 |: D% E" o3 I* h5 o

# }, ?4 K4 r" ~+ d/ u

在serverview.cpp 中 重 载CServerView() 构 造 器, 创 建 并 绑 定 嵌 套

: g7 A+ E' g+ n

字：

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

flag=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

8 v+ f! |8 ?. q2 H9 y5 U

m_hListenThread;

" o+ l1 P4 f7 A% H! ]

count=5;

# a1 Z. X+ E- r; a" M, L8 w) c

int status;

6 k5 ]- t( c9 ~$ m) b4 q1 k. W' W

WSADATA wsaData;

m_data[0]=“initializing Windows Sockets DLL....";

3 e+ {9 H$ v/ s. K7 b! d

if((status=WSAStartup(0x0101, ＆wsaData))==0)

{ m_data[0] ＋=“Succeeded";

- x5 [* m. {3 F! ^) ^9 k3 M7 K

m_bInitialized=TRUE;

}

" i" M' f) ~ f! M# e: ?8 b$ x& ]/ j

else

+ v9 i- ~; [- \+ w

{ m_bInitialized=FALSE;

' o2 @: ?% N8 M

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

m_data[1]=“Creating socket....";

if(m_sock==INVALID_SOCKET)

4 {4 u |, m! `& u

{ m_data[1] ＋=“Failed";

3 {3 D6 i# M- M+ x" m. G: S0 D( d

}

m_data[1] ＋=“Succeeded";

m_data[2]=“Binding socket....";

: s: V9 W5 p' [( P* k' ?8 e

sockaddr_in sa;

; E- S T* r+ `' w1 l& _& y

sa.sin_family=AF_INET;

! s" b4 V+ [) T4 M' r+ T$ ]; @

sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);

% H; l$ C3 f2 R; E" p3 o5 c

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

' |- v" l! t2 e' d

＆sa,sizeof(sa))==SOCKET_ERROR)

) M& i @; Q; K: e9 r/ ]

{ m_data[2] ＋=“Failed";

~& H1 H5 }$ ?% r

closesocket(m_sock);

}

m_data[2] ＋=“Succeeded";

! M* s. X7 Q5 N/ X7 t9 G

m_data[3]=“Creating listener thread....";

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

! u: b0 O8 m) f: k# }0 ~/ k( D7 D

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

+ ^: W4 J* U& ^$ }

{ m_data[3] ＋=“Succeeded";

m_data[4] ＋=“Listening....";

}

else

7 S6 G/ c+ J3 }) d

m_data[4] ＋=“Failed";

# ]6 f6 f* p m! p

}

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

1 p' L+ |# o; `6 B. u2 R$ t* C

CServerView:: ～CServerView()

{ if(m_bInitialized)

( Z! s+ T' u2 g5 C# B

WSACleanup();

, J/ O& v% I' a# \" E6 R

closesocket(m_sock);

* ?" ?5 j3 W8 C! E0 {

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

4 N e6 T% ?. ?5 o" h. O7 X4 j

}

2 A* q3 Q+ j+ I: q3 T T: e

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

long WINAPI Listen(CServerView ＊pView)

, I' x( ^ J# ~: P! `) U8 R% U" V3 x

{ char msg[2000]=“";

% _/ c% }) L* ]. b( h' `. N: i7 i# p0 l

int nchar;

SOCKADDR_IN saClnt;

int saClntLen;

7 [# d& } a$ S. K

while(1)

" G" F9 E5 r& p& s4 Q' u2 A+ {

{ saClntLen=sizeof(saClnt);

nchar=recvfrom(pView －>m_sock,msg,1024,0,

(PSOCKADDR) ＆saClnt, ＆saClntLen);

' n# f% C7 x+ E5 a9 Q2 j

if(nchar<0)

{ pView －>m_data[pView －>count ＋ ＋] ＋

! C2 }! l. C/ k) t. Y' Q

=“Error in recvfrom\n";

- z0 r/ ~9 @8 `1 n

pView －>InvalidateRect(NULL);

}

else

{switch(msg[0])

{

! A" n( {* Q7 a; X, w6 a9 w4 ^; Z

case ‘A':

% [( E6 w a% t8 |, v/ e

wsprintf(msg,“A:Client from ％s attached\n",

# s7 k. h S7 M4 {* p0 A7 i

inet_ntoa(saClnt.sin_addr));

pView －>m_data[pView －>count ＋ ＋]=msg;

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

0 d4 v% `3 S# O

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)

＆saClnt,saClntLen);

break;

0 _. W+ E8 l5 E/ s+ ]* d

case ‘D':

wsprintf(msg,“D: Client form ％s detached\n",

2 g9 y6 L" D) [. a1 n2 R

inet_ntoa(saClnt.sin_addr));

' \* {: F5 d# M6 y/ [- O# F8 U

pView －>m_data[pView －>count ＋ ＋]=msg;

% y4 _3 W: b! x* J

pView －>flag=TRUE;

9 f0 r/ o. M- i" M$ G

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

' |8 a3 H- M/ H( R6 b

sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)

k; `4 }6 M3 ]2 N

＆saClnt,saClntLen);

4 t% M% X& u& O

break;

# M2 i% _) _6 O- b ~ R

case ‘R':

2 i1 R' F R; y. U1 b8 d4 h

saClntLen=sizeof(saClnt);

. s7 B) S, _" q# ]* n5 j

pView －>m_data[pView －>count ＋ ＋]=msg;

pView －>flag=TRUE;

3 v6 T$ c8 {3 O" q/ C$ b. }

pView －>InvalidateRect(NULL);

- T8 N6 H( C+ k5 B' ^- _6 S9 c; x

break;

default:

break;

}

5 K; |. f, v: d

}

$ ?6 n6 g m/ u) x; K! v

}

9 Y' k% @% [3 G

return(0);

}

在 程 序 菜 单 项 中 添 加“ 本 机IP 地 址":

　 　void CServerView::OnIp()

6 }2 k: m) U7 i# [

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

: l( ^2 F6 i1 Z0 @7 s9 a

gethostname( Hostname, 260 );

7 S7 ^: r" o- o

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

3 T; l7 ?8 ?: }

if( pHostEnt != NULL ){

wsprintf( Hostaddress, “ ％d. ％d. ％d. ％d",

$ i p4 ?2 m( D% {

( pHostEnt －>h_addr_list[0][0] ＆ 0x00ff ),

" s0 x7 ]' L5 O' K) U9 _ i; ~

( pHostEnt －>h_addr_list[0][1] ＆ 0x00ff ),

/ }# [# j- \" J/ s4 ~

( pHostEnt －>h_addr_list[0][2] ＆ 0x00ff ),

9 M0 ~! g; w0 C; ?' y5 s

( pHostEnt －>h_addr_list[0][3] ＆ 0x00ff ) );

* `0 v# H, ?5 t. ^

　 　CString out;

# ]# k3 f0 [6 h

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

　 　}

: i$ j1 C7 p5 l* t/ q3 S

}

}

/ p7 W; I. Z9 l i! }1 {; W

, q* p" J3 ]3 l( s# S# t% L3 n

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

　 　void CServerView::OnSendmessage()

. g5 v/ w ]5 Y+ H

{// TOD Add your command handler code here

1 D# @0 k( N8 R4 C

char msg[2000];

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

　 　{ wsprintf(msg,“R: " ＋Sendmessage.m_Message);

* ~0 x2 ~( U% D3 g

　 　sendto(m_sock,msg,1024,0,(PSOCKADDR)

＆saClnt,saClntLen);

% @5 m5 W# N. ~

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

' k- A7 r- [# k9 G0 t

　 　flag=TRUE;

　 　InvalidateRect(NULL);

% ]+ G" ?* o# c- }$ ?

　 　}

}

. \( V& [! C4 ?+ Q, r+ e

为 发 送 消 息 项 添 加 一 个 对 话 框 的 类, 名 为send, 有 一 个 文

本 框, 用 来 发 送 消 息， 并 为 文 本 框 添 加CString m_Message 变 量

p& \! I# |4 O P2 e* B4 W7 T& o5 i

, 在ServerView.cpp 中 添 加 ＃include “send.h"

, s. f4 S4 Y- ^# ^2 t

为 发 送 消 息 项 添 加 一 个 判 断 函 数:

7 W( L* s7 B6 {1 A

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

{// TOD Add your command update UI handler code here

0 ^& D, J! K w4 K9 b$ w

pCmdUI －>Enable(FALSE);

4 [1 a+ M6 i# z8 b* l7 ]( _

if(Isconnect)

pCmdUI －>Enable(TRUE);

}

4 a) C2 T+ W0 e9 u/ E( W2 G

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

4 _3 ^8 ~7 Z- s# t0 R, R

{ if(flag)

& B) Y8 R p0 ? B5 X5 S

{sizeTotal.cy ＋=20;

. w! z$ x1 a& o* R

for(int j=65;j

: l. E+ ^! U4 x0 e0 d2 E7 f5 W( D; l

TextOut(10,y,m_data);

y ＋=20；}

// TOD add draw code for native data here

! N; Q( i7 o/ Z: e3 t2 i, ~; {/ d

}

) R1 n9 Z" x, M

, G* o) p; F d+ w7 j. R/ E

在Project 中 点 击Settings 中 选 择Link 项 添 加wsock32.lib。

----最 后 编 译 程 序, 就 可 以 得 到Server.exe 程 序。

二、 客 户 机 程 序

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

在clientview.h 中 加 入 代 码：

＃include “winsock.h"

添 加 变 量:

/ Y; T; c; X8 \: K: ~

CString m_data[1000];

HANDLE m_hListenThread;

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

o# U f2 H2 v3 u* P5 D$ @& q# Q

BOOL Isconnect;

0 O' S o! {0 ?4 [* `& ^ ?

int count;

" R! z5 `9 a/ }. Q! d0 Q9 W

CSize sizeTotal;

5 x' H: H! w+ ~$ o3 x

BOOL flag;

9 k$ j+ J' A9 v5 F! E y2 n- C

在 构 造 函 数 中 初 始 化 变 量:

E& ?& P9 E1 V& ^$ n

CClientView::CClientView()

% \% W# A0 y- r

{ // TOD add construction code here

Isconnect=FALSE;

1 f; n& G8 j! q' h

sizeTotal.cy=350;

$ r1 M& _. K, X1 a& Q0 Y" f

sizeTotal.cx=300;

flag=FALSE;

}

$ x* p: A" s2 o, U8 ]

在 析 构 函 数 中 完 成 清 除 操 作， 代 码 如 上。

( X* z; O, z! }+ M- X$ L! m

在 菜 单 中 添 加“ 拨 号" 项:

& ^" E! a# B7 n5 z& g/ J" X

void CClientView::OnDial()

3 X: P5 L+ y, L4 N" P$ E

{// TOD Add your command handler code here

/ @) M! C0 }) ]

count=5;

if(m_bInitialized)

6 | r" ]) h: l0 W4 J, i& g

{ AfxMessageBox(“Already dialing");

return;}

Cdial dial;

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

2 J3 i- T+ y3 R8 C

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

8 M" |% p! y+ o8 i5 @6 g

(INADDR_ANY);

5 {8 l& T$ |% K0 P: J

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

m_saSrvr.sin_port=htons(5050);

: u i2 b5 x0 G9 |/ I9 {9 Q

int status;

WSADATA wsaData;

m_data[0]=“initializing Windows Sockets DLL....";

if((status=WSAStartup(0x0101, ＆wsaData))==0)

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;}

* L$ N4 e# S$ Z" _' s- S

else

6 B6 t$ ~. C. ^

{ m_bInitialized=FALSE;}

: `+ c9 \: W6 Y* o" i2 @

m_sock=socket(AF_INET,SOCK_DGRAM,0);

m_data[1]=“Creating socket....";

! H% ~" x, o: g

if(m_sock==INVALID_SOCKET)

0 [. j8 r# t/ ^ \; z

{ m_data[1] ＋=“Failed";}

! f" g7 I. U; V C: g

m_data[1] ＋=“Succeeded";

1 _, k& M" {5 i

m_data[2]=“Binding socket....";

sockaddr_in sa;

B# {' }4 M' Q* V' g/ E# I

sa.sin_family=AF_INET;

2 k& k1 [* E8 g$ l1 ~; I* O) ]6 t

sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);

% x1 K7 P2 Q* ~4 H

sa.sin_port=htons(0);

# D/ m4 {/ C8 U& {

if(bind(m_sock,(PSOCKADDR)

＆sa,sizeof(sa))==SOCKET_ERROR)

{ m_data[2] ＋=“Failed";

- B* j* }; j8 C5 ^9 C

closesocket(m_sock)；}

m_data[2] ＋=“Succeeded";

! W9 e. E4 D- U" {6 j* J: ?- j

m_data[3]=“Creating listener thread....";

$ A5 S9 o3 x% m" t+ G3 i# x; N

unsigned long idThread;

0 v M2 v6 z" \ H

m_hListenThread=CreateThread(NULL 0,

9 r( z' M9 C* M6 B- D% g/ G

(LPTHREAD_START_ROUTINE)Listen,

$ B) @7 F$ a X. Z; Z* X6 O

(void ＊)this,0, ＆idThread);

/ N0 h* Z6 e4 O8 S1 }! c

if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

) G2 e# l/ T! G

m_data[4] ＋=“Waiting....";}

/ G. b5 y3 X/ `. s7 U

else

m_data[4] ＋=“Failed";

+ X6 r5 g! q9 z* `

InvalidateRect(NULL);

}

}

+ {0 a9 C1 k2 Q a( S% @

添 加 一 个 拨 号 对 话 框, 名 为dial, 有 一 个 文 本 框 用 来 写IP 地

4 h& o( H- G/ B3 r# n' Q2 t9 i

址. 并 在clientview.cpp 中 添 加 代 码:

+ N) o& z2 E, z) s# }

＃include dial.h

6 J5 W: d, G, r' y$ Y

在 拨 号 项 添 加 一 个 判 断 函 数:

z7 K9 _+ F2 d6 ]

void CClientView::OnUpdateDial(CCmdUI ＊

# W* x! J- ~/ Q( m1 k

pCmdUI)

{// TOD Add your command update UI handler code here

5 y0 C( |" s& I

pCmdUI －>Enable(TRUE);

( L( C6 a o- m* \6 z% N3 i& s2 V+ n ^

if(Isconnect)

pCmdUI －>Enable(FALSE);

}

, ?& Z$ r3 ^2 T( H% D- [

) G$ N& o7 w* v) E* k/ Y! m# Q

添 加 接 收 与 发 送 消 息 的 线 程:

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

, c1 n5 c+ r% y9 @% o

pView －>m_data[5]=“Sending ATTACH command";

* T- Y8 L6 e l5 _9 C6 H d6 w

pView －>InvalidateRect(NULL);

wsprintf(msg,“A: ");

9 D1 j! {" L+ Q0 f' f( G

sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)

＆pView －>m_saSrvr,sizeof(pView －>m_saSrvr));

int saSrvrLen ,nchar;

while(1)

% S! { Y4 ~3 Q; m! ?0 W7 x* q1 X

{saSrvrLen=sizeof(pView －>m_saSrvr);

( A# r/ V( _+ y# X; O9 A3 j# t2 T

nchar=recvfrom(pView －>m_sock,msg,1024,0,

(PSOCKADDR) ＆pView －>m_saSrvr, ＆saSrvrLen);

1 E- w$ Y; B$ R, ]/ t$ S0 {; J# L

if(nchar<0)

. U4 a1 X- D4 W7 A8 y2 D

{ pView －>m_data[pView －>count ＋ ＋]=

“Error in recvform";

5 K! K$ i( S% y6 b/ A! R3 n

pView －>InvalidateRect(NULL);}

7 o; b* u0 V+ R! }

else

0 Z6 K" I- o: T9 _- S0 | H

{ pView －>m_data[pView －>count ＋ ＋]=msg;

pView －>Isconnect=TRUE;

, F9 Q! X1 s. X- M

pView －>flag=TRUE;

; g3 s \, w$ r& j+ P) I8 n% F

pView －>InvalidateRect(NULL);

' a' h2 u7 d6 U

}

}

9 P3 f8 y( G2 Q* [6 O+ U2 s$ n8 V' U

return(0);

}

) B, C6 J2 v f0 T; O ^# C- e

T% H5 _! F" G5 L, P' c

同 主 程 序 一 样 做 一 个 发 送 消 息 项, 代 码 如 上。

K6 a* q: s: ]+ z* l

显 示 程 序 也 与 主 程 序 一 样, 代 码 如 上。

在Project 中 点 击Settings 中 选 择Link 项 添 加wsock32.lib。

编 译 程 序 便 可 得 到client.exe 程 序。

----server.exe 和 client.exe 做 完 后, 就 可 以 在 具 有 TCP/IP 协 议

下 的 网 络 中 执 行。