服务器与客户机互传消息

韩冰

一、 服 务 器 程 序

# V9 I3 d& X$ V7 V: U

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

5 o5 ~! i1 w- r3 t- V

在serverview.h 中 加 入 代 码：

＃include “winsock.h"

' p$ G- D1 d* C5 N- S/ N

添 加 变 量：

. F; ]% Z$ m! e$ v; L. G

CSize sizeTotal;// 控 制 滚 动 条

, r) a2 O9 ^) [) W6 p9 K1 \. J- ?

int count;// 信 息 条 数

' O3 X! c- I* n& Y: |0 a: g

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

char Hostname[260];

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

SOCKET m_sock;

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

9 t% d& v R9 _" i# l4 O& Y' O$ u6 n

BOOL flag;

) R; q! G$ Z1 n7 g7 }) N

SOCKADDR_IN saClnt;

int saClntLen;

/ m" H U0 o4 k- W

BOOL Isconnect;// 是 否 连 接

( c8 Z2 ^4 ~0 z, m' ]

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

( p& s$ l7 M+ a/ u s! J Q

字：

CServerView::CServerView()

/ n+ M, v7 s1 A

{ // TOD add construction code here

( R7 p9 n# p$ r6 u

Isconnect=FALSE;

flag=FALSE;

sizeTotal.cy=350;

5 W" l( U4 F* [. t

sizeTotal.cx=300;

m_hListenThread;

$ D4 `1 d* S' n8 W

count=5;

int status;

+ F, Z i5 l E

WSADATA wsaData;

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

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

{ m_data[0] ＋=“Succeeded";

& A- P9 U: ~# b B( q0 e2 w

m_bInitialized=TRUE;

}

. v: m- }$ u5 V# R$ H8 v( [

else

{ m_bInitialized=FALSE;

; S& P2 ^6 Y" C$ N& r& `

}

, {( v& t. ~' i' Q0 {2 e$ h' F7 H

m_sock=socket(AF_INET,SOCK_DGRAM,0);

, f2 K/ O3 g, n

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

0 T5 e7 s3 o' u9 Z( c6 X- B8 J3 D- X

if(m_sock==INVALID_SOCKET)

$ P8 E+ p) j7 I* ~% u

{ m_data[1] ＋=“Failed";

}

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

0 x" o! I( l2 b; q" j b

sa.sin_family=AF_INET;

: \3 P4 J6 d' b# P

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

9 q) h w; K( P

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

7 ^0 n& f( ]# D; o

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

* E( I5 z8 T2 f8 B1 F

{ m_data[2] ＋=“Failed";

closesocket(m_sock);

}

m_data[2] ＋=“Succeeded";

: |7 [3 G3 L- _4 Z" j- G

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

v$ P3 u1 g! q: ]) E6 V

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

p" Y! n1 m" W2 T

{ m_data[3] ＋=“Succeeded";

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

3 O5 D- X! I% J2 [; \8 G0 M0 j

}

else

3 Y. g2 L7 g' V) S7 O8 g! g! s

m_data[4] ＋=“Failed";

* u/ j# W$ J0 e7 j

}

$ m. Z+ F+ X6 z7 ~0 f7 V, X8 h

" y! f6 f5 |6 M# A6 A3 P$ Z" P

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

: N2 z5 N, ]9 F& S0 F9 A

CServerView:: ～CServerView()

" }. Q2 b( g/ x# k3 Y

{ if(m_bInitialized)

WSACleanup();

closesocket(m_sock);

" U9 E; ?* E5 b Z

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

6 o0 m! n, F$ v4 y4 X% k

}

0 j" n3 T/ Z( O/ _

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

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

4 I- [4 X7 w6 H! M

int nchar;

8 ~- L, r m q( c

SOCKADDR_IN saClnt;

int saClntLen;

while(1)

{ saClntLen=sizeof(saClnt);

8 ?1 O& x8 v- Z, A$ J

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

if(nchar<0)

/ h' H: V4 Z1 _3 h; F& M! X# j, C

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

=“Error in recvfrom\n";

: O- U& `& m" _# ~9 k! L# K0 z0 K

pView －>InvalidateRect(NULL);

}

, X p6 {" ?0 r+ z

else

{switch(msg[0])

{

s8 \+ d9 C5 t/ y z. Q

case ‘A':

* x) k% M6 \" |

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

( H/ [$ {- G9 B G/ B) h" m

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

8 B* J+ f2 k" c* s* }% f3 V

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

, i, T4 @/ j% N. b7 v, S4 l

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

8 Q( F! H5 @: x) k8 g" }0 m

break;

?% b* W ^ [0 x# w9 v, Q

( T3 N0 n: B/ A# b. E6 i8 D% \9 D

case ‘D':

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

/ O" t% Z; ^8 a- v- ~" I

inet_ntoa(saClnt.sin_addr));

7 G. t3 ]1 W8 w! m

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

8 E4 b! S- V: E" D2 S" q

pView －>flag=TRUE;

+ q! P) @, x- O0 W

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

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

＆saClnt,saClntLen);

break;

4 [ a6 w4 c3 V3 ]/ R

case ‘R':

6 K5 N9 L7 ^) I% J- V

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

. B+ D' P3 k: d# c1 h& |

break;

7 Y/ n$ r, i" H# w* w U

default:

9 }' A3 v8 m, D2 O7 t3 K

break;

}

}

}

3 v& \' d4 @9 U7 p& w: a

return(0);

}

L6 k6 Y& f/ [

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

　 　void CServerView::OnIp()

4 R7 E. \" T6 X$ M; D

{int WSAReturn;

& r" r! i8 [. v+ N5 w: s

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

8 ~* I' P$ |' \

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

4 P( S7 j( [# n3 k8 w9 E

struct hostent ＊pHostEnt;

9 ]+ T' Q8 e6 R4 x, h1 E; l% U) Q

pHostEnt = gethostbyname( Hostname);

; Y& Z' X! F5 X. |. A! [

if( pHostEnt != NULL ){

7 t0 Z& `6 a% a3 D

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

6 J4 x( u9 q" P0 x! O

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

" {' H* j/ M/ X }. k' G5 s( W

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

0 [, c' C! r- ~+ ? |& f

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

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

　 　CString out;

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

- S" l( w j; `

　 　}

}

}

# A; B$ J$ J1 V" j7 T

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

char msg[2000];

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

! n; `" r. X6 k1 C

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

* ~2 y+ d* C' k) D/ C/ _. }

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

＆saClnt,saClntLen);

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

, @' ^0 H E3 v: z$ g2 h

　 　flag=TRUE;

9 H% R. h% M$ l i' K! V4 O( U

　 　InvalidateRect(NULL);

　 　}

}

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

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

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

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

5 L; Y; |: B6 b

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

pCmdUI －>Enable(TRUE);

( B% u" P5 `+ B# A, P0 I

}

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

{sizeTotal.cy ＋=20;

7 w$ w% @2 S' L: A5 B K$ g

for(int j=65;j

% f' O8 f8 Q" C2 o& s# ]) Z/ \ [" R7 B

TextOut(10,y,m_data);

6 t# A2 m9 V1 @8 J& u3 y8 S

y ＋=20；}

// TOD add draw code for native data here

}

; N% }& v+ f/ F* T/ ?

" j8 |5 B' l m1 r3 A q) f$ C; W" K

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

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

# J! y2 m* Z& G, w, g: ~

二、 客 户 机 程 序

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

6 e7 d0 H# N2 r5 m8 L. C, |, N

在clientview.h 中 加 入 代 码：

+ y, N) {) d8 ^) Y* E& |

＃include “winsock.h"

; X* i' K9 M1 i. l0 M1 V- }

添 加 变 量:

* D- k* R, k. }. K$ I' l

CString m_data[1000];

' q B5 V% i, Z- k z- M$ t

HANDLE m_hListenThread;

6 d4 Q) w' Y: N8 r: H

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

