服务器与客户机互传消息

韩冰

. ~6 {4 R: O: Q

一、 服 务 器 程 序

+ t' W% {4 S1 d4 H L! n) h

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

在serverview.h 中 加 入 代 码：

. l P) \/ Y2 k; ^. }# v; R

＃include “winsock.h"

添 加 变 量：

0 f) A: M; F9 ^3 m4 c' x" a

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

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

char Hostname[260];

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

SOCKET m_sock;

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

BOOL flag;

/ k) s9 L; b$ N( A1 k: W

SOCKADDR_IN saClnt;

! C& @3 F4 f* q# D7 f5 Q

int saClntLen;

8 O/ l2 X8 r7 N8 F

BOOL Isconnect;// 是 否 连 接

) H1 c7 g! x# n- F

2 q+ J4 k) G2 m* I# d+ L

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

' k5 N0 t# _2 w* i7 A% o

字：

CServerView::CServerView()

, w8 b$ _1 B0 g5 h' V. `

{ // TOD add construction code here

) D1 p% |& Q2 W/ x" k8 K

Isconnect=FALSE;

; [, r0 J) i* ?' m- _

flag=FALSE;

sizeTotal.cy=350;

- i6 I |. v! R0 K3 O

sizeTotal.cx=300;

m_hListenThread;

6 ]$ }+ N9 U+ P! V9 _- g% R

count=5;

. Q+ [* X& t! g# j

int status;

WSADATA wsaData;

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

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

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

}

else

{ m_bInitialized=FALSE;

}

+ F9 f+ I- ]- j `

m_sock=socket(AF_INET,SOCK_DGRAM,0);

5 X0 R5 o! Y5 L$ M3 ?

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

/ u$ F, o$ Z& I5 U3 [4 `0 ]$ D6 ~

if(m_sock==INVALID_SOCKET)

3 w6 P# p1 t7 S0 n+ n( I+ s9 `* c2 i' J: ]

{ m_data[1] ＋=“Failed";

8 H+ {; l% P, ]

}

m_data[1] ＋=“Succeeded";

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

: O: J! x3 D( D+ P: O

sockaddr_in sa;

sa.sin_family=AF_INET;

% a9 z0 H" j1 W+ z

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

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

$ g, M3 _2 d! ? `$ i: _

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

' _/ Q! R) y2 t# J0 |) j

{ m_data[2] ＋=“Failed";

7 [+ ~3 s: z0 `. n2 G

closesocket(m_sock);

8 k, S2 i5 b. k* r

}

! j% Q) \$ f% ? q" T% k* f

m_data[2] ＋=“Succeeded";

) u3 o. F; ]9 X0 C+ Q1 \7 G

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

( s$ ~9 J. D6 G8 w! r

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

Q9 Z$ g7 _. \4 ?& I3 j

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

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

. o$ S7 A) S' I9 z3 K2 h6 F

}

1 ^) y( U! q) v: r# R5 R3 {4 ?

else

m_data[4] ＋=“Failed";

+ H1 x+ M2 v0 u& f

}

, R c" q/ j8 T, {! d

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

CServerView:: ～CServerView()

{ if(m_bInitialized)

- e1 o4 i! Q! p7 P) F5 } e

WSACleanup();

3 V) L+ p: C' M& \2 w7 h

closesocket(m_sock);

if(m_hListenThread)

