服务器与客户机互传消息

韩冰

一、 服 务 器 程 序

; e) D( T, c" k+ g' h5 w/ ]) X' |

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

9 \" }) |3 T* ^7 u2 A

在serverview.h 中 加 入 代 码：

* v" {% B: u& Q0 M1 T: U- S

＃include “winsock.h"

添 加 变 量：

) ]* ?$ C0 G1 H$ ^1 _

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

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

char Hostname[260];

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

SOCKET m_sock;

5 N' i$ ~& A2 t0 Z

HANDLE m_hListenThread;// 线 程

# { T& s! L7 i. @, B: W

BOOL m_bInitialized;// 是 否 初 始 化

1 W# Z* m% k6 b n

WSADATA WSAData;

BOOL flag;

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

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

' g3 c* D! `1 k1 _! P3 w& z5 y

字：

3 w2 w+ ^0 m1 Q; S. j- `( t

CServerView::CServerView()

{ // TOD add construction code here

T/ Z+ c$ j5 ]% ^) o7 e

Isconnect=FALSE;

flag=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

m_hListenThread;

count=5;

1 l# D) L5 q& H" ]* U

int status;

2 {) K/ Q2 ]7 N' M

WSADATA wsaData;

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

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

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

& y' F+ U1 I2 q. @5 h0 Y

}

0 |1 @" w6 K8 x& \

else

{ m_bInitialized=FALSE;

) p4 H/ y7 c8 G5 x" Z4 H

}

; S0 ]% r- f6 z' [! N

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

6 G q& g7 u; }5 Z' b) d- o7 X

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

}

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

; r- k' W; d2 x+ b) g7 ^

sa.sin_family=AF_INET;

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

/ k& A# r4 m* W6 V

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

: T% D0 P# r. e; Z5 y

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

- w% @+ Y0 t$ Y! l N) p* {

{ m_data[2] ＋=“Failed";

) O. y4 M# V5 M$ e$ U7 i. v: R* y

closesocket(m_sock);

! W3 l, W4 V6 g5 b

}

m_data[2] ＋=“Succeeded";

3 G z. t) B7 k: N

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

- i2 Z7 w @, i: H

unsigned long idThread;

" S" j' C! y/ L5 o. P/ T5 r

m_hListenThread=CreateThread(NULL,0,

2 c' |8 M$ m! t- t" e

(LPTHREAD_START_ROUTINE)Listen,

: U- d1 D8 Q- h) w% W( \

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

4 {3 ` h) X4 e; `( q' G8 L

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

}

else

m_data[4] ＋=“Failed";

}

) [- o8 W/ z0 O& v+ O: ~

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

CServerView:: ～CServerView()

{ if(m_bInitialized)

WSACleanup();

closesocket(m_sock);

( @8 A ^2 B; P( G% h- Y* _

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

}

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

% o3 N# c/ o* W* p

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

int nchar;

8 d k$ }. K3 J) e- k- p

SOCKADDR_IN saClnt;

int saClntLen;

while(1)

0 n9 f: L* ]* {2 c% w2 k5 o0 A

{ saClntLen=sizeof(saClnt);

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

{* W2 K1 z3 K! T2 ^

if(nchar<0)

- `- p! {8 q: C/ v

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

=“Error in recvfrom\n";

9 r. m8 x0 y$ G+ Y9 G, g

pView －>InvalidateRect(NULL);

# D% C/ J6 o; K$ _- Q- }7 V

}

else

6 c0 U b5 y) y* S. s2 s

{switch(msg[0])

{

case ‘A':

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

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

! p4 h/ |+ w, p* X

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

( U' t; v G; \

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

＆saClnt,saClntLen);

+ R- r6 Y a% M$ V

break;

2 q# I* ?' F' \ F& E; F

case ‘D':

) }- M5 i+ y2 z3 d

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

inet_ntoa(saClnt.sin_addr));

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

3 _6 n3 H+ [$ M) d9 n, z

pView －>flag=TRUE;

+ P h B e& T" c" n& B9 p" e# c

pView －>InvalidateRect(NULL);

5 G4 k3 H% E8 Y, v; k, W2 ?

pView －>Isconnect=FALSE;

: N) p1 v+ I# F& D+ u6 g

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

＆saClnt,saClntLen);

break;

