服务器与客户机互传消息

韩冰

7 E3 U. G5 F0 d6 P1 @ V# u

一、 服 务 器 程 序

X6 a A* ~6 {8 Y2 W ^7 ^

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

& j5 ?# o3 T( E( {" Q Z' v$ H7 ^

在serverview.h 中 加 入 代 码：

＃include “winsock.h"

8 f K" B1 C% V$ ]

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

' E- W; `; p& ?7 a9 V* V( y; t Y; ]

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

char Hostname[260];

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

* \/ W# F5 |# h8 o5 q# o

SOCKET m_sock;

/ R3 h* `, V# e7 L% H

HANDLE m_hListenThread;// 线 程

% [: v" G) g& g

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

% v2 Q4 f0 A, l& N( C; y0 @

BOOL flag;

SOCKADDR_IN saClnt;

, c A: l$ c- }4 m) l

int saClntLen;

7 U. I0 p% k9 I9 V8 x

BOOL Isconnect;// 是 否 连 接

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

字：

CServerView::CServerView()

1 q9 [- z3 j. w$ f

{ // TOD add construction code here

Isconnect=FALSE;

flag=FALSE;

+ H2 g. {& k2 a! U8 @8 M$ U

sizeTotal.cy=350;

6 g' @6 f Q. l9 D' X

sizeTotal.cx=300;

m_hListenThread;

count=5;

, y" }- A+ {, Z

int status;

WSADATA wsaData;

# \( m0 z- }, X6 d& c- B/ X/ o

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

1 X. l3 Z) s0 S% {4 _5 k

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

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

}

else

; G% p2 ?! ~' c3 o. A( v

{ m_bInitialized=FALSE;

( P: Q* R( _6 {2 ?

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

i# h& O# {+ y8 @6 }

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

if(m_sock==INVALID_SOCKET)

- \4 r+ M- }' S4 k" D9 h

{ m_data[1] ＋=“Failed";

}

; p3 y4 A: \ n+ ?; d% \

m_data[1] ＋=“Succeeded";

0 C1 s3 G! O3 j! f+ S: t( u

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

4 l! L& X7 H* B) J8 j

sockaddr_in sa;

sa.sin_family=AF_INET;

3 q7 h8 b* ]: F: w1 v) c

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)

m3 Q; {. H6 J7 v- d

{ m_data[2] ＋=“Failed";

closesocket(m_sock);

. o; ?9 S9 }3 a( P

}

' S% j( i6 ~! J4 u/ ?! Q1 u

m_data[2] ＋=“Succeeded";

+ ?1 s9 K- j5 f) e* o

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

4 g/ u# T2 A9 _! H% A3 B

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

# I8 B2 L1 k+ X; y7 @

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

2 b# @) K$ y4 Z+ \$ B- ~4 ]+ U/ d

{ m_data[3] ＋=“Succeeded";

3 A$ {) l, k3 U; ]

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

+ H# u6 H( L1 O# z" |. l

}

( J) _% t7 T3 w" r6 p! B

else

m_data[4] ＋=“Failed";

' w+ V$ m+ a* i: z2 ^

}

5 s. N- U" h Y: S

/ N% m: [6 T: q) Y0 B* k

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

CServerView:: ～CServerView()

+ H$ w7 J: m. Y r

{ if(m_bInitialized)

/ |" {' a# y1 }: p' a+ L

WSACleanup();

: F+ V0 q# x- r( S7 F7 ~

closesocket(m_sock);

# w. x- N8 n# s3 r }

if(m_hListenThread)

8 H* ~. D2 |2 X7 F7 \

::TerminateThread(m_hListenThread,0);

}

! L- y6 |- j2 R) |) O8 w& _+ z$ L

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

" R4 z. V: Z: Y/ H' J+ k. \

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);

: y3 T$ C, E u ]" Q1 {

if(nchar<0)

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

=“Error in recvfrom\n";

9 }: X$ k3 U; F# R7 J; g3 K7 w

pView －>InvalidateRect(NULL);

}

else

{switch(msg[0])

5 Z, \( t3 Z7 h+ g3 d

{

case ‘A':

K6 }: I- p5 E l" E( h" B2 V

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

7 H$ D6 v4 u t* E' p

inet_ntoa(saClnt.sin_addr));

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

' N( q* z. _3 k" Y, ]+ _ `

pView －>flag=TRUE;

3 k) r# Q% q2 Z; b, ^* y& l. \

pView －>InvalidateRect(NULL);

