服务器与客户机互传消息

韩冰

一、 服 务 器 程 序

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

在serverview.h 中 加 入 代 码：

8 z. m+ p2 z$ ]" j1 h `

＃include “winsock.h"

添 加 变 量：

! c" R+ p- x1 a# @/ ]4 z% u

CSize sizeTotal;// 控 制 滚 动 条

. a: k4 ]8 [4 T, b |2 R2 }! m: e

int count;// 信 息 条 数

% Z6 R8 v3 F# ^+ R% ^+ g; @, g

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

char Hostname[260];

6 |) Y) w% |" V$ F: O. A

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

SOCKET m_sock;

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

) X X+ X, i. m

WSADATA WSAData;

" N& O' |$ u9 @2 e

BOOL flag;

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

) ~9 g% L- h6 F1 j: w- q$ c$ p; p

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

( ^( S( a# Y/ I% k) y6 N

字：

& d" p; u! x" u: m

CServerView::CServerView()

" h# q0 d( w/ Y, O9 v$ |4 g

{ // TOD add construction code here

+ d6 g3 v2 O4 s9 { d

Isconnect=FALSE;

flag=FALSE;

0 V5 I; u* R$ E+ j

sizeTotal.cy=350;

sizeTotal.cx=300;

7 r5 k2 x+ a( A" C4 d# j

m_hListenThread;

count=5;

, z* M# e& o8 V

int status;

; B: V" Y- T5 B( t

WSADATA wsaData;

1 D& d! H6 q) V' ^: B

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

/ @2 @' a! [. o6 }6 E) @7 s

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

$ r% D" x4 ?: _' A- |. O' o9 }

{ m_data[0] ＋=“Succeeded";

6 i/ {) \7 Y% s- P9 h

m_bInitialized=TRUE;

/ R2 i5 x7 g5 T a' F" g9 \0 @6 k

}

( p# S, g: b' u7 @+ m# V# ]

else

, o( p" T' ~) K3 o

{ m_bInitialized=FALSE;

# M, S, O) @0 F9 ^

}

3 n+ V% [& O( ^& d& _

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

if(m_sock==INVALID_SOCKET)

+ h) Z5 v8 ~. v

{ m_data[1] ＋=“Failed";

}

m_data[1] ＋=“Succeeded";

2 q* U( |4 ]! d% l: h: v5 \9 R

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

sockaddr_in sa;

% l+ l4 t9 h9 A1 F0 a+ ?! C* y, R; w

sa.sin_family=AF_INET;

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

sa.sin_port=htons(5050);

- C( j9 W9 ]( B$ Y7 a& ^- V! O) w

if(bind(m_sock,(PSOCKADDR)

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

{ m_data[2] ＋=“Failed";

& ?: c0 k& h1 e; Y( p

closesocket(m_sock);

* c1 w" ?8 b5 M; e2 [! m7 @) e% \

}

m_data[2] ＋=“Succeeded";

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

, [" V( k9 {' @

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

$ w* a r& E9 i8 Q/ T' O; w

{ m_data[3] ＋=“Succeeded";

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

}

+ Y1 s3 Z/ a2 T/ ^+ _% e. X

else

m_data[4] ＋=“Failed";

}

# |8 h! M- ]/ J, Z9 [6 W

, _: e8 q8 W% [6 Q6 p$ |

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

7 `' ^* G# q. r, I

CServerView:: ～CServerView()

+ ~7 ~0 _6 V; V' c7 z9 u

{ if(m_bInitialized)

1 t4 E: l G/ [8 ?$ y/ A. C

WSACleanup();

& Y/ s0 y* @) a& z5 O, \' a8 }8 m7 w

closesocket(m_sock);

6 y8 Z5 ?1 H6 D; {

if(m_hListenThread)

; k: @- r* h5 C5 s& E( H

::TerminateThread(m_hListenThread,0);

& D$ P' D# O d$ Z

}

3 k5 H- {- y% J- S# n P

# H3 t% p' H6 O

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

long WINAPI Listen(CServerView ＊pView)

; c& s0 r; j+ T/ R: F

{ char msg[2000]=“";

int nchar;

) v* v) T5 n- L/ \# {9 L) q; i

SOCKADDR_IN saClnt;

" y" `3 G6 y9 r N( G2 a" [2 t$ y$ V: `

int saClntLen;

while(1)

{ saClntLen=sizeof(saClnt);

, h4 o$ |" k# z* \2 _8 a5 a$ s

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

6 r+ C! S H- C' M& Q4 y- P- @% u

if(nchar<0)

: I4 T* J: D! b$ d+ U) C5 b" K

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

=“Error in recvfrom\n";

pView －>InvalidateRect(NULL);

}

- c8 S4 N. z& I: N

else

% Y8 R4 M# ]0 D8 C; ]5 @: X( j* k

{switch(msg[0])

{

case ‘A':

- v; L/ v! S! [( y" Z& W

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

9 \+ ~- I0 S$ {2 z; B

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

/ _# X# f+ Q5 [& [3 Z

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

; Q/ M% O9 ^- Z( T: u; e: c9 b

pView －>saClnt=saClnt;

/ R7 v* X7 k) b+ L9 P( N- Z6 o

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

5 X& h! ^* O; a4 O

break;

! T& `; ]" R8 D) e6 p3 a

& w* q! A; K3 _ W2 L

case ‘D':

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

6 G8 k* p3 h) P4 s

inet_ntoa(saClnt.sin_addr));

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

* g" B9 _6 M! r( D

pView －>flag=TRUE;

4 q d" Y1 O9 z5 H

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

5 d1 E$ d/ w: d0 [6 v: C9 K

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

. k+ \* _# w! H9 F

＆saClnt,saClntLen);

7 Q# H2 }3 ~; Y& q& g

break;

{- O y) P) C8 F) K

8 b% f' t, C6 O3 t- [

case ‘R':

saClntLen=sizeof(saClnt);

: w5 ?4 S0 Q5 M4 L- [

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

pView －>flag=TRUE;

; O2 H4 d8 f: |5 d) ]8 A1 A5 V! P

pView －>InvalidateRect(NULL);

2 b' b+ Y- h8 N: K

break;

H* m- Q/ u1 B8 l" X

" w1 W4 V' E7 q* P8 w0 W6 N# K

default:

1 Y7 o, U$ F3 ^" m2 v% L; T

break;

7 O8 w4 M% E+ P! U* [. D* c

}

" v. ~1 l- g& i$ O

}

. `* Z- ~2 K* z% v A2 _

- h, c0 Y! O. y

}

5 I( h0 N* _: B8 z. O! ~( h; _8 y( m

return(0);

U; e( z. E' o6 u

}

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

　 　void CServerView::OnIp()

. h8 {0 g& D# D

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

. \- i' K" A8 n6 w& x

gethostname( Hostname, 260 );

0 f5 q& |) @. @

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

6 ^7 h) F7 T! z7 e& d3 s

if( pHostEnt != NULL ){

$ P4 j. R# V& f. |; h- y6 f

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

( n! }3 o- i8 v3 D

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

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

& o3 K/ I! q! u. r+ g

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

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

% _6 F; r8 G) P3 ~/ W# j

　 　CString out;

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

　 　}

n; ^* @1 {6 z

}

}

; @$ _: W) c; u! z2 T/ r# I

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

　 　void CServerView::OnSendmessage()

X& I, T0 H- k/ j. I

{// TOD Add your command handler code here

4 y+ u' t( l; {8 I( H

char msg[2000];

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

3 ?* q, Z& }" v. v6 H

＆ ＆!Sendmessage.m_Message.IsEmpty())

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

% v0 w. r( P0 ~1 x$ A& C

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

! G7 c6 C0 z! j! V

＆saClnt,saClntLen);

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

0 Q+ s$ Q8 d4 c" J& n

　 　flag=TRUE;

" J; w2 S, B! Z3 T; d6 o: r

　 　InvalidateRect(NULL);

　 　}

}

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

- V% ~0 j9 N( d/ ]

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

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

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

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

2 t4 G& b, I- j# m, S

pCmdUI －>Enable(FALSE);

if(Isconnect)

pCmdUI －>Enable(TRUE);

# Y" ~$ W* I8 V& h' U M& v7 Y" [

}

5 ?/ e3 w; f2 s" D" {. X. A" K

+ c# I+ [" i" I

再 窗 口 显 示 消 息:

' m5 _+ ~- w+ d% {4 L2 ~ J3 O( h

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

7 N F( z. J+ @& S$ m8 ?

{sizeTotal.cy ＋=20;

. J O9 j/ h4 |

for(int j=65;j

TextOut(10,y,m_data);

3 j) r# i' Y2 c5 n

y ＋=20；}

% K1 A/ X4 K( W% y. G

// TOD add draw code for native data here

}

2 m( b% `% V' k+ X; [

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

1 ^ [! I5 `* x5 i

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

( @! N& B" \8 E$ b

! p3 ^& M& A. q7 d0 Z( C. k

二、 客 户 机 程 序

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

在clientview.h 中 加 入 代 码：

＃include “winsock.h"

添 加 变 量:

5 y K( i3 C' T

CString m_data[1000];

1 C1 [. Q3 J2 @3 S7 g, I' v2 f4 u+ F0 k

HANDLE m_hListenThread;

6 V# k( K2 |& q Q6 \% t, a

SOCKET m_sock;

& _- p: ?- j$ ^8 o' G. {

SOCKADDR_IN m_saSrvr;

8 E# ?$ N* f- Y" `

BOOL Isconnect;

int count;

CSize sizeTotal;

BOOL flag;

8 C; S6 |- i# i5 W) j/ G

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

% n/ g' T3 t5 T0 g" h7 r) I& c8 ?

CClientView::CClientView()

{ // TOD add construction code here

Isconnect=FALSE;

P$ D" l p& {9 h- N- E: ^; p/ i

sizeTotal.cy=350;

sizeTotal.cx=300;

) a3 G: |# C3 H! v+ z0 Q

flag=FALSE;

9 P0 |( X7 W- l

}

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

. B' `/ w. N% Y# R

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

void CClientView::OnDial()

# l% O" m0 r, `9 ~

{// TOD Add your command handler code here

count=5;

if(m_bInitialized)

, e! M$ q7 n7 z+ K

{ AfxMessageBox(“Already dialing");

return;}

' K& P: S9 [7 F j! S

Cdial dial;

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

3 ` d# i& I5 L

m_saSrvr.sin_port=htons(5050);

int status;

1 L, _1 o! f$ z; `5 o% h& [

WSADATA wsaData;

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

: {* p* a$ i" x& B

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

2 p: b, l/ I2 ^( v o

{ m_data[0] ＋=“Succeeded";

' P8 }3 _) d; Y) y$ g9 k0 g4 [

m_bInitialized=TRUE;}

else

{ m_bInitialized=FALSE;}

! z& O) ]4 A4 a& [

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

) w& t+ u+ x) v) s" n

if(m_sock==INVALID_SOCKET)

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

% R# u6 k+ D5 f8 B- t

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

* X, K w; f- Q; [3 G7 k: ^" L

sa.sin_family=AF_INET;

# o- c' S& d* v7 z! }8 \( o1 c

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

sa.sin_port=htons(0);

if(bind(m_sock,(PSOCKADDR)

; [1 D$ w! t& Q4 g' C

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

8 `2 c3 R; e4 n! m b; \

(LPTHREAD_START_ROUTINE)Listen,

+ f$ @; l8 g# X0 ?8 ]8 @

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

if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

" ^, o, r5 [& j! ]( W

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

% I; v8 W0 m$ C& o! y( l( o: }, C

else

m_data[4] ＋=“Failed";

1 K0 a M! S. u+ |- V1 U' L

InvalidateRect(NULL);

( O. r9 G, q. x1 E( W7 b+ V

}

}

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

* h! s- g2 g; K, d0 O3 h

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

＃include dial.h

' H/ Q( Z& T1 f& J

/ X+ ^- {3 k# w; }/ q

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

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

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

pCmdUI －>Enable(TRUE);

if(Isconnect)

pCmdUI －>Enable(FALSE);

+ I1 [# i# T+ C4 ^

}

! j6 I3 F! U- q I' t( K5 p/ e

8 d; I$ g; k# R

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

! U5 j2 k1 U1 q( R" {$ k6 h, O% Z

long WINAPI Listen(CClientView ＊pView)

- G) _: ^7 L/ s

{ char msg[2000];

$ ]# ^% O. G* n! m

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

pView －>InvalidateRect(NULL);

}8 P o/ @0 D& H% [$ b0 g1 k

wsprintf(msg,“A: ");

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

/ K; I" X) M8 G5 n% ^2 S

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

int saSrvrLen ,nchar;

while(1)

8 l( D9 y+ p5 x" F2 h0 T6 e0 m

{saSrvrLen=sizeof(pView －>m_saSrvr);

% g T( m: ]6 O5 \

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

/ ?' Y5 \* N: ?, c7 ]3 Q

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

0 x5 }" I9 }) H* z% A, [4 V& x

if(nchar<0)

* Y$ N! u, M6 D

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

# m2 x h, R7 ]/ Q6 v; F5 Q$ J3 t

“Error in recvform";

pView －>InvalidateRect(NULL);}

& m5 N$ M8 l) N! F$ B/ j

else

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

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

9 E/ b4 B% p. h! L: m- X

}

1 N- b1 G. T! J# h

}

7 I) x* X+ s* T6 K+ g% h; k( B. Z

return(0);

}

8 l9 ^2 ?& |, M" n0 ~7 v/ B8 B

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

4 N0 ]+ ~" ~; y, o

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

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

% V; Q N: G# }+ S2 F1 S

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

9 P$ {' p8 q/ v2 N8 A* v! N6 M

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

下 的 网 络 中 执 行。