, B- c( ~4 d. A' }7 z1 D1 z

BOOL Isconnect;

int count;

CSize sizeTotal;

7 W) w/ ~- [8 {$ b- ^/ z' @- B4 @

BOOL flag;

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

/ Z; R8 j, X" O- k& p7 e6 ~& b

CClientView::CClientView()

{ // TOD add construction code here

Isconnect=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

flag=FALSE;

}

6 E' ]; Y- v7 X( w/ `

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

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

void CClientView::OnDial()

{// TOD Add your command handler code here

count=5;

* u. c) Y W4 T

if(m_bInitialized)

{ AfxMessageBox(“Already dialing");

( O( ~5 ~5 K$ |# Y. e8 _

return;}

; j$ G3 m$ K! H, `/ y1 x

Cdial dial;

6 z) @1 l4 f, `4 {3 U

if(dial.DoModal()==IDOK

; D; `: u4 e7 w2 B7 c$ M& }- R3 ?

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

# U+ a9 ^/ [; H! u$ t! N) O* @

m_saSrvr.sin_addr.S_un.S_addr=htonl

0 {" S/ l$ f$ k& ]5 l* E

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

( u: X3 S: K8 T2 z7 w/ y" w+ s

(dial.m_HostAddress);

m_saSrvr.sin_port=htons(5050);

" W7 r. ~, r( o1 f* x2 p

int status;

WSADATA wsaData;

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

3 B( y6 w2 [' C( i, v

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

{ m_data[0] ＋=“Succeeded";

, [7 r1 J" d6 p6 h. b3 }

m_bInitialized=TRUE;}

) s4 _- S+ v' P7 I

else

2 \! H) l- c3 _+ a% r3 F0 y( E

{ m_bInitialized=FALSE;}

: E, q4 V B. s# I

m_sock=socket(AF_INET,SOCK_DGRAM,0);

5 L, B6 e; J! z" ~1 ?3 n: z

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

# M) p# Y9 f6 y% h* b

if(m_sock==INVALID_SOCKET)

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

# L3 w- u I7 s+ N

m_data[1] ＋=“Succeeded";

9 w. n, s7 ~1 a7 A( Y

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

. b3 {1 L1 j4 a1 D, }) L

sockaddr_in sa;

sa.sin_family=AF_INET;

' k& A5 m8 X* x9 v

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

) w+ p0 }* o6 J# x2 n

sa.sin_port=htons(0);

+ ~& _7 u1 V) E% c

if(bind(m_sock,(PSOCKADDR)

4 P! d3 A8 R6 D

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

# e. {+ x2 |$ T1 c6 u% c

{ m_data[2] ＋=“Failed";

* L2 O) q1 Z8 _# b4 D

closesocket(m_sock)；}

m_data[2] ＋=“Succeeded";

9 \( N! M* y+ X7 ]/ j2 ~

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

+ l# {! P$ I2 u5 d' ^

unsigned long idThread;

$ a7 @- Z" w9 r9 a

m_hListenThread=CreateThread(NULL 0,

: R4 [" w5 |( g5 [! {& B! q

(LPTHREAD_START_ROUTINE)Listen,

9 `6 p0 H! ]" O' V

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

if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

6 C, {) i5 e+ Q! a2 U4 W1 @- S

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

else

m_data[4] ＋=“Failed";

% o' s% @3 p Y) ^" D

InvalidateRect(NULL);

}

}

% K6 a5 {& q; `, u+ z. f8 Y" E

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

; @& j5 g0 S8 u' o2 \8 x' v

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

＃include dial.h

' _! z. ]' i& e) I! B. z" T

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

! X, ?* N1 d; N

void CClientView::OnUpdateDial(CCmdUI ＊

6 D' E9 H; ]; K% q

pCmdUI)

1 F/ d: p' a6 y; s3 E0 d

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

* G/ S( y/ `5 q3 U( s& M

pCmdUI －>Enable(TRUE);

/ l8 z1 E6 Y; k; p( i0 T

if(Isconnect)

: ?5 B8 `3 o, U8 f

pCmdUI －>Enable(FALSE);

; k* u7 s, P7 Y. j/ q: [

}

; \- D |0 y" X9 z! _

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

long WINAPI Listen(CClientView ＊pView)

; L+ X" F+ \3 _% F1 [5 a% ?

{ char msg[2000];

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

6 L: n# ~0 S! s( }( N

pView －>InvalidateRect(NULL);

wsprintf(msg,“A: ");

7 M& i% q8 H6 z& D

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

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

! a* Z! {. x" J8 X& s" c

int saSrvrLen ,nchar;

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

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

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

/ n0 N. e: O0 M. \5 {* Q; R

if(nchar<0)

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

I W; R+ I# \% p0 Y

“Error in recvform";

" x& e, I# b- n2 E" ?

pView －>InvalidateRect(NULL);}

else

+ x6 E s" l) ~7 ]% Y+ ~) Z. L

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

pView －>Isconnect=TRUE;

* F' u# O! B- {8 r( s1 F

pView －>flag=TRUE;

" B) M: V H' _" e R

pView －>InvalidateRect(NULL);

}

% O( f( Y* ]6 _4 ]( `2 S

}

( x+ x+ E( v/ o% m2 T7 d9 c: y/ g

return(0);

5 V/ d; d1 o2 h. Y( e5 H' e* I

}

5 q8 K! @$ z$ e

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

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

9 C/ M6 R; Y' _1 Z

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

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

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

下 的 网 络 中 执 行。