( s! U$ X3 A* s {+ k5 f

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

; g1 U8 }1 o5 f- N i4 k, s9 m

pView －>saClntLen=saClntLen;

0 E$ Y8 v Q% E" A5 R& R+ P! d) y

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

＆saClnt,saClntLen);

break;

/ G& w# L4 J+ j) y4 w) G0 w

case ‘D':

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

3 Y, L i+ w% T( ]3 C2 t

inet_ntoa(saClnt.sin_addr));

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

1 Q2 z* w) y. [& G ?

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

7 x' _& [( U/ t3 a% S3 D1 W- i0 N

pView －>Isconnect=FALSE;

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

: c; l3 |( L# N6 t8 _

＆saClnt,saClntLen);

break;

* z4 ~9 t5 C+ ]' Q L+ a

case ‘R':

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

$ _3 k R- x4 O4 j" r8 I' O

pView －>InvalidateRect(NULL);

9 {: ?9 B% Y: J$ F& c

break;

k- X% `1 C" o# P3 o2 S1 u

default:

6 q4 ]! ]! o3 T$ S

break;

6 O [5 B# U7 Q( k

}

}

}

return(0);

}

- l. c8 h5 K' P: p

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

+ k2 b. ?: L; U, r

　 　void CServerView::OnIp()

) R* [/ `6 f' U, m8 T) @

{int WSAReturn;

$ t0 u4 E# x; |0 T1 k1 H* ]7 x

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",

# ~2 S: \* D1 Z. @& D, q

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

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

e7 {, @8 E' s& G: g. E7 T

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

5 |* j8 A) |! `' @- g4 |6 O

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

4 K8 W) k, Z, {) R

　 　CString out;

+ S4 r( l8 z$ V6 W9 Y ] J: p" k

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

( K2 J( i; x6 \3 y4 X% F' E

　 　}

}

, X* b' K3 c# l2 \) f* g

}

( Q: p- {3 z, N+ L1 Q. g0 d

- B* {, v. m1 u. l1 `, f

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

8 b. T1 p" D4 }# n% ^; `. @

char msg[2000];

Csend Sendmessage;

/ O/ H2 j6 `- D, s+ u

if(Sendmessage.DoModal()==IDOK

( M- I- R* ?& Q) A( n/ Q& G

＆ ＆!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);

　 　}

) {, x/ D7 X5 S7 q

}

0 v4 Y5 C# G5 @: M( r1 f! _

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

8 ]% W* _9 {0 E& t" Y# J

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

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

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

3 _* N1 \2 k# r! X

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

3 h5 p. [7 @9 `. R: m' G6 {8 K

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

pCmdUI －>Enable(FALSE);

# U I' @5 Z/ h* B2 P6 n4 |# J

if(Isconnect)

( D. ~$ |0 Q) k1 K. @

pCmdUI －>Enable(TRUE);

}

4 G8 c9 ?2 A. p1 }

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

{sizeTotal.cy ＋=20;

for(int j=65;j

TextOut(10,y,m_data);

y ＋=20；}

- _# r. k: o" O: D3 s

// TOD add draw code for native data here

}

@* d, d) c7 b$ a# [: f# a, c8 z

8 }2 u) w2 V) Q2 _1 V

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

4 M. ` k# G8 m) N" L

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

) W2 S3 e# C" |1 s. B

二、 客 户 机 程 序

4 i, V: z$ R' h1 ?

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

- _# p: ?+ o% n

在clientview.h 中 加 入 代 码：

＃include “winsock.h"

- {' \& s* {" C! o' w2 Z* {/ ]5 B

添 加 变 量:

CString m_data[1000];

HANDLE m_hListenThread;

6 a% p- R- I! `' d

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

/ F& D6 Z" B* V( c) ]

BOOL Isconnect;

9 o& G. b( @6 z' O! F" Y+ N1 G, V2 S

int count;

CSize sizeTotal;

$ D; f, ]% N) w! R

BOOL flag;

