服务器与客户机互传消息

韩冰

& F2 f" T4 F1 |: m2 R& P

一、 服 务 器 程 序

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

在serverview.h 中 加 入 代 码：

- \6 K% o1 ~ ]- S, g6 \

＃include “winsock.h"

. r& N# v' w/ y. i* R

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

! X9 y& l8 u2 x' x

int count;// 信 息 条 数

+ X' J- I+ x" [* ?

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

char Hostname[260];

# r8 e2 z; J& @

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

SOCKET m_sock;

/ g4 |* T; E, a- v- M- ]( P

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

: k' t& B6 d4 P: c& Z8 o0 n3 s

BOOL flag;

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

+ x, ?# N! D& @- H( B Y- g& w

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

) o) `7 F8 r" A5 Q9 l: d

字：

& E9 R% z; j7 U4 h% J6 M

CServerView::CServerView()

{ // TOD add construction code here

@6 V$ S/ x- M5 C6 W

Isconnect=FALSE;

flag=FALSE;

sizeTotal.cy=350;

( s% r0 W+ W q) S

sizeTotal.cx=300;

: c3 J0 I9 _, \

m_hListenThread;

count=5;

4 X( B; s B& c1 B) _8 S

int status;

3 l4 F& s& D* r% U

WSADATA wsaData;

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

. P6 i/ A# A7 J/ k

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

" J1 S2 y @3 M; w; l2 h, `4 t

{ m_data[0] ＋=“Succeeded";

9 f$ J. @4 D9 c D J' a

m_bInitialized=TRUE;

* U6 J3 ^3 n% Z2 j ]

}

0 a! `% q# y& k, p

else

{ m_bInitialized=FALSE;

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

7 |! o7 U+ A3 j: o: L) ^

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

2 w" x) ?- u V. E* y |

if(m_sock==INVALID_SOCKET)

; P0 N* H z$ Q, j. @* \2 P

{ m_data[1] ＋=“Failed";

7 h! ]: B5 `0 o8 m" M

}

m_data[1] ＋=“Succeeded";

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

! h- W- B& b4 ?- @# F. S! Y

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)

9 j, S) g9 C4 _5 r

{ m_data[2] ＋=“Failed";

0 r( p3 v) q+ E- L0 j! e, \

closesocket(m_sock);

, k" ~0 t# f( u2 ^) x

}

' a: \& c6 ~6 l. Z

m_data[2] ＋=“Succeeded";

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

! m; G+ W8 {/ I4 W1 t6 i

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

( C) E% h9 ?- B7 j5 N

{ m_data[3] ＋=“Succeeded";

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

' |0 c7 w# k9 J% ^/ E- {1 Y; L" W% F

}

else

& c) ?( Y' L! w) `# s! L8 V

m_data[4] ＋=“Failed";

}

( Y5 d) \8 s; w, {5 ^

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

CServerView:: ～CServerView()

$ }6 n6 k8 F: t3 b1 X. R

{ if(m_bInitialized)

% U' Y& x9 u. x' T# S+ w

WSACleanup();

closesocket(m_sock);

2 D( G& t, F% |- N2 k- {4 c0 N

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

}

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

long WINAPI Listen(CServerView ＊pView)

- u1 d. K; D; T- z s+ L5 Z$ D

{ char msg[2000]=“";

4 F1 {" m3 |. e

int nchar;

. d/ ~2 Y K& Q. [0 V

SOCKADDR_IN saClnt;

: l3 r4 i# A! g0 y8 b: i6 E7 n

int saClntLen;

) }/ k7 x5 ]* y7 Q3 `

while(1)

{ saClntLen=sizeof(saClnt);

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

; L, x" k3 _1 L* }6 Q

(PSOCKADDR) ＆saClnt, ＆saClntLen);

if(nchar<0)

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

: n8 y5 I4 M; J7 _+ P' \: J2 y! F! I/ ~

=“Error in recvfrom\n";

pView －>InvalidateRect(NULL);

}

1 {9 X% I% \* l+ S" {6 B. d

else

{switch(msg[0])

{

: c- K; A6 _: ~) {) e: h

case ‘A':

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

- R1 m, i" [$ t! H+ m6 a' Z

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

: L- ]( d4 V$ o

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

V7 r' l/ l6 C4 }" I, K

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

break;

! \2 `; `6 n* I7 [, s

" j- u! L% {. g' t# x6 `8 d

case ‘D':

9 U7 f# k, P& j% g- C/ y% U% J

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

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

% h: _. r/ P `- D e j7 a

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

6 z! w* H1 ?( j% E( G- z

＆saClnt,saClntLen);

break;

3 @! h- K( V# ?+ n/ P. t3 N

case ‘R':

saClntLen=sizeof(saClnt);

3 m6 G; ?3 S3 q! Y( V

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

5 ]1 g8 K% N ]5 j( n. q" r% Z

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

break;

& Q6 Z& p/ ~& h; y

default:

break;

i( ]" W; f) ~5 j7 v9 ]

}

8 X: { Y$ \% m; E2 j/ K+ `

}

- k6 {! k- e1 f) r6 @( D) P

}

