服务器与客户机互传消息

韩冰

5 d+ M- A# W; _; Z+ i

一、 服 务 器 程 序

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

在serverview.h 中 加 入 代 码：

＃include “winsock.h"

& W/ d8 w/ [8 a* b ]2 ?

添 加 变 量：

5 D2 m0 d1 b( f/ \0 h6 y4 A

CSize sizeTotal;// 控 制 滚 动 条

# N' v+ ]% M5 C/ H" z8 |& ^

int count;// 信 息 条 数

9 x$ ^% O! v( N7 l" c

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

char Hostname[260];

! k( e0 F# [3 G4 U0 A% d& Q

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

SOCKET m_sock;

HANDLE m_hListenThread;// 线 程

' s3 B$ F! q# y( _! s/ N, N+ O

BOOL m_bInitialized;// 是 否 初 始 化

O+ G8 F% E3 x

WSADATA WSAData;

BOOL flag;

4 p! R r. O7 Q/ j% ]9 N! ~

SOCKADDR_IN saClnt;

int saClntLen;

1 ~3 D0 l- B. u d6 v% t# K7 D

BOOL Isconnect;// 是 否 连 接

9 z3 [: U6 L: z7 g

9 Q' o0 o1 z, t/ [( w( [! p/ k

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

字：

" d# p2 q5 n% B$ d c. [4 W

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

flag=FALSE;

sizeTotal.cy=350;

9 B0 d* [) j2 H( ^ d# G

sizeTotal.cx=300;

4 h: k! H; c$ k9 {

m_hListenThread;

count=5;

int status;

WSADATA wsaData;

) @3 p' N. v; |9 @( f

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

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

% }6 E' ^0 }- r8 D6 D3 w

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

}

else

' u9 m% c: \! b: j/ q* M# V% c$ V

{ m_bInitialized=FALSE;

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

2 g7 x7 _! \. G: B# z

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

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

}

m_data[1] ＋=“Succeeded";

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

+ ^1 k. t" R/ s; E

sockaddr_in sa;

9 w8 e1 J* f( I/ X1 s! |

sa.sin_family=AF_INET;

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

L2 u$ \2 n# x& v5 G% o

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

; r+ l6 v& \; N1 ?* T6 v

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

{ m_data[2] ＋=“Failed";

0 |+ R( b. f! H0 J% K1 l, n' U

closesocket(m_sock);

}

! H0 _! o' h" h# d; Q- f5 t, R6 G

m_data[2] ＋=“Succeeded";

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

0 T9 P9 h0 y# _3 [- e

(LPTHREAD_START_ROUTINE)Listen,

0 C6 Q: u: t; e

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

' X Y# e1 D# _- S# T

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

}

% |% L1 t5 O5 ] k# |" C

else

m_data[4] ＋=“Failed";

; N" S" e# B% Z: @3 o. }$ b

}

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

; S* K$ _( y" e# r$ f

CServerView:: ～CServerView()

B2 z8 g- V7 {3 L( a7 x; ?" U; m

{ if(m_bInitialized)

WSACleanup();

0 t! l2 D- [8 g4 ~

closesocket(m_sock);

' S% X$ S7 ~- s) E! c$ l9 ~

if(m_hListenThread)

7 m' t9 w% h8 T4 d- |0 t. N' K% e

::TerminateThread(m_hListenThread,0);

; U" t) m8 _# w

}

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

0 {; r* k6 g7 R5 {& N+ Y9 `

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

int nchar;

" O* o) M/ P6 |& G+ K) q" B4 q! N

SOCKADDR_IN saClnt;

+ A1 \/ s3 S# [& b5 v- A

int saClntLen;

1 Y/ }" c5 Y/ Q5 D; i q

while(1)

( Z' _. J7 z2 x0 L) Y. a

{ saClntLen=sizeof(saClnt);

2 x4 C8 q' p2 n" h& `

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

if(nchar<0)

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

& c; t" z6 t) e

=“Error in recvfrom\n";

2 X1 I% Y, ]+ Y9 z

pView －>InvalidateRect(NULL);

5 s7 n9 h: q: @ ?, x

}

else

{switch(msg[0])

: ~' n! ?: T/ g/ N) h0 E

{

case ‘A':

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

. G) H+ H$ I7 W( I# }

inet_ntoa(saClnt.sin_addr));

! C/ X1 x+ P6 p/ K: ^! U/ }

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

break;

! b# N, h% H* T0 j' J4 V$ e

case ‘D':

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

inet_ntoa(saClnt.sin_addr));

. F: D, O# A0 ~5 T9 t5 C& H

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

5 T" z, G. `/ S) D; v

pView －>flag=TRUE;

3 p+ q, y- m0 Y9 n; w' G

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

3 ]- i; F- E0 x2 s/ J: w3 f' w

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

＆saClnt,saClntLen);

# l! a, `+ l$ h" o1 b

break;

3 i9 p$ F8 d# Z# a9 v/ H/ U

, G$ N' f) i8 Y3 \3 {

case ‘R':

' \* t* y0 S/ `* c7 P1 D

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

# J) c) {+ @9 L: y1 |5 [

break;

& B2 J$ R( i: J1 J

, M! Q$ F: n$ M V$ j

default:

% ^3 _# i# r5 n: U

break;

0 R# z3 J" U6 \! F) b( j

}

}

: J: \0 [! d* F: F+ s H+ q3 T6 M3 p

}

+ w& q6 E# L3 g: Q# C

return(0);

}

