服务器与客户机互传消息

韩冰

一、 服 务 器 程 序

* N: Q' p9 h' I" B6 i

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

, s& m4 ` w6 E, `6 B5 k* J

在serverview.h 中 加 入 代 码：

＃include “winsock.h"

+ T' q+ R Y' |; Z. z

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

. O* D$ O6 a2 G) u2 q: ~

int count;// 信 息 条 数

8 c. Y! g" N. c! J9 J

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

3 T2 E" L. O- O5 X* S

char Hostname[260];

, N& i- a/ n( ]; o% ^9 h

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

SOCKET m_sock;

1 V) C6 Y1 \- f/ J: h

HANDLE m_hListenThread;// 线 程

% F4 W' L# n& p9 \# k

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

BOOL flag;

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

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

$ i3 j6 s* L! Y, L

字：

CServerView::CServerView()

{ // TOD add construction code here

8 z- d5 w: I/ n# z* D. H1 g

Isconnect=FALSE;

flag=FALSE;

/ C2 A1 P7 @, N6 V3 F

sizeTotal.cy=350;

sizeTotal.cx=300;

8 \ J4 _$ k2 _+ z

m_hListenThread;

2 B: a$ J8 H) T: c5 y2 ?5 d

count=5;

int status;

, J/ S4 \8 ~0 u

WSADATA wsaData;

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

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

+ n5 ^* E) c( c+ H5 x

{ m_data[0] ＋=“Succeeded";

) f* v+ e& U7 |! x( j

m_bInitialized=TRUE;

}

else

$ B. Q1 X- L9 F

{ m_bInitialized=FALSE;

* E/ v$ R1 p t! C

}

3 F) _- H+ P# a0 ~

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

if(m_sock==INVALID_SOCKET)

Y! J" m; C' E

{ m_data[1] ＋=“Failed";

}

; h& G6 V7 s5 ]: o$ S/ u# T9 {

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

sa.sin_family=AF_INET;

/ G- j- A8 B4 ]; d5 a; j

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

$ z3 X5 f! M: ~, q! a" m

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

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

) c1 S: m4 e1 k- f* ]5 t

{ m_data[2] ＋=“Failed";

closesocket(m_sock);

- i+ l' E/ u9 F3 w* u

}

) ~3 ?& R$ @" r2 N4 Q+ [* ^8 F' \1 L

m_data[2] ＋=“Succeeded";

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

% e8 s+ R r4 R9 {$ Y5 |# Y# t `

(void if(m_hListenThread)

: e; D+ \; K% K9 ~; _7 o! U4 t

{ m_data[3] ＋=“Succeeded";

4 T$ q; w9 E) Z7 A" v- f

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

+ s9 B' [. f! u& v: a0 q

}

else

9 @1 d# Q1 b3 e: p, a% q

m_data[4] ＋=“Failed";

# Q p4 V1 v6 Y2 ?7 G2 D

}

3 A8 S- B9 X+ ?6 x# C" v& A2 |

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

CServerView:: ～CServerView()

6 Z* k V. V# B; V5 Z

{ if(m_bInitialized)

WSACleanup();

closesocket(m_sock);

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

6 L3 ~0 A" l/ f# C7 g# r

}

5 \7 U0 J$ z; w6 A% \

0 q) [$ j) A7 C: h

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

) i) L8 w- l9 c9 b+ K/ U, Q

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

) d7 g' j/ | P$ \2 O/ ?

int nchar;

SOCKADDR_IN saClnt;

int saClntLen;

& [) Q" p& s& x8 s F* P' }! k

while(1)

7 X% y) W7 Q5 V8 v* e8 p' f

{ saClntLen=sizeof(saClnt);

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

* ^; P& X* d: z4 P) S# R

(PSOCKADDR) ＆saClnt, ＆saClntLen);

. W$ {8 Y8 `8 N9 x* V

if(nchar<0)

3 X1 D. _6 W. g3 q4 ~; H2 j

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

=“Error in recvfrom\n";

pView －>InvalidateRect(NULL);

( N- U. f* v" I% H$ a

}

else

. G0 E" ?' Z; J" N3 f- F

{switch(msg[0])

+ X4 r0 y* F4 I* d- M# Y

{

1 N1 x# l' A; B" c, Z1 {6 G

case ‘A':

x. m1 H8 S9 O0 }7 \! n, r* n; f! J

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

inet_ntoa(saClnt.sin_addr));

: b2 S: e! a5 B. j

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

8 B! [5 O, ^& r+ ~! z# I

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

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

8 C8 u3 w, w; K& C1 \8 `

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

( d6 Y9 P$ H% d, C+ f' I8 ]3 V" O

pView －>Isconnect=FALSE;

0 f0 g0 O, D' a: D3 l

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

＆saClnt,saClntLen);

* w! X) `8 M1 f

break;

- @ z" u$ y! A9 @- b8 `6 o1 G

