服务器与客户机互传消息

韩冰

) `% O. @- |# z

一、 服 务 器 程 序

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

/ E6 L6 y" M$ X3 X

在serverview.h 中 加 入 代 码：

) N1 K5 P: P0 u' o; i2 q3 g, I

＃include “winsock.h"

4 ?/ x$ |! @0 g7 v& l7 q7 { s

添 加 变 量：

( [2 ]& R5 p w5 A

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

; F8 c+ t, f9 o( I- l# X# Z$ U9 Q

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

- T5 q U. l" _# M% G. Y

char Hostname[260];

( m* l- q v2 C

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

SOCKET m_sock;

, Y; [; W: P6 c; e; d4 d

HANDLE m_hListenThread;// 线 程

) v' T9 L7 { q& ^

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

. e" U, a0 ~, W( \4 f; D/ t- d

BOOL flag;

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

" ]# q# c9 h6 S: }& Q

) W3 d5 l: T) f* i) d

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

c! |) X, a4 j9 r

字：

CServerView::CServerView()

{ // TOD add construction code here

& g4 h, K& `! I. i' Y5 \$ g$ X

Isconnect=FALSE;

flag=FALSE;

9 M) g. R+ ]4 u0 E0 ^; ?0 Q8 D* E7 }5 ~

sizeTotal.cy=350;

/ _. h9 Q+ W' V. j! p

sizeTotal.cx=300;

8 U% ~. N: R! C2 Z2 k* a

m_hListenThread;

8 j7 O _# Q2 E: I0 c1 Z6 D% f

count=5;

int status;

WSADATA wsaData;

3 E0 O# u; V7 o6 L2 v

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

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

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

/ X/ g1 v+ d6 d! w4 E5 w" [

}

else

$ \7 ^1 x' \( e+ I; L8 N0 z; E

{ m_bInitialized=FALSE;

, Y& o5 y, N2 [( I. q! G2 n i+ h

}

6 @ h1 l8 i! Y0 d) a# ]1 p6 L/ K

m_sock=socket(AF_INET,SOCK_DGRAM,0);

# o3 d2 N5 w0 X* D( H+ [, Y, ~

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

& i z; r1 z7 b! Z$ n. k+ g5 D

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

* `1 F6 M, ?) Q8 F4 d( i2 a- K

}

5 d; s" {/ I# {, x7 @

m_data[1] ＋=“Succeeded";

: O" G r4 ]( `' @! F! c! i

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

sockaddr_in sa;

sa.sin_family=AF_INET;

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

C6 \& p$ ^# _

sa.sin_port=htons(5050);

' {+ R* }. s+ F1 ?; g* A- F

if(bind(m_sock,(PSOCKADDR)

! X1 P7 T+ {/ p A

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

% o5 u% {: m* j1 J1 }' C

{ m_data[2] ＋=“Failed";

8 L5 l1 M, C! Y9 ~+ Z5 F

! L% _3 }/ }* K2 M! P- G

closesocket(m_sock);

}

m_data[2] ＋=“Succeeded";

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

) ^/ }, K7 w3 ]6 u+ A

unsigned long idThread;

7 R* V" | M0 ~! I* {& r" T& F

m_hListenThread=CreateThread(NULL,0,

# u. I5 T4 n5 E& m! `4 ^3 |

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

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

}

else

3 ?* R. j% }- d/ `

m_data[4] ＋=“Failed";

# l. L, S! y( X1 W8 A C% \

}

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

CServerView:: ～CServerView()

9 L, }- P/ N! \1 o8 W" r+ n

{ if(m_bInitialized)

/ j: p9 x! p* r& T

WSACleanup();

closesocket(m_sock);

if(m_hListenThread)

6 j8 ~0 R! ~) {* m

::TerminateThread(m_hListenThread,0);

}

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

long WINAPI Listen(CServerView ＊pView)

~, E! W2 T( Q) ]- D Y7 M: d y9 ]

{ char msg[2000]=“";

int nchar;

D, Q- w1 w1 D$ }5 E! [* V' Z

SOCKADDR_IN saClnt;

3 k6 R5 k; [% n, C' B9 w/ r

int saClntLen;

. i: |" F' b( v; s" w& J

while(1)

{ saClntLen=sizeof(saClnt);

7 n3 p, r3 S u6 e

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

l- W- E/ ^% n3 _4 t

(PSOCKADDR) ＆saClnt, ＆saClntLen);

' s4 s5 Y9 u+ \4 j1 N: H& ]

if(nchar<0)

6 d) ]8 h5 p! b" Q" W7 i6 Y/ j- i

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

=“Error in recvfrom\n";

pView －>InvalidateRect(NULL);

; R7 H5 G5 Q" g0 L9 S

}

else

{switch(msg[0])

: X) Q+ d/ a6 w" T

{

case ‘A':

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

inet_ntoa(saClnt.sin_addr));

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

1 F5 S- G/ K9 {' n

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

9 }2 _' x8 }0 m

pView －>Isconnect=TRUE;

4 z+ i" ~$ W. q0 A& `7 Y- q/ v

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

