服务器与客户机互传消息

韩冰

9 U' }" n. X: P5 v& j" P

一、 服 务 器 程 序

( I6 h* X: ^$ v

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

在serverview.h 中 加 入 代 码：

＃include “winsock.h"

/ }5 {, f* U5 `& ~

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

7 k; ~. C. V, E% G, y

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

( Z( H' Q4 ~9 H2 v' E) P/ i2 F

char Hostname[260];

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

SOCKET m_sock;

HANDLE m_hListenThread;// 线 程

7 K0 C5 [ h g6 w, ~- a0 F3 ^

BOOL m_bInitialized;// 是 否 初 始 化

Z& r9 j; P1 I6 N9 v( J

WSADATA WSAData;

* m3 j8 m' N( r# D* J8 z2 H$ q

BOOL flag;

SOCKADDR_IN saClnt;

/ J3 A2 N5 y: a+ ~4 N

int saClntLen;

: ?5 o& U' N- ?. D

BOOL Isconnect;// 是 否 连 接

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

字：

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

& \' ~" H: d" C: P

flag=FALSE;

sizeTotal.cy=350;

- K) @& u; r: i2 A

sizeTotal.cx=300;

9 W0 a3 d& N$ ?) `5 F

m_hListenThread;

count=5;

int status;

) _, e: V- O8 r- c+ a

WSADATA wsaData;

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

& V# W. g6 `5 J7 I# i9 `' u

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

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

. } A$ N1 R0 a k

}

else

" O* D4 n; K, ?- W& [, [6 e8 t

{ m_bInitialized=FALSE;

}

}' |; R- j7 h

m_sock=socket(AF_INET,SOCK_DGRAM,0);

. X* D6 }: l) |7 N; o; L1 `! u

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

! E) \: Z8 d, ~- `! k2 j! l6 G

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

}

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

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)

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

{ m_data[2] ＋=“Failed";

) Q3 r% W% t; K4 O

closesocket(m_sock);

# H; f, T5 Q+ O

}

m_data[2] ＋=“Succeeded";

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

' k' a, ~3 }, S+ o; ?0 y

(LPTHREAD_START_ROUTINE)Listen,

3 Z# l. J" _" g. z

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

8 q& C$ A# M! @4 f+ ^

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

9 V6 j6 c- ]! ^- k6 ^, p

}

- r7 N* t1 @% j/ F: l% K* q9 Z

else

6 K- d" W2 r" {- Z

m_data[4] ＋=“Failed";

I% S$ @+ K* p5 Q

}

7 u# T7 S6 P4 M& t

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

0 i( M( ?; W" m- T% `

CServerView:: ～CServerView()

* }0 P1 @+ W) A0 u3 S& y% m/ A

{ if(m_bInitialized)

WSACleanup();

closesocket(m_sock);

% H) J# r7 N- @3 b2 O9 I

if(m_hListenThread)

$ u: {: Y2 a& H9 B P- N" ]

::TerminateThread(m_hListenThread,0);

}

, u7 H! D( v2 r/ \9 |: D5 `! A2 w

. L# ?3 b9 P3 z8 X+ |$ [9 z! U

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

long WINAPI Listen(CServerView ＊pView)

8 i5 O% w1 Z# V2 s1 {

{ char msg[2000]=“";

# X- t0 [. O. z) p `" ^! X2 r

int nchar;

SOCKADDR_IN saClnt;

int saClntLen;

while(1)

{ saClntLen=sizeof(saClnt);

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

if(nchar<0)

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

=“Error in recvfrom\n";

8 X% ^9 b3 ~/ d& X. d: [

pView －>InvalidateRect(NULL);

/ p. R* i( r' L6 e, B# \

}

else

/ ]5 m( n- _( ]9 V+ u r

{switch(msg[0])

{

case ‘A':

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

/ W/ Z# Z; H9 c

inet_ntoa(saClnt.sin_addr));

0 m1 d3 U4 U' u( Q N4 Q: Y

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

/ V: k; ?& O7 a* i! x v- S) A

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

. u- f; g* q) C# h0 r0 j

pView －>saClntLen=saClntLen;

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

; u2 q- k% N a* W J5 v* D5 u

＆saClnt,saClntLen);

) n+ @1 z, v# L' O- `: ]

