服务器与客户机互传消息

韩冰

5 {" o+ D# B& k+ y( b5 [9 H* D; D1 W

一、 服 务 器 程 序

5 _6 Z% J' U( R7 Y' g

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

# [# ^$ B+ X: |& L# q

在serverview.h 中 加 入 代 码：

＃include “winsock.h"

3 @- v1 I% s: j

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

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

% r6 O" H8 Y" `# D

char Hostname[260];

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

SOCKET m_sock;

% O, S9 T1 _' z: N y

HANDLE m_hListenThread;// 线 程

: D: b! x1 S1 b z8 o

BOOL m_bInitialized;// 是 否 初 始 化

' J0 H% M7 ]; A9 g' K9 c2 h

WSADATA WSAData;

BOOL flag;

: X" U' w( Q/ c2 R3 L9 i7 h4 W6 a

SOCKADDR_IN saClnt;

int saClntLen;

3 t) ?& @, q9 y( j; V' |

BOOL Isconnect;// 是 否 连 接

/ H! V/ H6 b @! s/ q

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

字：

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

2 U1 e8 z' z: e! H

flag=FALSE;

; o& ]* S; C; F

sizeTotal.cy=350;

sizeTotal.cx=300;

7 U0 [* I7 c2 t6 n) r

m_hListenThread;

+ c# F. q5 ]3 M g: R. G

count=5;

, ?) |" i9 g, w: ?6 {; ^" h

int status;

WSADATA wsaData;

% U, z# }0 I8 e

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

1 }( h2 S+ h- m2 k( Z+ ]8 \

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

, `. x+ P9 F0 i a& K

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

! l# z1 L, J+ i% d) h$ |

}

else

& |- s+ g2 C( H8 W5 o

{ m_bInitialized=FALSE;

3 p" n* }% Y' O u+ t2 w8 ^# n

}

m7 B' q- |! @% f/ [& F z

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

. @. ~4 U5 L( D4 B# L R

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

}

m_data[1] ＋=“Succeeded";

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

) N, L- t$ M) E" u$ v2 e+ a

sockaddr_in sa;

) h k6 S; E" {: |2 {: v- g

sa.sin_family=AF_INET;

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

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

, x( c2 h( \7 u$ r( c7 e. Z3 T

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

2 b% S+ A8 X7 i1 \& ~8 r

{ m_data[2] ＋=“Failed";

; `4 A! Y0 [" u5 J; I" j

closesocket(m_sock);

$ Q- o$ N9 t+ O+ `2 \+ F6 `6 G

}

m_data[2] ＋=“Succeeded";

6 M p+ U2 f8 k3 @0 i, z y

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

6 |: |" T2 ^) L& h4 Q

unsigned long idThread;

- }; M& ]) P) E% J5 Y3 a7 l; p

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

- f' e+ K% Y5 R& a6 g/ i0 u3 m2 b- n) a/ i

(void if(m_hListenThread)

2 S- q- |3 I6 O3 s- z0 l# C3 N/ E

{ m_data[3] ＋=“Succeeded";

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

) A8 W4 ?2 W+ l; k4 ^! `1 a

}

else

m_data[4] ＋=“Failed";

1 {) w B* u. f0 ?( ?) [

}

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

CServerView:: ～CServerView()

2 F/ s% z* F3 F. Q. V9 X7 T# k& T

{ if(m_bInitialized)

2 g) I/ h% i) I, C

WSACleanup();

" h4 } j# c- R7 ]5 P- ?5 F( t0 N

closesocket(m_sock);

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

# m0 J5 i/ m. o6 r) P, X# [

}

2 l% T9 {* ]5 m8 l5 E! l% N+ Z

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

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

8 p; P" f$ h' d& H' z0 o' @4 Q7 R

int nchar;

- U6 o. r! e. U1 ?

SOCKADDR_IN saClnt;

int saClntLen;

9 K4 w1 f; Q! `1 M z a

while(1)

{ saClntLen=sizeof(saClnt);

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

if(nchar<0)

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

& `7 `5 C/ n" m" a

=“Error in recvfrom\n";

8 U j, f7 d% C6 t% j( ]

pView －>InvalidateRect(NULL);

}

4 f1 P2 @( t( V4 n$ X4 }6 {$ d2 }

else

8 y: I8 U# p9 t, D3 {! T3 Z. g2 M" m. D

{switch(msg[0])

) o) |: i4 k) ]* u

{

case ‘A':

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

inet_ntoa(saClnt.sin_addr));

' H. {9 s, X7 V6 C* B

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

* y. H+ Z& G. x0 ]4 q4 @8 ^

pView －>flag=TRUE;

1 P1 l2 g$ G" s$ Z4 [5 _

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

4 _5 E5 m. t0 r( U# C# d6 {4 C

break;

+ n3 L+ Y" q: f

case ‘D':

& \9 i+ h6 ]" a% P: L

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

& g1 L% ?0 h2 a* O

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

1 Z3 d' F8 l) q* G1 g; t

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

＆saClnt,saClntLen);

" \5 R* X; D3 {8 o% s

break;

case ‘R':

saClntLen=sizeof(saClnt);

4 G9 e5 \" y$ r% Z( e

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

2 p$ q. }1 `6 A% Z* f

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

break;

* A* y; k& l. Y, c6 r. a/ ]