case ‘R':

U* s0 r* P; [& r" t3 y) x2 l+ n, K$ m

saClntLen=sizeof(saClnt);

5 W0 X5 r8 \! ]. X. S, v( u {- n

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

pView －>flag=TRUE;

$ V2 |' C9 g, a

pView －>InvalidateRect(NULL);

( }! r0 ?9 i) |8 H3 v! ?

break;

. t6 n6 C% G# V& `! N

default:

break;

0 L) y2 E) B- A( c. u) @; \

}

6 `! B( j, @2 @! f. _9 }$ ~7 P ]/ j

}

# n6 t6 L+ S( D. I4 i

}

3 y9 v6 Z" k8 \: N+ M: l* b

return(0);

}

& |! W0 o, a1 i; z% C

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

　 　void CServerView::OnIp()

) e+ p! b9 O, y' H" Y* e

{int WSAReturn;

R2 L9 r+ V8 _6 x

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

$ d# g, s9 ^" d- L; Y# O/ C

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

2 u) ?/ S( S* ~+ W2 O# j' |

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

8 r% T8 D: j) q! i

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

3 v% e& X3 `7 P) p5 F

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

" Q" N+ y% K# \% X6 Y: x5 b

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

6 ? D0 t% { W, t8 H6 g- `) \" f

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

6 E& V4 _" P, w' L1 T

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

　 　CString out;

' t# T0 _! w6 @0 b( x# }

　 　out.Format(Hostaddress);

. w7 ?, _9 `0 N8 L Z- V+ m7 m

　 　AfxMessageBox(out);

& w2 c2 I- A6 _0 \

　 　}

) E7 B( q: Y. ^, G, o) B8 s9 r

}

}

- @. E% q0 ^' c# X2 J* C

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

: o7 d0 _: a; S. b6 J% M4 Y, D j

char msg[2000];

Csend Sendmessage;

- p+ z* F+ A: _( _# `" E1 R) ^! a% q

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

) W$ n0 [# D2 F ?+ ]5 @

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

3 y! {/ W/ r2 C% j

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

8 T6 P8 A3 r _+ [

＆saClnt,saClntLen);

4 ?/ O0 p5 S5 o+ M8 u$ I( n# }

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

　 　flag=TRUE;

5 i: w' T4 w" J' V7 R0 z$ c) `

　 　InvalidateRect(NULL);

　 　}

, B0 J. A1 J; x: o* X5 K

}

% l. F5 i+ z6 P. h1 |( u

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

- e5 Q+ ?' ?" d* k! @* b, @3 z2 e

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

' c9 L- X% @( K( o, X% N

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

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

( o3 k- m. z% X* f" L" w4 m

void CServerView::OnUpdateSendmessage(CCmdUI ＊

7 Y0 i7 i+ t1 q; z; _' @

pCmdUI)

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

: i* e2 s; a* `0 ]$ ?1 a. y2 h

pCmdUI －>Enable(TRUE);

" f4 H# C# \' L; v; E d

}

3 Y3 Q5 W' t# y. U$ i1 ~

再 窗 口 显 示 消 息:

4 m0 E& d. ^2 e6 f4 W% `8 g5 M# D

void CServerView::OnDraw(CDC ＊ pDC)

! Y* a& _; g# {$ r1 |9 P

{ if(flag)

{sizeTotal.cy ＋=20;

for(int j=65;j

" g1 ]+ S" m( |+ W

TextOut(10,y,m_data);

& J! p( h8 ?/ D

y ＋=20；}

// TOD add draw code for native data here

; @5 A j4 B) J1 Z! I ^$ d* H

}

, h( A2 r+ c- T) m" \

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

. P& o8 u0 S& p% z4 _- i7 z

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

# I% [( R) m, S }

二、 客 户 机 程 序

* w3 o. F% G# R) r

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

" N. t. I3 S& z4 ~

在clientview.h 中 加 入 代 码：

/ q/ j# j( s1 h

＃include “winsock.h"

0 h% l# m5 Q( l

添 加 变 量:

CString m_data[1000];

* L% V; y& `' _! _6 \4 K

HANDLE m_hListenThread;

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