9 m2 \& u4 J: X7 g/ p

case ‘R':

7 M" T& ^# \" _: f: ?

saClntLen=sizeof(saClnt);

* C& T8 c% k- p2 j3 [* n

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

1 d4 d' d0 e% ~2 P

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

break;

default:

8 I5 x# Z- Q& \# \7 l! D) e

break;

}

}

; R6 X/ r+ G' u& q

2 h1 K- C! j: W, x X! Q

}

$ u4 O/ g- {* Z( i6 d; [! L8 o) w

return(0);

/ C& X" ~0 v8 B) u

}

1 R; O: S+ G6 t2 J

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

; z& x/ e" Y* L8 ~# q' @2 ~# U

　 　void CServerView::OnIp()

: H; |/ N$ @* }: q9 L

{int WSAReturn;

& o% E( M- d" F. \

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

- B2 [/ X2 j. O9 @

if( WSAReturn == 0 ){

; ~: d0 ?% E. f8 @0 @3 o

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

: b+ ]: b- b1 c7 {0 h

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

/ I' D$ }0 C; E9 O8 G: a+ g

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

5 Q# ~8 E* q1 g, t0 R

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

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

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

0 G" f. q& w* w+ |9 \" t$ N

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

2 H' n7 k0 i) Y% j

　 　CString out;

3 Y9 |. c' F" l2 ?* S1 l2 [/ x9 T. H

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

　 　}

" ]' K) Q$ F' S6 X% g

}

, x' G9 R+ |; f

}

: E" n6 U7 V( R

" `6 L3 D' r# A

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

1 p! C) S8 o* Q* i( F' P

char msg[2000];

9 I. t5 {2 R+ }, |) l

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

( v+ {* B( C" v) i" g4 f

＆ ＆!Sendmessage.m_Message.IsEmpty())

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

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

$ ^+ S# W+ `! v L( j1 A) }/ t) F

＆saClnt,saClntLen);

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

" ]1 q% C2 u& O7 r+ [

　 　flag=TRUE;

4 \$ I& M7 }2 n; x( f" q* X

　 　InvalidateRect(NULL);

　 　}

}

) ]3 X) T3 K2 S

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

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

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

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

/ [( B: h9 }0 W( i0 a1 L1 y& v0 z' I

pCmdUI)

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

- |# h2 F0 W. T& I

pCmdUI －>Enable(FALSE);

if(Isconnect)

pCmdUI －>Enable(TRUE);

* y. A) ~1 A3 Q

}