default:

5 S/ g, T7 r7 m/ J' K7 [

break;

}

& ]' ~4 k& x, X9 w2 ]0 k

}

# U+ G) y. `+ p9 G* c `

6 w" L7 n* n" M

}

return(0);

7 x& E& [/ E& }8 L

}

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

' p3 c& w# p/ ?6 @. t6 t

　 　void CServerView::OnIp()

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

- g. n, L3 I+ J9 @+ J! l( ?' P

if( WSAReturn == 0 ){

# V# X" g, l3 Z+ A( J) M7 y

gethostname( Hostname, 260 );

! Y4 z1 G2 F- t$ {

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

/ ]9 @: Q, B+ [: s9 ~; X

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

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

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

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

3 X+ A6 E' r+ K8 E

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

4 O, R" z3 o7 ?4 H

　 　CString out;

0 }& ?" t1 v7 x' t; X( q& c& \

　 　out.Format(Hostaddress);

( y o/ V: p* d, Q( I; j

　 　AfxMessageBox(out);

　 　}

}

/ H7 h3 t) ] l( _1 l) b0 L8 d& F

}

, q& k! u3 P6 d) Q2 o% I

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

: n; }2 }3 S, n; F. j8 f

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

- `, f# N/ s& l A3 l

char msg[2000];

: o( k( G7 s' J/ S0 J& x3 c

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

: P8 K4 R Z1 G$ Q! c

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

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

& [ B9 E; J7 ^( E+ e0 b' t

＆saClnt,saClntLen);

) B# e/ a1 B+ a+ K* s

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

　 　flag=TRUE;

　 　InvalidateRect(NULL);

Z- S/ T L& o3 U. w3 f m

　 　}

m( a7 Z5 n- H1 O7 `# k9 H

}

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

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

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

. q- l3 ~" Y! B7 D' {

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

8 F. u, K& W0 k: E2 x7 E2 g

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

) H8 r$ F- H5 G* x: O0 c5 N

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

& Z% P0 }; D1 V2 }

pCmdUI －>Enable(TRUE);

}

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

6 _6 C# g' w% L: d0 `

{ if(flag)

{sizeTotal.cy ＋=20;

for(int j=65;j

0 f0 d" `4 {% G; c& H$ D0 d# ?" l

TextOut(10,y,m_data);

" u/ a# m3 |: f, L( e r

y ＋=20；}

% |( K8 S M. H5 m

// TOD add draw code for native data here

3 R- R V% I; f3 M$ g

}

8 k( m/ T+ Y+ K/ S' u4 I$ f

) ]- I" _0 ~; B# y

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

: C$ W+ T8 r N# n; u6 W# V7 J

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

3 h( J- i9 S# q B9 N

二、 客 户 机 程 序

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

在clientview.h 中 加 入 代 码：

6 G: r. w+ j) F' h. N

＃include “winsock.h"

添 加 变 量:

CString m_data[1000];

% x' ?6 x; J' |) B

HANDLE m_hListenThread;

* v% S4 X8 J; Y& i q

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

int count;

CSize sizeTotal;

' s! j5 j K6 e* j m* u

BOOL flag;