$ |8 |; `; M0 X9 z, [

::TerminateThread(m_hListenThread,0);

}

( @% ^; ?5 O# B4 a

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

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

: D& N, A) y' Y2 z

int nchar;

SOCKADDR_IN saClnt;

5 j- d, |" q0 `0 S8 W( e

int saClntLen;

- l( X. [ D5 b% a4 y& r: B9 h7 d9 V

while(1)

- Z! ]( l6 ~% P# p/ z

{ saClntLen=sizeof(saClnt);

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

/ L- w5 G- \6 T( T# R# A0 s

(PSOCKADDR) ＆saClnt, ＆saClntLen);

4 B. k6 R" s/ T' t

if(nchar<0)

" d1 F! \3 j6 Z$ Z# `% H: X9 g

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

, p- ~. G: b8 L, A

=“Error in recvfrom\n";

1 w, {/ N! g" H

pView －>InvalidateRect(NULL);

. M" p9 h; U' Z$ Y; {* N

}

7 i) \! V. t3 P8 }; m- b) M

else

{switch(msg[0])

{

7 d, l2 ~$ ^& O, _! V, t3 U$ m

case ‘A':

! e, p0 ]7 i- h

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

; J1 {' ^/ k! x% p4 o1 \+ D

inet_ntoa(saClnt.sin_addr));

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

8 j# s3 S1 \& M* u0 q9 ?

pView －>flag=TRUE;

( t+ U1 a' g$ z+ ]5 K7 n l, I1 e& `

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

( y7 D# H2 j. K9 r6 t6 ^: D& S

pView －>saClntLen=saClntLen;

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

, R: I8 R% `- J9 \( J2 e& m

＆saClnt,saClntLen);

break;

3 u! ~, b+ ]) ]" C$ `1 m% I- {

case ‘D':

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

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

( `* ?' X; M4 r* F. f

pView －>InvalidateRect(NULL);

& t# J7 r. [; H G4 Y8 k2 r

pView －>Isconnect=FALSE;

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

2 B; O8 x! | {

＆saClnt,saClntLen);

0 S" [" _& C/ _" C

break;

+ L* T0 G9 f5 G* `% a1 R; X9 L

6 h4 o1 Q" H; g8 Q, G2 d, r* \9 @, W( _

case ‘R':

% i2 H# y4 n, P2 D k4 b" [* P

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

3 ^: L% O7 y- L+ C: `; e

pView －>InvalidateRect(NULL);

, I% a% |* V* m7 A' N# }

break;

; Y5 P. _- X2 T9 a

default:

/ S6 T4 `% ?0 h, u) k

break;

# Y$ o: a$ v6 h* S, z- a

}

}

6 U" L+ ^, ]8 V E, H" M

}

return(0);

( H; b" R0 C2 ~* S1 @

}

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

　 　void CServerView::OnIp()

5 Q4 b( [" c" H" c" v

{int WSAReturn;

5 S: I' h: Q) h' T3 p& y& G

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

* z3 _7 w H% h j* t6 o

if( WSAReturn == 0 ){

# X; x6 k w5 @' g. P: h. ?

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

/ _5 P$ c/ R! n9 ]

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

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

8 r) }; |# Z$ w: G, t% {4 v

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

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

4 K( `5 i+ Z8 V5 d) |

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

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

* p1 a& h4 ~8 i% h* r" d! w

　 　CString out;

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

　 　}

}

}

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

4 y1 J5 e* e3 o/ C+ N

　 　void CServerView::OnSendmessage()

( F7 k6 |% s6 W/ n: a

{// TOD Add your command handler code here

char msg[2000];

! W: j5 y8 q) |0 }3 o* @% U3 L% @

Csend Sendmessage;

, V' E% K% P- n( m6 F

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

: l5 r1 T8 r8 ]2 S/ U

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

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

＆saClnt,saClntLen);

6 N m+ D3 E6 e% C* ?& S

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

　 　flag=TRUE;

　 　InvalidateRect(NULL);

　 　}

) c0 P8 g0 \ T& ~ j" ~

}

" D( ^6 M- Q; f u; U; z% F3 I0 k! t* l

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

; R) ?: ^; r: Y- `- n3 x }5 ]

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

/ _. }$ {) b+ O5 T3 T

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

. v. [' k! k4 d; e, C- v3 u1 {

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

) b4 G8 p/ ~7 ^/ Z8 O) j

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

pCmdUI －>Enable(FALSE);

+ p* }" o1 O: M6 |$ K

if(Isconnect)

: F8 C7 j! f# z5 l# s: p6 M0 m

pCmdUI －>Enable(TRUE);

}

再 窗 口 显 示 消 息:

; K, Q+ o" z7 c; e! p" \

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

0 \+ _6 `- Z. O5 W) p- m

{sizeTotal.cy ＋=20;

4 c8 Y9 t% I) t8 s" X

for(int j=65;j

TextOut(10,y,m_data);

y ＋=20；}

// TOD add draw code for native data here

; E4 b2 I3 Q8 O" D4 C; l& M/ J0 ?

}

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

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

二、 客 户 机 程 序

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

在clientview.h 中 加 入 代 码：

＃include “winsock.h"

添 加 变 量:

CString m_data[1000];

, ?' z0 f, o, c6 X8 d U

HANDLE m_hListenThread;

' \( Z% I! n+ w$ `' {

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

( k3 L% \; `* v

int count;

CSize sizeTotal;

" \+ c! D( E; n* A. j" H

BOOL flag;

. C2 y, K/ F* v" Q$ s1 L& [

. Z2 N9 `. H! I& v) g" r: ~

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

* d- f. P% k4 q8 L" W

CClientView::CClientView()

{ // TOD add construction code here

& B, } e+ b& V5 J

Isconnect=FALSE;

! A4 d3 O! U4 }5 b4 X8 e! g

sizeTotal.cy=350;