break;

& {1 O+ e" I- ]4 B' A4 K

+ J ?8 `+ a! q! A: d0 K* B

case ‘D':

% |! C: i' W7 H; q( K: O) f% _

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

inet_ntoa(saClnt.sin_addr));

7 G" R! v2 w3 H/ H( C4 U. U L- m

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

! n/ K p9 }4 U: O: X& K6 s* G

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

/ o) L6 W) ^' f8 e1 n! g

pView －>Isconnect=FALSE;

X1 C% {6 V' q6 t6 T

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

( p' O: U5 O. i

＆saClnt,saClntLen);

& D% f/ F7 A% q! F4 p9 p

break;

7 L; i8 \2 {( s/ n, @& s3 b

case ‘R':

5 \1 _% J( a" d6 z" }6 {3 K

saClntLen=sizeof(saClnt);

7 `6 D2 V) H+ J# g2 `/ w

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

pView －>flag=TRUE;

* c3 P7 S, e4 W" h' I# q9 K0 R

pView －>InvalidateRect(NULL);

break;

@. L r n: m: o& G& N `

4 _+ s/ }0 o8 z. ]; Q* u0 e

default:

break;

3 K: ~) t# M2 t8 W

}

}

9 T* H: l, u4 y

- E5 E& s4 o( J7 T' L# C3 G/ Z

}

return(0);

}

! o# m) x+ O" V( d9 ]

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

! A9 V' P3 k0 S

　 　void CServerView::OnIp()

{int WSAReturn;

% k" w S3 D% H; U6 ]4 a

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

5 ^1 D( Q- a5 [) {: f! W& C. N

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

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

" J% U/ W1 d% u, v X

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

9 N7 S; w( ~7 Y6 F" @! ]

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

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

　 　CString out;

0 ^3 @- W' d7 S! u. @& A' e" x

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

1 n4 X" f% G' R, K4 \

　 　}

! j- i0 c' ?' F0 G5 c

}

' r5 r. X! H' w0 t

}

6 G: k+ {1 @' L2 y! W; A

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

char msg[2000];

) w1 v& e1 W: d2 Y! I3 U# B8 z5 n

Csend Sendmessage;

* ^; M2 B' Q+ p" E" W3 u# g

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

8 R9 r! d/ a) s' E$ f5 F0 q5 Y

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

3 P5 Y6 m1 |/ U. n6 C5 ?

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

＆saClnt,saClntLen);

0 D3 ~' s' W0 L1 C3 r" k

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

( [ o5 F8 q6 @

　 　flag=TRUE;

4 T) A8 _( ] k/ ?( A2 R

　 　InvalidateRect(NULL);

; h; z) L% M: o% m6 w( U

　 　}

}

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

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

$ v) s6 n3 G, J8 h4 Q1 A7 T. e

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

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

& s; V! R6 g, M% ~* k

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

) O, N6 A: [* N0 W$ A4 o

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

pCmdUI －>Enable(TRUE);

" |4 v. r& n; C

}

0 _3 w9 g- ]: n; M+ a, l

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

{sizeTotal.cy ＋=20;

, X$ V$ ^9 c0 J+ y' `

for(int j=65;j

/ J# p, J3 u% ?3 f* S5 C% \

TextOut(10,y,m_data);

; v' _3 \+ Q$ |: [7 u7 V

y ＋=20；}

// TOD add draw code for native data here

}

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

/ d; @7 o2 O$ q' ?' D) s) q" ^( D

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

1 z! Z# p' i+ b: U. e. M

二、 客 户 机 程 序

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

7 N% r7 b6 U' |; t5 X0 r, `

在clientview.h 中 加 入 代 码：

＃include “winsock.h"

添 加 变 量:

# F z8 \& n; x1 m) o7 X

CString m_data[1000];