. j* U& E2 g6 G6 u9 a. n0 e, \

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

B$ B. |. p3 }6 F$ b

　 　void CServerView::OnIp()

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

6 f4 C5 C8 {2 I/ F0 {3 V

if( WSAReturn == 0 ){

, k: k8 k+ J+ H

gethostname( Hostname, 260 );

5 ?1 W n5 I% ?- L

struct hostent ＊pHostEnt;

1 I d1 @2 E/ i9 |5 t, H1 ~

pHostEnt = gethostbyname( Hostname);

5 i! j" A& Z: Z" h

if( pHostEnt != NULL ){

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

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

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

. M% a6 R$ |# `" A% k" l$ J

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

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

　 　CString out;

$ `7 j x7 X! ?' g Y) m/ P; a

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

% G8 K3 h, B6 J8 ^. }

　 　}

7 |8 j7 E* R) a

}

}

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

char msg[2000];

Csend Sendmessage;

' J/ M) H. k' r2 x* y- B

if(Sendmessage.DoModal()==IDOK

; f% P+ Q; S9 G; q

＆ ＆!Sendmessage.m_Message.IsEmpty())

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

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

0 q1 X) s2 z' P# }+ J

＆saClnt,saClntLen);

4 ~# N3 g2 F9 q* b

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

9 z0 Y! i3 r/ K2 C, o' J" ]

　 　flag=TRUE;

　 　InvalidateRect(NULL);

8 C& F+ C5 z1 U) G7 E2 x

　 　}

}

2 p/ ?% G) x% `+ u6 j- {8 c

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

" a, j1 R0 X' O+ T; I4 M

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

( {9 y; d1 _! B

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

; v2 V, `+ {7 Y+ [/ ?

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

pCmdUI －>Enable(TRUE);

}

2 }5 P( Y+ w) k. j8 H3 `0 t* e8 y

再 窗 口 显 示 消 息:

; S5 o2 m8 K, t- r# f0 x

void CServerView::OnDraw(CDC ＊ pDC)

: j, ]# o+ v: i- g% K N

{ if(flag)

" R0 L" _, f5 ]0 a( v% Q8 \

{sizeTotal.cy ＋=20;

( G7 S. @- l/ V' @' E

for(int j=65;j

TextOut(10,y,m_data);

* [1 U6 }6 H/ y/ Q6 n7 [7 _* J

y ＋=20；}

- [6 z0 S2 G* b7 i

// TOD add draw code for native data here

* q" |6 h3 H, Y# m' M

}

h; E4 g& K/ Q. {

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

: `) \! W7 l: ?. @/ e) x. U

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

& O1 d. |' E/ u( A1 W; j7 A

二、 客 户 机 程 序

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

在clientview.h 中 加 入 代 码：

! j9 p4 a) \" B& N1 h

＃include “winsock.h"

8 J8 c! m* c/ v* ?2 c# J( O

添 加 变 量:

- G' X* X& \6 A( O

CString m_data[1000];

% L1 v6 ?2 U, |; D8 l, I

HANDLE m_hListenThread;

SOCKET m_sock;

7 N$ n3 R- j2 ^. T8 _

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

int count;

CSize sizeTotal;

, B9 k' s& [7 C9 H2 ]

BOOL flag;

: A& _) a: X/ S% u$ `+ w. A4 V) @" R- [: Z

* ^- J) e$ x! I+ V0 J- x$ f3 a

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

" |& L3 y$ p/ L% O

CClientView::CClientView()

{ // TOD add construction code here

+ H j) f* y; U/ }# ^

Isconnect=FALSE;

2 g0 V8 ^2 f! c/ Z

sizeTotal.cy=350;

* G5 y" R! S1 Z* i

sizeTotal.cx=300;

. `, t4 d& t1 t$ d% _) [; J& O

flag=FALSE;

}

7 J8 T o$ W7 ]- f

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

0 U; }4 t i) A0 \1 i

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

void CClientView::OnDial()

6 u& [3 R' B& E6 ?+ r0 \

{// TOD Add your command handler code here

count=5;

if(m_bInitialized)

6 A# v1 u4 H- z+ l+ Y+ Q

{ AfxMessageBox(“Already dialing");

return;}

Cdial dial;

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

" W/ ~' K/ ?+ X9 t7 m% b

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

( q+ S; n! U3 x3 }

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

: Q( b6 U7 u$ d. r6 a" b9 r1 F2 M

m_saSrvr.sin_port=htons(5050);

int status;

WSADATA wsaData;

( M8 v* i( D% N" X6 j6 m, S, R

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

) n* O6 c0 z2 E5 h- x/ U* h

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

{ 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)

# ` {$ X7 ]3 Z n# I; i' X/ p8 S! C

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

m_data[1] ＋=“Succeeded";

9 P4 Q; k" ^! ?# g% ^7 F. e" @

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

sockaddr_in sa;

; d3 q5 y. z5 O1 n9 s# Z

sa.sin_family=AF_INET;

. D- H6 E) q6 Q

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

sa.sin_port=htons(0);

if(bind(m_sock,(PSOCKADDR)

, w3 |. V& N0 E. x4 S6 }

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

5 f2 r3 Q/ U! H! f+ p

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

& B. P( Q. p# ~

m_data[2] ＋=“Succeeded";

, w. n2 }/ ?* t! S- e. R. v

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

unsigned long idThread;

0 p0 J3 { f. p) w3 M0 @4 }* s

m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

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

# a, J0 L [0 X' X

if(m_hListenThread)

! W7 u1 K, [1 z i

{ m_data[3] ＋=“Succeeded";

. [/ X. ^' |0 o) Z: f

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

else

m_data[4] ＋=“Failed";

8 ?( y8 f2 N# t5 J+ n7 F

InvalidateRect(NULL);

}

3 m4 T. m E! z/ {

}

( Q* y* Q/ y0 Q3 j' j! E1 ?

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

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

＃include dial.h

/ ^. _& c6 D+ l4 n4 o3 a' n

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

( |: L! Y! j' N) C

void CClientView::OnUpdateDial(CCmdUI ＊

, G& w; }( b; l {; `9 C9 L

pCmdUI)

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

) R5 B3 m0 c4 C7 {% O( U/ j

pCmdUI －>Enable(TRUE);

0 M9 T T, z. F) N) i

if(Isconnect)

pCmdUI －>Enable(FALSE);

}

2 x R/ T: J/ ]: m7 P: C2 }

! w" M, G* O8 }: L2 Z/ l

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

?* O" H6 ]( Q. ~, s

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

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

pView －>InvalidateRect(NULL);

4 z( x4 U1 J4 m: J* l

wsprintf(msg,“A: ");

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

5 }2 W* p* @/ {" c- A) b7 r

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

int saSrvrLen ,nchar;

! L$ M8 m& T$ C0 z8 t# s

while(1)

# ]$ q0 O" [4 L& c

{saSrvrLen=sizeof(pView －>m_saSrvr);

* }3 I8 i- P" a8 i

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

, [4 P2 B6 K' j" ]& H5 y; g1 N$ c' x

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

if(nchar<0)

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

“Error in recvform";

( z1 A# f/ S3 f0 p

pView －>InvalidateRect(NULL);}

: c) a9 f4 t8 h0 N% z! g* \8 f) x

else

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

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

7 T4 A! X" m" z: D0 c3 Y3 w

pView －>InvalidateRect(NULL);

% ^: Q p) Y- ^* t# I) r- O, ^3 B

}

}

9 p8 U& q2 C0 D% l7 d+ A. m

return(0);

}

8 R4 ~, |" W% f6 V2 J

" x6 d/ i! {9 w' f% O4 s

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

3 k- V0 `( o+ N: c Q4 G$ s

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

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

; _* l) S% ]( G/ `: y( ]" ]' i. U& v

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

/ ?4 G8 e1 J* `9 C: U+ l

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

( E- K. d! O( V* h$ |7 t, `

下 的 网 络 中 执 行。