, Z! z( x$ p0 p/ a& F; f4 \

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

CClientView::CClientView()

{ // TOD add construction code here

Isconnect=FALSE;

+ d4 w" ?6 g6 `8 R/ _* P

sizeTotal.cy=350;

6 T6 f6 \" w) q

sizeTotal.cx=300;

, N3 H5 J+ y' H8 m6 b% K6 K/ l5 o S

flag=FALSE;

}

, V8 T6 B1 O2 e

4 m4 s' Y( |& k" g, C6 N

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

" [8 p) k) {& J/ J% E

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

void CClientView::OnDial()

{// TOD Add your command handler code here

+ i' n; b& J! t& l

count=5;

if(m_bInitialized)

' X1 x' }( B2 ^, [4 z- ^* G$ i

{ AfxMessageBox(“Already dialing");

return;}

J& d( Z" W; W

Cdial dial;

7 {0 ~# Q e4 @2 L0 J

if(dial.DoModal()==IDOK

5 ~, e( q: L' w6 ?7 c. P

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

6 e R4 w! \/ L) R9 f6 X) G o) y

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

$ U) Q4 p9 n& P9 D4 k

m_saSrvr.sin_port=htons(5050);

+ k9 I5 E. S" I, F

int status;

9 l$ E0 c8 V1 }3 I

WSADATA wsaData;

% L% ?8 }2 R& w' q9 ^8 S8 F

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

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

{ m_data[0] ＋=“Succeeded";

6 i3 A$ I) ~4 H

m_bInitialized=TRUE;}

else

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

( o, l! A+ E! z0 \

if(m_sock==INVALID_SOCKET)

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

* `( |2 o0 N4 D9 l

m_data[1] ＋=“Succeeded";

) q# C" w& t9 F( H! F: l

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

sockaddr_in sa;

sa.sin_family=AF_INET;

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

" p( g2 S* S6 [2 I" n4 }% c% t

sa.sin_port=htons(0);

if(bind(m_sock,(PSOCKADDR)

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

& D3 R# U7 G% [7 v5 O7 \

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

s+ r2 I8 o9 v- o: Y

m_data[2] ＋=“Succeeded";

U& j g: F' t( y

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

1 L. A) r0 M8 n, o# {

unsigned long idThread;

m_hListenThread=CreateThread(NULL 0,

a, p2 Y: {. `& E. z

(LPTHREAD_START_ROUTINE)Listen,

! S' S5 W, z3 g) I/ |9 X& b

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

if(m_hListenThread)

; Y) Z" k; \2 c+ |

{ m_data[3] ＋=“Succeeded";

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

else

! l6 j( s! J! T9 s! R4 Q

m_data[4] ＋=“Failed";

+ V8 y! Q B/ k2 L/ m

InvalidateRect(NULL);

. H! V8 c/ `5 n2 G3 _0 Y: @3 j# J

}

- N# d, u* S# F$ ^0 `: l: W# a

}

& y+ d4 `0 `) S% R+ B4 z: Z+ C

; C9 g! h- {, r

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

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

＃include dial.h

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

% g; Z* {6 X3 V/ E/ n! A4 `

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

# M8 A( G( d9 S$ d+ y" E/ Z+ a

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

* ]0 h- C( s4 w. U5 r _

pCmdUI －>Enable(TRUE);

* u! I6 p: s ]7 m+ ` c7 i

if(Isconnect)

pCmdUI －>Enable(FALSE);

* u0 Y: H; v# i2 h# r( A

}

1 p) e+ e8 j/ N/ x

9 F. ]7 o6 J2 z3 s" [) X

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

0 P6 H; _& ~$ w+ F

long WINAPI Listen(CClientView ＊pView)

5 Y$ U# @% I6 o; K

{ char msg[2000];

" ]$ D4 y% Q$ U# d7 Y' C

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

/ E; ]7 }- E2 A. I- R2 Q

pView －>InvalidateRect(NULL);

& I- } @0 g9 D; F# q! o0 e m

wsprintf(msg,“A: ");

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

. o8 E& F5 |2 _5 m/ d4 E5 O

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

! |( i7 s( i8 I! ?4 d

int saSrvrLen ,nchar;

( B! c5 W# c2 |9 W% V

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

; ~0 [% p; x' N2 N ?) R5 a/ n- ]

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

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

if(nchar<0)

6 r7 l( ~) z* E

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

9 h* k2 E: Y8 f: L9 n5 G4 W( y

“Error in recvform";

pView －>InvalidateRect(NULL);}

; d" @& ]. M7 q5 v

else

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

2 X# e& i" G! P# g3 R! G

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

- g6 U/ `+ j& R8 h; F5 ?

pView －>InvalidateRect(NULL);

# ?& o. L) [. X* _8 t

}

}

2 R7 `2 `+ E; W) C* ~9 I

return(0);

}

3 }3 G' C9 k5 {% B

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

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

$ h9 P ]2 B" J% Q" d

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

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

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

}) G! L' v2 r) L; b. j1 O

下 的 网 络 中 执 行。