sizeTotal.cx=300;

flag=FALSE;

}

4 Q: e% O' u5 p5 x% K1 h5 [

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

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

" W$ P, Y5 n" y& z) C; F7 W3 G

void CClientView::OnDial()

{// TOD Add your command handler code here

5 G. P* u# x) T% J

count=5;

if(m_bInitialized)

{ AfxMessageBox(“Already dialing");

, A$ n9 _5 j, l* J- t L

return;}

/ m3 z$ D% I) x% \. A

Cdial dial;

if(dial.DoModal()==IDOK

' f: w/ Q+ y6 ?! @& N

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

/ K0 R3 r6 m8 f" D5 B* h

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

K" ~ y- u! H3 c

(dial.m_HostAddress);

m_saSrvr.sin_port=htons(5050);

int status;

0 o# @6 F+ i0 ?4 I* \9 q* O& M, i

WSADATA wsaData;

5 l' M. z& P/ M& j" ~* r: Q

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

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

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;}

else

; w& Q4 E- Q' ?# b% O. b, l7 \1 u

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

! [ _: d5 J) \" x+ D* o8 [0 t) U

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

$ ], v+ p: Z1 d

if(m_sock==INVALID_SOCKET)

% Y. a( ?. W8 Q2 e

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

9 v+ n/ X+ ?2 X' V! a3 q4 U

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

: p* H4 }6 F2 t

sa.sin_family=AF_INET;

3 e* j+ g1 L1 m

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

sa.sin_port=htons(0);

$ G% }) h V8 l; K% O7 M d

if(bind(m_sock,(PSOCKADDR)

4 G5 h& p' [. P9 A, \& g

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

. @( L. J7 u( l9 k+ T+ z8 E$ d0 J

{ m_data[2] ＋=“Failed";

8 z* x9 X; M5 Z2 P; Z$ @

closesocket(m_sock)；}

m_data[2] ＋=“Succeeded";

; s" E' _# l' P" }- h4 \* p

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

unsigned long idThread;

# c# A; b$ w$ l% M" V+ R

m_hListenThread=CreateThread(NULL 0,

+ a0 I! k& E4 q h4 s0 N% b

(LPTHREAD_START_ROUTINE)Listen,

4 }1 Y; Y' J0 w s _2 H

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

if(m_hListenThread)

& Y! y4 W% A4 S, u" g; [, U s I- G

{ m_data[3] ＋=“Succeeded";

1 D( x' I6 r$ m$ s3 J+ u" r

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

else

$ n& ]- `) I; q3 ?% C/ \

m_data[4] ＋=“Failed";

InvalidateRect(NULL);

}

, E4 G) A, ]4 y

}

" p1 q, |0 F' s Y, R, @1 D

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

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

＃include dial.h

! U' f% n! L: u, j

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

void CClientView::OnUpdateDial(CCmdUI ＊

$ @4 q; L0 H1 u" A. B1 ^( |7 O

pCmdUI)

2 T! S2 ?* A& v

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

( z5 }! d9 t/ _

pCmdUI －>Enable(TRUE);

if(Isconnect)

/ s1 [+ }5 }) t" y" ~- G- k

pCmdUI －>Enable(FALSE);

}

1 l6 \+ m' u, E) \, [. e4 k. s9 A

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

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

9 X* Q% k4 q: c% C6 k4 p) ^& {1 n5 z6 z

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

- V, T6 y7 O9 Q- Z% l* G

pView －>InvalidateRect(NULL);

wsprintf(msg,“A: ");

( F1 E4 ~2 f8 A( o

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

" v. [- q& `$ c6 L& O5 I

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

int saSrvrLen ,nchar;

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

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

6 o4 t% d7 M- \8 d

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

if(nchar<0)

+ W, b& N3 ~( h9 D# ^

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

7 A: O$ k$ R/ c5 J: d

“Error in recvform";

pView －>InvalidateRect(NULL);}

/ a: G; E1 |* e5 ^+ d. V# k% t8 ?

else

# c* J; T1 p( A* T

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

pView －>Isconnect=TRUE;

6 _8 r- G1 P9 s) }; E8 J5 r

pView －>flag=TRUE;

6 u8 F5 s( B; O

pView －>InvalidateRect(NULL);

% o8 q: y* n! C! |# K2 a' S; V# r

}

}

return(0);

) @' X) F1 q" \# J+ @

}

8 L, t V/ h; U& y5 j: F3 c

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

# L8 }' x/ J2 x& S, s2 D" s

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

: Y' e" ^$ q2 ^

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

' c. E: o9 D( s7 u

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

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

下 的 网 络 中 执 行。