7 s5 U, {7 O4 O( B8 d% c

?- Y0 J; H# d" e6 L' S

再 窗 口 显 示 消 息:

- [: p6 q8 @# \7 F( T

void CServerView::OnDraw(CDC ＊ pDC)

6 a$ P" |) \8 O. q/ G/ m* m

{ if(flag)

{sizeTotal.cy ＋=20;

for(int j=65;j

TextOut(10,y,m_data);

y ＋=20；}

// TOD add draw code for native data here

/ q! H/ ~7 \6 j, u- z$ T; b

}

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

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

, D* n8 v+ I Y7 }

二、 客 户 机 程 序

' i" |; K& Y- i% @; F2 Y" |3 u

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

' G }! G0 L; h

在clientview.h 中 加 入 代 码：

% V9 e8 |( U# {: g8 P) L% d

＃include “winsock.h"

, v a4 O: x1 @2 z6 V

添 加 变 量:

2 n2 S( f7 o; j# [9 J: a- f+ e

CString m_data[1000];

HANDLE m_hListenThread;

: e/ e6 Z, [! d: ^) I( J* z

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

4 |" a% `! r) V% l& b7 q9 J3 y/ ~

int count;

( O6 y6 O3 a# I @7 W

CSize sizeTotal;

- A% b4 j8 t4 Z% m

BOOL flag;

* j% Q% F: C+ _8 B! X

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

CClientView::CClientView()

{ // TOD add construction code here

# F5 ]% Y4 M3 l

Isconnect=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

9 \; r5 D) W4 C$ W8 S

flag=FALSE;

}

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

3 M& r1 s3 @. D

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

void CClientView::OnDial()

1 ?& J( I7 ?, D: g+ T

{// TOD Add your command handler code here

. B3 H( `* U& E5 f- Q

count=5;

if(m_bInitialized)

6 O/ o1 I" T1 P0 X% L2 \

{ AfxMessageBox(“Already dialing");

return;}

Cdial dial;

6 w g0 v$ |- ]& d. H/ r

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

! @. N' L q$ ~' N8 ?, m+ W- }

{m_saSrvr.sin_family=AF_INET;

- S: q- h$ b6 o# E

m_saSrvr.sin_addr.S_un.S_addr=htonl

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

1 t0 b9 N2 E5 f6 l

m_saSrvr.sin_port=htons(5050);

int status;

5 D3 T- S$ U1 |- o) V% O( \3 B7 A

WSADATA wsaData;

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

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

2 d9 F4 `, U( _$ L% q

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;}

else

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

if(m_sock==INVALID_SOCKET)

6 V5 ~2 g) O( V; E+ @( c+ L

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

9 _ H6 T5 n' ?9 z2 H! e \4 _

m_data[1] ＋=“Succeeded";

& p/ ^- u0 G7 i% h/ R

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

sockaddr_in sa;

! a+ \6 `5 M0 M# h" K9 ~

sa.sin_family=AF_INET;

: ]: X; k/ j/ Y/ V+ r$ a, Y; Q" S3 \

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

4 D+ ]" p7 s: r+ I$ x8 f

sa.sin_port=htons(0);

if(bind(m_sock,(PSOCKADDR)

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

3 S: q/ h! a! L# n

{ m_data[2] ＋=“Failed";

* _% j$ h' Z2 Z

closesocket(m_sock)；}

. i; M( f+ R- C/ ^. n

m_data[2] ＋=“Succeeded";

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

3 i. x$ B. O B7 y9 h/ |5 f5 E

unsigned long idThread;

# T4 S3 F5 i9 m6 V* Z3 l

m_hListenThread=CreateThread(NULL 0,

1 {, \: k2 j" d" H' c* e% H I

(LPTHREAD_START_ROUTINE)Listen,

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

7 ^5 c/ C/ _0 M

if(m_hListenThread)

1 \2 D# x8 x% r* y" K$ c% _4 r

{ m_data[3] ＋=“Succeeded";

; z+ ^ b& O; {4 l

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

5 _) Q9 E z6 `

else

8 ]' V% B3 o0 i3 _

m_data[4] ＋=“Failed";

P) d8 S# e7 z- |

InvalidateRect(NULL);

' B5 [9 O5 k6 I$ Q+ R; _

}

}

5 L# [, O2 w% h9 L( G$ b

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

7 x$ V( T( _: [" N K! O( Z

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

＃include dial.h

, @; r, u) d4 h/ R8 q5 I) H

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

; ]. `1 a+ m- s3 |3 N( @

void CClientView::OnUpdateDial(CCmdUI ＊

( Q4 I; L8 z, q* {: \" `% F

pCmdUI)

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

6 A# J8 a! a7 ~5 l

pCmdUI －>Enable(TRUE);

" {3 r; ^" Z. q: b: }$ t/ z/ O; }3 h) V

if(Isconnect)

% ?) {3 V+ F- ]

pCmdUI －>Enable(FALSE);

}

8 [! n N0 N X) a% ^6 @, T

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

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

v" T3 \- b9 H) M& r( o

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

0 K3 f3 `7 Y# Z% q" L: F

pView －>InvalidateRect(NULL);

. K) ]% Q, _( N1 k0 ~' Z

wsprintf(msg,“A: ");

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

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

int saSrvrLen ,nchar;

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

4 `# `5 I7 O/ V0 y& W6 c: a1 ]/ j6 b

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

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

if(nchar<0)

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

# l2 E j/ k/ G1 L/ l0 @1 E

“Error in recvform";

pView －>InvalidateRect(NULL);}

( M9 M9 Q9 J' V* s1 Y: S8 U0 ^

else

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

pView －>Isconnect=TRUE;

! B! u0 d2 J: D% P I

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

}

" V" X8 w% i8 e: U

}

; O/ |, Q" ]6 p

return(0);

}

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

/ n* \, v4 U( j& K2 u6 M( L

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

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

5 Q: c1 Q1 j, w, g4 a

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

' D9 \4 C/ B8 E, a5 y% ?

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

下 的 网 络 中 执 行。