7 Z' R8 A9 N. _1 Y3 @; W

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

＆saClnt,saClntLen);

break;

?$ [% n+ \9 |

case ‘D':

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

inet_ntoa(saClnt.sin_addr));

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

8 a( w& X3 S$ ]" ^1 h6 |9 B

pView －>flag=TRUE;

- d7 q' _% x/ O/ e4 u: ]4 I5 c3 `

pView －>InvalidateRect(NULL);

) I! |# K5 Z$ u( x) z

pView －>Isconnect=FALSE;

% b9 j! J8 F% Y5 u' N1 g

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

＆saClnt,saClntLen);

9 K6 U: H: C5 S& V1 y0 o

break;

; g. q& ?5 s- Z. P8 X, Q

7 l# q* S1 U- F+ _( Y

case ‘R':

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

9 ~4 }# z. l4 R, V! {) ]* u ~

pView －>InvalidateRect(NULL);

9 n4 V! g' c! W% m. w. m1 ]

break;

1 l( _8 m4 F0 r

default:

9 T8 x/ w6 Y/ z3 C# _5 C

break;

}

}

+ t+ \3 J4 p+ ?! l; |' ^/ m2 g% x$ c9 t

9 i( J# M8 E8 p, n7 i

}

return(0);

; n8 [7 G5 h9 t9 |0 E0 A

}

' u7 Z& j; i f1 n# h

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

　 　void CServerView::OnIp()

{int WSAReturn;

$ E3 p" ?2 j0 ^/ [! ~% t! P

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

1 J. V! O, S, H) x. q: C( E

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

6 d0 x; @3 T2 H

if( pHostEnt != NULL ){

6 Q6 B& T2 u4 |; w

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

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

' V% m+ I7 k s% P/ P

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

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

. g( m# e0 c- c3 u

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

　 　CString out;

. a& X. l$ W: J; N; K6 ]

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

' d6 @: x( \' |% A# B) N. O

　 　}

9 \7 c. J+ l* J+ h' \

}

}

0 m( w' O' w) r* O: D7 U

" Y$ p1 } w) R. `/ I% w

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

2 T) D, r2 ]+ N! N$ u% z8 g# N

char msg[2000];

/ N9 Q8 N1 l2 U# ~, q2 t

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

$ a5 J) G6 q4 @ E7 F0 o4 X$ c

＆ ＆!Sendmessage.m_Message.IsEmpty())

+ q: f, A& E( l+ G/ B7 {

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

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

* Z0 _$ @' t5 L0 ~% k

＆saClnt,saClntLen);

) _! t! [* C6 K0 s1 x# W) F4 M7 O

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

　 　flag=TRUE;

　 　InvalidateRect(NULL);

0 p( p% z& r4 N$ k% z! }

　 　}

}

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

1 U% C9 E7 y0 L* Q# _2 z2 U' U

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

8 l7 z0 y+ H: R! Y8 W

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

8 g- t8 R+ L3 s) t" S; y, h Q( M3 d. a

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

* @/ M" b6 ? ~+ w1 J, u

void CServerView::OnUpdateSendmessage(CCmdUI ＊

: ^4 i3 l! C- I0 c

pCmdUI)

8 @" Z" o. o J4 |

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

pCmdUI －>Enable(FALSE);

5 @8 }8 z L0 R, t# \( [6 v1 ~

if(Isconnect)

pCmdUI －>Enable(TRUE);

}

& x9 o8 K& j1 x- D3 \4 R. I

再 窗 口 显 示 消 息:

9 k1 D6 h0 P( y& n" }9 |: O9 R* c

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

$ v/ g4 G; }% Q1 V# s% E

{sizeTotal.cy ＋=20;

for(int j=65;j

1 D. Y4 u2 w6 E" q

TextOut(10,y,m_data);

y ＋=20；}

// TOD add draw code for native data here

}

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

3 ~# x% w; o) c7 ~ m1 u

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

5 i- u+ G, C( F" B! b8 x

二、 客 户 机 程 序

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

: g1 D! K1 \+ i) J- h3 y+ ?

在clientview.h 中 加 入 代 码：

3 l; v) t7 E, h. Z; A- u% s9 n

＃include “winsock.h"

添 加 变 量:

CString m_data[1000];

HANDLE m_hListenThread;

2 S1 N% y* _: D) Q: W

SOCKET m_sock;

" R2 x) G* e {8 d, E

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

( Z3 x k) O, o' M

int count;

CSize sizeTotal;

BOOL flag;

/ U& L8 f% f' K

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

3 x& v4 V; N+ m/ z