return(0);

5 f/ F0 g% g6 M% ^; } O

}

, ]2 t, {1 I9 R( I( r* @9 X* g

- [# X s4 m+ O+ _/ X

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

) N: V6 p+ _8 T" R

　 　void CServerView::OnIp()

: a, e# h: {& r1 U: K, f

{int WSAReturn;

5 \1 F \. I4 r9 v2 e

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

4 q! P5 F2 N% o% a" v( k+ p4 J3 G6 o7 X

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

: W! S4 r. Y! g

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

, H3 V6 Y- U: b5 h- Y

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

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

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

6 x8 t0 A! C/ K1 l0 D' ~* R

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

! q% G7 I+ l1 X, X7 n7 W* Z: p

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

6 g( m. b3 P6 W

　 　CString out;

7 ~* s( ]. p8 k/ {

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

% ^( _" ]; a9 q0 o

　 　}

9 k B7 u! b; T) h( |

}

2 b% E2 B: w$ ]: m7 S

}

6 B5 J: U' D3 Q Y4 I

) r7 L& j( N* `( U* W

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

　 　void CServerView::OnSendmessage()

+ z2 K4 F( r* O) w

{// TOD Add your command handler code here

char msg[2000];

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

' c3 t: f: g+ O& B& O4 _& G; {' }

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

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

$ J" p* k' O* Z' C w1 }/ r

＆saClnt,saClntLen);

. x: i" k2 N" j O$ f

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

　 　flag=TRUE;

% {& F5 Y8 K$ L" H+ n7 Q

　 　InvalidateRect(NULL);

　 　}

}

) U/ ^; V- r0 V; ?; U

0 W+ j1 T# g( J5 T/ `% D, v0 s* U

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

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

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

" s8 B& L# F* w6 |8 |2 A a

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

! p# F5 b @$ M |# R( C$ W

pCmdUI)

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

pCmdUI －>Enable(FALSE);

% U' _; q/ O1 w9 Z2 }) `! y

if(Isconnect)

" L+ b! c# z' R; P3 ~9 |

pCmdUI －>Enable(TRUE);

/ F1 z4 v9 t9 o+ a( |% R

}

: b ^8 e" V; i! M p9 `* ]

: ?6 K2 h0 E' [* ^" M2 P

再 窗 口 显 示 消 息:

# Z5 h9 c/ S7 l6 ^/ u! v X8 }

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

9 L9 [( ?. m! p

{sizeTotal.cy ＋=20;

for(int j=65;j

TextOut(10,y,m_data);

y ＋=20；}

// TOD add draw code for native data here

9 V5 y: A: n" f1 u' b

}

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

" N" m& \9 P! n+ z0 Z, k2 G* b0 {- Z

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

二、 客 户 机 程 序

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

3 ]5 Y* B. t% h

在clientview.h 中 加 入 代 码：

3 G/ n2 n1 [: R7 L6 E3 j, [. d

＃include “winsock.h"

添 加 变 量:

) o9 z9 R$ Z5 k3 @1 `0 Q

CString m_data[1000];

HANDLE m_hListenThread;

) F) P- U7 O* o

SOCKET m_sock;

1 O0 o5 l# S: a% ^; b- w4 f

SOCKADDR_IN m_saSrvr;

& ]# z3 k5 g! j6 t( c; j5 j

BOOL Isconnect;

( v4 Y- \: J: m* r! P! B

int count;

CSize sizeTotal;

, y( M9 h2 o/ `; i

BOOL flag;

+ h) w( R" M! A7 d- Q9 S3 ~

' W+ c. t; @% s+ o) Q8 @6 D6 }

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

CClientView::CClientView()

{ // TOD add construction code here

n( T8 {5 d: I/ T0 v' B- N2 o

Isconnect=FALSE;

sizeTotal.cy=350;

; E" q& v4 d! f0 M2 o

sizeTotal.cx=300;

! t- |: w _4 V- P

flag=FALSE;

}

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

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

* ?5 q$ q- Z0 e2 ?5 Q* d

void CClientView::OnDial()

{// TOD Add your command handler code here

count=5;

if(m_bInitialized)

{ AfxMessageBox(“Already dialing");

return;}

Cdial dial;

if(dial.DoModal()==IDOK

9 x1 _& S% ~( ]" K$ C! w$ H

＆ ＆!dial.m_HostAddress.IsEmpty())

1 n9 R% e/ s. }4 d D; p$ M

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

3 D7 q! B( {5 y7 a: F

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

6 s2 g0 S& A/ k

(dial.m_HostAddress);

m_saSrvr.sin_port=htons(5050);

int status;

WSADATA wsaData;

" M6 g& ` v9 v9 ^: J

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

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

( ^) t' {6 D, Z( ^4 [

{ m_data[0] ＋=“Succeeded";

6 u1 w& W1 K+ a1 A; f7 K

m_bInitialized=TRUE;}

6 G' E( |; J8 r! [' ?- R5 l

else

& e; f4 ^7 ~8 e/ X: y5 ^

{ m_bInitialized=FALSE;}

2 h. c2 D" c$ v

m_sock=socket(AF_INET,SOCK_DGRAM,0);

7 u9 B1 x B, G" }# \8 F

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

if(m_sock==INVALID_SOCKET)

" y1 o" U4 r$ \* S. O2 M# u! L

{ 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(0);

if(bind(m_sock,(PSOCKADDR)

. G. n$ x8 L" T; P4 L

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

5 _) u; M+ N% g8 h$ V' D7 }

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

- e" z* s. Y- \# ]& O3 s

m_data[2] ＋=“Succeeded";

7 ]) b' w; e4 h) f" w- z

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

unsigned long idThread;

% n% V7 Q' z& Z' ?

m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

5 V$ U X- w8 W6 ^- c. u

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

. i5 q3 Q* v7 e4 i9 P4 b

if(m_hListenThread)

% A- k0 S9 N- _6 W/ N! z; H

{ m_data[3] ＋=“Succeeded";

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

else

m_data[4] ＋=“Failed";

6 A, X5 W8 L$ C- d

InvalidateRect(NULL);

}

3 t. ~, G5 L. w

}

! x7 {1 V# Q, u

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

' o3 h5 e% q- U& K" \- O* Q# }5 Y

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

' Z* Z0 m( l! U) b

＃include dial.h

, Q5 L& O. c; A4 q$ Z

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

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

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

6 t( Q0 S' Q0 E- R( B R# O

pCmdUI －>Enable(TRUE);

if(Isconnect)

pCmdUI －>Enable(FALSE);

}

; M! K$ f: c+ u' U

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

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

6 k' Q( w! z7 {# I. X

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

" D& j. m; Q2 w8 ~% ` J+ L3 ^

pView －>InvalidateRect(NULL);

# ?5 w! _8 j( c+ m( T% @" r5 j/ r

wsprintf(msg,“A: ");

) V& [: Y$ w( N* W

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

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

int saSrvrLen ,nchar;

while(1)

/ N0 S; W) H: y1 U' C! T

{saSrvrLen=sizeof(pView －>m_saSrvr);

8 D9 J1 ^& R2 g

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

1 A# _, v3 R* |* e8 T0 X; x" Q* P

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

if(nchar<0)

$ j$ m, J0 |5 K$ j

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

2 r; P. Y3 F& V+ U8 v$ ^

“Error in recvform";

pView －>InvalidateRect(NULL);}

5 p/ L+ P3 S! \1 Q+ T4 `3 Y

else

, V8 d; Q% ?8 S. e( p s" ?

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

pView －>Isconnect=TRUE;

- W4 o) z% ?! Z) W' [! D2 ~2 s

pView －>flag=TRUE;

) v3 w' v5 |6 ^+ y; Y

pView －>InvalidateRect(NULL);

l$ ]' V( l6 s& {: K8 ]

}

: k; I7 q, T7 A6 G

}

8 ]2 o+ j0 H9 _$ C+ v

return(0);

+ g# u* @# h6 z4 B" T9 B" F9 [' x

}

! T- I# T! i9 d4 a3 q6 @& i

- D* @7 d. b) v

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

9 X- n4 K7 e$ z

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

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

+ F! q+ [1 r/ g- {

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

5 \, Y/ x ?8 U }& a

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

0 b3 |4 g. W% B6 {! F

下 的 网 络 中 执 行。