& ^1 u% ]- O. K! a

( u* ~: a# z0 @

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

CClientView::CClientView()

{ // TOD add construction code here

1 p- j; W) A# q9 r0 _7 D( z) K

Isconnect=FALSE;

/ G, p1 ~5 G0 B7 l

sizeTotal.cy=350;

5 n" u- c' `- w! J) \% r' t

sizeTotal.cx=300;

flag=FALSE;

}

+ d* U+ N( h, e& [0 t+ U0 d3 a

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

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

void CClientView::OnDial()

{// TOD Add your command handler code here

count=5;

- s0 Q, d/ M# b

if(m_bInitialized)

{ AfxMessageBox(“Already dialing");

return;}

f2 d+ H9 F$ i

Cdial dial;

if(dial.DoModal()==IDOK

% j7 A) l" f- ? Y. A

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

9 `, Z, B! s7 W+ `9 q" q* v

m_saSrvr.sin_addr.S_un.S_addr=htonl

% N2 J4 h& s; d' I! W

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

m_saSrvr.sin_port=htons(5050);

int status;

% _6 b0 b# x" h( ?& E, ~

WSADATA wsaData;

$ r/ b! f! F; \) _" X! [

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

! b' c2 L& X( H: N/ |6 S( j

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

{ m_data[0] ＋=“Succeeded";

0 A9 t3 z: j9 b( G/ H; g. o& f# g) z+ A

m_bInitialized=TRUE;}

else

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

4 j! @2 O2 ~! N; p

if(m_sock==INVALID_SOCKET)

6 B) z' G! t( F! k. ^

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

/ O5 f7 @5 P3 _0 W- x; T

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

sa.sin_family=AF_INET;

9 A* f; }6 d3 E# o

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

2 v3 y5 n, V0 a2 U5 v" h. g8 [& o' e- d

sa.sin_port=htons(0);

if(bind(m_sock,(PSOCKADDR)

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

- _3 d7 W' U4 t/ q3 d5 T

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

v- ?( ~& w h$ K! @* M2 h" Y

m_data[2] ＋=“Succeeded";

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

unsigned long idThread;

$ U2 i7 r8 S7 K: v5 K! m" r

m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

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

if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

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

else

m_data[4] ＋=“Failed";

InvalidateRect(NULL);

}

, [( m2 {$ t; A% o

}

# B( x$ ?" R- M: u2 e8 O) |0 m; w

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

, f) |" E" q# e

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

2 _# k- o" \7 c% q' i

＃include dial.h

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

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

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

pCmdUI －>Enable(TRUE);

if(Isconnect)

; A1 w! C- T% j: c$ }5 a) E

pCmdUI －>Enable(FALSE);

}

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

long WINAPI Listen(CClientView ＊pView)

7 a+ z' q: [% }5 \! j

{ char msg[2000];

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

pView －>InvalidateRect(NULL);

2 W% e+ V# F, x$ k& j; k z9 G$ O

wsprintf(msg,“A: ");

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

, s% z5 L: f) |% K! P# Z' n! {( e" t

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

( o8 {8 V" ~* p8 H

int saSrvrLen ,nchar;

+ X0 {8 {- s1 E( Z( H

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

6 j7 x( W0 N7 Z/ a, l

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

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

! h/ [3 M/ ]" L) ~) a+ }4 `

if(nchar<0)

; G; @/ n9 |7 q1 N0 {" V

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

) W# h: ~# [8 l; i+ [& A

“Error in recvform";

pView －>InvalidateRect(NULL);}

else

" u! i; I6 p6 c1 W# O2 J# I

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

7 l+ O. U& z9 F X& J

pView －>Isconnect=TRUE;

: s3 h) Q4 Y7 {$ O6 s' f

pView －>flag=TRUE;

# U* J! X$ D- y, h$ L2 O

pView －>InvalidateRect(NULL);

+ W0 g. C ~2 U( |: Y" X2 t

}

+ S" c5 G" ^$ a6 r4 B; M

}

* T5 d* w; k6 i0 a/ \! o# U; ?0 Q/ Z

return(0);

}

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

5 b u5 N4 G* y5 H. b& K

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

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

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

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

' _- H& A) z+ ?* D* n$ A g

下 的 网 络 中 执 行。