CClientView::CClientView()

9 A4 Z9 q) f) Q& [5 G& C

{ // TOD add construction code here

Isconnect=FALSE;

sizeTotal.cy=350;

7 {% {! h" d8 ?" w1 g6 u

sizeTotal.cx=300;

flag=FALSE;

: o% N6 r9 ^" ?" M1 c' ^$ ^7 X0 m1 s

}

( Q: O4 \: o6 Q' _3 G3 t

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

0 y+ T8 C3 z* A3 R3 z* X2 K

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

void CClientView::OnDial()

5 S6 K$ ]! b/ L; _2 N5 U

{// TOD Add your command handler code here

, G- Y# F- k0 G8 _8 V

count=5;

" F6 Q$ S" O6 @1 Y/ y1 o

if(m_bInitialized)

{ AfxMessageBox(“Already dialing");

return;}

. r0 a9 |# a0 s0 D" O: V& i& ?

Cdial dial;

if(dial.DoModal()==IDOK

# Q( r) s% V1 w5 Q

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

4 Q. D# V! K T/ R) z2 H# C

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 K& K. T% ]' O

m_saSrvr.sin_port=htons(5050);

. ]1 e# Y' F |" v" q8 b+ x: q

int status;

WSADATA wsaData;

. t) t7 y+ R8 U+ n& ]% t

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

, G0 {5 g. f, ?/ S7 f, y0 G

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

{ m_data[0] ＋=“Succeeded";

1 F3 A9 {) W7 l/ o9 ]6 |

m_bInitialized=TRUE;}

else

{ m_bInitialized=FALSE;}

) v. M- q+ h' d: H" Y

m_sock=socket(AF_INET,SOCK_DGRAM,0);

7 Q7 S8 j0 A9 x5 R! n2 Y8 F% N

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

if(m_sock==INVALID_SOCKET)

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

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

3 D+ p. ]$ g8 a9 a; t5 @, a

sa.sin_family=AF_INET;

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

. X3 Z: n7 P6 `$ m; e1 B

sa.sin_port=htons(0);

if(bind(m_sock,(PSOCKADDR)

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

9 ?6 L# u) b1 q: I7 v: e9 y

{ m_data[2] ＋=“Failed";

) L0 J; j2 x* W/ d' k5 Z* a

closesocket(m_sock)；}

m_data[2] ＋=“Succeeded";

; G) @- c S/ A: |; A, r$ z. C( V

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

/ |2 I; ]# q. R1 l4 {0 O

unsigned long idThread;

4 {3 D1 }- l' E5 }0 f2 Z1 Q

m_hListenThread=CreateThread(NULL 0,

0 N y! v; A6 l* D; r" ]

(LPTHREAD_START_ROUTINE)Listen,

2 d6 @, G5 W+ y' m0 K! S9 p

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

if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

% b2 V! {" `: o

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

else

m_data[4] ＋=“Failed";

# h w' s% C+ [+ G6 M. N* X2 ~

InvalidateRect(NULL);

}

}

2 K- P5 Y1 U2 k% b% @4 w# u

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

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

＃include dial.h

7 E8 m4 n/ I) x( ^, n |6 h9 {

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

void CClientView::OnUpdateDial(CCmdUI ＊

0 S. A, M" Q1 @/ J+ N @

pCmdUI)

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

( V; W8 N* P8 _8 ^/ z4 g

pCmdUI －>Enable(TRUE);

, f7 ^0 l+ x+ A# Y6 j

if(Isconnect)

, o* ]& f/ a Q2 ~

pCmdUI －>Enable(FALSE);

}

6 y5 X% e3 ~- n/ t+ E( P; F

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

! W o8 G B1 f( ^! t6 t: r/ r- d

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

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

/ M: {) q! g' \8 T! B

pView －>InvalidateRect(NULL);

wsprintf(msg,“A: ");

) |) D0 A! P# f8 g

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

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

z3 G. b+ h/ Y

int saSrvrLen ,nchar;

4 v' J% o- f9 N; f; R( d

while(1)

$ }$ B" \0 q: Q- G$ Y8 [

{saSrvrLen=sizeof(pView －>m_saSrvr);

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

+ D- I4 @: S$ ]& Q

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

6 c9 I- z8 S+ M9 G# ^; _" r

if(nchar<0)

, g+ G3 j& L+ ?% e

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

“Error in recvform";

pView －>InvalidateRect(NULL);}

else

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

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

5 v" b( K7 T- O' Q- g/ a

}

, v0 o" T8 L/ f) n; G8 f

}

return(0);

}

6 T7 B. Y5 b: {: f* w+ p6 e

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

/ ?: F! h/ t- @

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

d! O& ?% a3 w+ S) e( i; T

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

" ?6 f1 Q) \7 _+ n+ d

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

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

下 的 网 络 中 执 行。