w7 H+ e* T4 S0 W( |, h& A+ c: W

int count;

, V: T C& {( k$ v6 o% B' Z

CSize sizeTotal;

5 s7 h9 v5 f+ r" s* F* V; m+ x

BOOL flag;

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

CClientView::CClientView()

{ // TOD add construction code here

( ~) R* v' Y8 F; B1 \; l

Isconnect=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

- ~. A9 }2 ~9 |7 X

flag=FALSE;

}

& n0 L) |! d5 H+ j( K4 |# E( V

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

; t2 @; q) C1 f4 A

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

void CClientView::OnDial()

* R% @' `& i5 D2 l+ e9 {6 t" d2 K

{// TOD Add your command handler code here

* S% \( g/ h2 S7 h2 o( D: |

count=5;

if(m_bInitialized)

& o+ m5 ^* o( T' @

{ AfxMessageBox(“Already dialing");

2 Y/ o" Y$ {* u% ^" D- l

return;}

Cdial dial;

- U o. c3 _! K$ Q# I

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

; q/ ]% }! F6 {5 T& m

m_saSrvr.sin_addr.S_un.S_addr=htonl

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

) ?5 P1 O" k5 g5 ` @: O

(dial.m_HostAddress);

! F2 N5 \6 N* B" j

m_saSrvr.sin_port=htons(5050);

int status;

# x: F4 V0 v, i# q% I: [ y( s: T4 Q% Q

WSADATA wsaData;

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

) a/ \0 w( |0 k

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

{ m_data[0] ＋=“Succeeded";

) \- G6 d, ]6 Y8 @- N

m_bInitialized=TRUE;}

else

" z/ q/ f1 K! X o7 F

{ m_bInitialized=FALSE;}

% }$ h; Q& U/ p% W

m_sock=socket(AF_INET,SOCK_DGRAM,0);

( A$ O6 _. h6 C- F0 f) Z

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

: `8 p8 m: t( ]: k. a, s; `" V' u, i

if(m_sock==INVALID_SOCKET)

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

9 M( F$ w* D9 f8 U

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

sa.sin_family=AF_INET;

; I ~) ]) e+ V

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

sa.sin_port=htons(0);

% Z0 `! E. o3 ~ l0 g3 O1 M9 w( k; d

if(bind(m_sock,(PSOCKADDR)

. j4 M2 y, `6 [; [1 ?( P6 u) C

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

( p/ c9 e4 A F8 f4 {* @

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

m_data[2] ＋=“Succeeded";

- q) V1 B2 L( S% p9 s( m

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

unsigned long idThread;

0 r5 e/ x- M4 h

m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

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

6 N% ?6 w' s5 }4 v

if(m_hListenThread)

! T- M8 `4 k( w- i

{ m_data[3] ＋=“Succeeded";

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

else

* I6 F) [" m1 ~

m_data[4] ＋=“Failed";

InvalidateRect(NULL);

- R" f; R5 w6 D- \$ F

}

. h6 a8 F9 H% O% }2 K

}

7 W$ c4 J( U8 \" d S3 |0 q- R

5 A9 l- g9 p4 X* P2 P: ]! G

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

" q( e) A& `: Z$ P6 U, C2 W7 Q

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

4 \! G/ ]0 C; L/ M, |7 y( G

＃include dial.h

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

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

, p% y( m: p" G8 u1 r. ~

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

pCmdUI －>Enable(TRUE);

$ W, }$ d6 ]0 |

if(Isconnect)

e. D4 e* ~9 n2 C/ ?

pCmdUI －>Enable(FALSE);

. r. M8 |; J+ P

}

4 X' ~; t1 o& Y8 V9 f4 y0 W

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

long WINAPI Listen(CClientView ＊pView)

5 {0 d+ Z# B2 E/ N$ ^

{ char msg[2000];

! f0 I% l# M, `0 \" R; ^

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

" \; [) Z1 n& X0 \

pView －>InvalidateRect(NULL);

wsprintf(msg,“A: ");

2 I6 c4 y- x. I$ V" J

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

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

6 e& D! N4 ?9 D0 m# w' c" m3 G, G

int saSrvrLen ,nchar;

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

2 z# h% D3 ?7 k+ C# T9 H- t# O

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

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

if(nchar<0)

% T2 I' b- p6 d& c' x

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

“Error in recvform";

' q9 l% n& q+ M

pView －>InvalidateRect(NULL);}

else

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

6 O( l4 P' h8 Q2 y2 O/ g

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

; s* y+ }5 h* \ G0 W) o; M) J& G

}

: \8 {5 v- k) @

}

return(0);

}

+ s4 k5 H2 g& j, B1 J1 a

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

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

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

t6 h7 K! [. @$ C

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

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

5 F( e8 I5 u5 T) a7 o

下 的 网 络 中 执 行。