_ X, W% [7 ~2 D% K. {

HANDLE m_hListenThread;

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

( @. t2 B$ z5 ]$ Y+ E6 c; d2 D0 w( }

BOOL Isconnect;

int count;

6 |) E- G T8 Y7 M! U. K. `0 Q) r

CSize sizeTotal;

: n- L+ s4 H P; w9 k; U/ n! @6 I

BOOL flag;

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

CClientView::CClientView()

{ // TOD add construction code here

Isconnect=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

. p- z3 e" [8 n# J6 [9 _; T1 J; z

flag=FALSE;

}

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

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

void CClientView::OnDial()

! B4 E" H1 U9 Q/ W$ c

{// TOD Add your command handler code here

count=5;

) G0 @& D5 e( r# g' U

if(m_bInitialized)

$ {7 O: f6 A. E$ u' Q7 u* V# M

{ AfxMessageBox(“Already dialing");

return;}

6 u7 P( r. h: ?( ]! m

Cdial dial;

* g$ Q) P/ \) ?0 r" @2 ]

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

) u' u, M9 Y. W `2 ~5 g

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

$ l @5 |! V6 }$ t& J# r6 U

(dial.m_HostAddress);

* R. d3 k. p! }! N5 I6 u- A

m_saSrvr.sin_port=htons(5050);

+ O; P, ]9 \; \' K4 S* Q- w& ~5 d

int status;

) x0 t4 ^- X# s3 K3 y

WSADATA wsaData;

$ G" w7 @$ p+ [* X/ P1 q- p; ?

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

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

{ m_data[0] ＋=“Succeeded";

. v% `4 B2 B* {- i& t, b& ~

m_bInitialized=TRUE;}

else

" z# b# p+ U/ B' j* k0 P

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

, _3 V @4 A* @

if(m_sock==INVALID_SOCKET)

3 C+ l" I$ ]7 C6 ~

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

( i- r/ A- p$ E7 Q |& Y

m_data[1] ＋=“Succeeded";

: N+ E, C! G) v3 Q) e" S

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

* M% x' e+ l" J; X3 y6 {& `

sockaddr_in sa;

7 ~2 y1 u* J0 p6 `

sa.sin_family=AF_INET;

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

sa.sin_port=htons(0);

F' Y' e6 A* `3 |. c8 W N

if(bind(m_sock,(PSOCKADDR)

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

( b) ]) k; L) {4 N

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

' N2 b1 F& `* u1 t/ I- F

m_data[2] ＋=“Succeeded";

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL 0,

8 f; X; r8 v. Z! ?

(LPTHREAD_START_ROUTINE)Listen,

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

. A a. v1 _; P

if(m_hListenThread)

( J2 E y. u" c3 P

{ m_data[3] ＋=“Succeeded";

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

else

- Q+ Q; r5 j6 H

m_data[4] ＋=“Failed";

7 }8 Q& t% H1 \1 z% u- e

InvalidateRect(NULL);

}

}

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

. ]) w* {% j+ o

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

＃include dial.h

& \1 L! F& G- j" [+ _

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

; b7 a% p2 n& o- f

void CClientView::OnUpdateDial(CCmdUI ＊

; v2 t; `/ i+ S

pCmdUI)

- p9 C q/ V' W# [1 k

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

; c& b9 a! Q: d# n- c

pCmdUI －>Enable(TRUE);

& q; _7 y( I' k1 w- O/ O+ l. ]! n

if(Isconnect)

5 V: v+ s' C- h/ h

pCmdUI －>Enable(FALSE);

}

' f7 ]1 R9 P# j! I' w3 R% q# W

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

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

4 t- a4 r1 `: C) A" \" q

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

8 M) `2 Q' F! }" N8 p& j

pView －>InvalidateRect(NULL);

wsprintf(msg,“A: ");

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

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

2 C8 W2 d; j$ z) v' B6 l3 k

int saSrvrLen ,nchar;

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

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

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

if(nchar<0)

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

“Error in recvform";

: E, Z) |8 X/ d' R* O' m8 {1 K

pView －>InvalidateRect(NULL);}

6 N4 A1 X" w2 M- p$ f/ P; `

else

$ `8 Q' {/ s, l2 ~6 T1 W

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

pView －>Isconnect=TRUE;

& A+ c, m7 U0 R0 a* W# C( Y( } K- s

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

/ o. y5 w3 k7 z8 P& v

}

}

return(0);

}

0 z6 y6 h7 J1 h0 @: i- }$ u) p

- L* m4 M1 Y& \( K$ } d

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

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

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

; K1 s* \! l8 A3 ~. V- V4 A: m

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

/ S$ i; j+ i$ J& I2 k$ g

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

下 的 网 络 中 执 行。