服务器与客户机互传消息

韩冰

D5 R; p9 N3 ?+ |

一、 服 务 器 程 序

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

( l9 h" f5 ?, r; L

在serverview.h 中 加 入 代 码：

3 y! x# c, y# P0 A

＃include “winsock.h"

" r8 G& h$ S0 ~8 z) E T7 y! D

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

( i, q. c: E$ h. ^. I

int count;// 信 息 条 数

2 F) {2 M4 b2 T, n6 i) ~

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

char Hostname[260];

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

4 @; g& j# k1 A. t5 p0 r- p

SOCKET m_sock;

& H" V. A" y5 j( {2 c( Z

HANDLE m_hListenThread;// 线 程

6 m7 I2 t' Q2 j( E* [% o

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

BOOL flag;

2 P( n5 O8 R: Y/ X9 p

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

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

& q' I5 x' I( | L d' F

字：

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

% b" A6 {3 D" _, D7 H. t9 p

flag=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

# v; K) K( ]! R2 s! F/ ]( z

m_hListenThread;

3 \* m, N* v& ?! b2 @" n8 B

count=5;

, z; |( Y' _$ f7 V/ U

int status;

( f; J3 [* F- W3 [

WSADATA wsaData;

; V3 x; N6 l i: h. {6 P

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

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

0 _; ~; g$ J/ O$ H; G5 s

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;

}

else

{ m_bInitialized=FALSE;

% n% _5 V1 L: U ]. \

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

+ K5 D$ o+ d. A

if(m_sock==INVALID_SOCKET)

5 I4 L8 {/ I" W, @ p

{ m_data[1] ＋=“Failed";

1 H3 t7 l3 }1 k

}

& e$ M; S" {* L' o# F$ v

m_data[1] ＋=“Succeeded";

7 c% e5 G. j2 ^# F

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

sockaddr_in sa;

7 l* z0 Y6 ^1 [) R

sa.sin_family=AF_INET;

/ q" d! ]- B! O$ @

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

0 B8 ]0 R* ^+ }1 E8 G# M$ x) ~7 m

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

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

# W$ i, D0 X6 ]) x# u3 C

{ m_data[2] ＋=“Failed";

$ g4 {5 r8 d# Y; j1 y: m

closesocket(m_sock);

, T z+ p, u4 P

}

. U$ B. p& x5 q' _ J

m_data[2] ＋=“Succeeded";

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

2 J/ O) e: A, q Y' P1 Q

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

, i8 [2 ~) q& c) _$ m2 D% j

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

: R5 [: S2 _, K. g9 t) t

{ m_data[3] ＋=“Succeeded";

/ q% `, F( s1 A- q9 m

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

, r4 K2 t6 z; S

}

: I4 H) x1 }- `3 Z" u+ v4 a

else

m_data[4] ＋=“Failed";

}

% F4 s8 O: V) S; h" T4 g

: x% [, f" P$ q% x7 u3 c3 v

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

8 J2 K2 t' n4 C

CServerView:: ～CServerView()

{ if(m_bInitialized)

WSACleanup();

* {5 C; v" ?7 k4 M8 E+ O+ v4 L, _$ M

closesocket(m_sock);

if(m_hListenThread)

2 b, Q6 V9 E+ i3 D0 C+ r% s

::TerminateThread(m_hListenThread,0);

}

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

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

int nchar;

5 r; W4 a0 V1 |9 m Z4 s

SOCKADDR_IN saClnt;

8 E! l K" k/ ~9 S. R u9 y% c7 s0 h* m, ^

int saClntLen;

. Q% h# H I: d

while(1)

{ saClntLen=sizeof(saClnt);

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

6 u) u* v4 K5 c7 ^; l) Q

if(nchar<0)

* L; _; e; V) `2 s" }* Z% r

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

$ z: K% q7 z% f

=“Error in recvfrom\n";

pView －>InvalidateRect(NULL);

}

else

{switch(msg[0])

; U2 e' J0 M1 R1 Z* ?

{

case ‘A':

d: Y$ U. p2 S8 o& d

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

inet_ntoa(saClnt.sin_addr));

2 N3 f5 m0 M0 F0 [- E

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

/ b1 h& o. T' T* Y Z9 S3 u

pView －>flag=TRUE;

9 n' }! x. s& r6 p- x t3 ~

pView －>InvalidateRect(NULL);

& ?' B2 W0 _6 |; B, p

pView －>Isconnect=TRUE;

( k& X' z% s' N+ X

pView －>saClnt=saClnt;

0 L4 ~( \% x$ M$ U, \

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

- S- ?* _% R9 r8 ~9 t: v

break;

, o0 A# E: c( G& M. O8 C

& t# l) L# O6 l) `- [ |

case ‘D':

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

inet_ntoa(saClnt.sin_addr));

: q/ m( A L0 u Y* a; d \8 W7 I

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

, s! f1 x0 y% A' d$ ?

pView －>Isconnect=FALSE;

2 z6 \! O3 |( E( ?

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

6 E! Z, z* G+ e( `

＆saClnt,saClntLen);

break;

case ‘R':

saClntLen=sizeof(saClnt);

; Y+ b; n0 ]+ G+ j9 H5 z( ^

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

, `. s) b- c5 ~" N, c+ `, J

pView －>flag=TRUE;

, s+ i7 |6 X( z0 g2 j- D2 d

pView －>InvalidateRect(NULL);

/ o' Q5 a D' n" |: H3 S8 C

break;

default:

+ j, m1 |6 A9 L

break;

X5 `+ Y$ | {$ _& @

}

}

" v$ h5 C" w3 u

l! m! y5 T+ M* J+ p; t

}

/ N! E: y5 q2 q

return(0);

9 k2 ?; u1 \0 e* ]

}

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

　 　void CServerView::OnIp()

' _$ ?7 v$ B8 Z9 K

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

0 a+ c& o J7 Y N0 R+ U

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

( z7 o( p9 s8 v

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

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

7 G! w' M! M% j0 w( v! N

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

( G9 ~. s. `5 R/ X

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

, u8 D3 X; Y) ^ Y

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

　 　CString out;

　 　out.Format(Hostaddress);

" B% R, u6 d8 G7 \" j

　 　AfxMessageBox(out);

　 　}

}

}

7 {% q: Q" D% h" j& D+ f

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

　 　void CServerView::OnSendmessage()

2 ~2 F4 ?. x1 g8 N0 r! ^& j

{// TOD Add your command handler code here

char msg[2000];

0 D4 c1 n' e7 Q4 L/ @7 ^

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

6 p l! r5 W' W2 g6 X

＆ ＆!Sendmessage.m_Message.IsEmpty())

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

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

＆saClnt,saClntLen);

4 c/ v1 K _$ V/ m8 X; A6 E

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

+ t& w' m$ D$ N/ \

　 　flag=TRUE;

! @& h' i, S; {1 ^" t

　 　InvalidateRect(NULL);

9 p8 F6 S+ D$ G

　 　}

}

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

. Z, {3 \, @5 G' z o5 v2 [ q( h

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

0 C- Z* z# \' _* L+ b7 u; i

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

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

+ m! _, ?' E; e4 P

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

+ A/ {2 p% e% u( Q5 ~/ ]7 \

pCmdUI －>Enable(FALSE);

# k7 G2 m3 X( w# q

if(Isconnect)

pCmdUI －>Enable(TRUE);

+ |; A5 C8 C, ?! P! s0 R$ X

}

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

% a; r% V9 m* q( c8 Y# s) x( h

{ if(flag)

+ \/ f2 C2 F t+ q5 R$ `% H

{sizeTotal.cy ＋=20;

for(int j=65;j

TextOut(10,y,m_data);

, i) {( _) `# H! j; y6 T

y ＋=20；}

// TOD add draw code for native data here

}

' z! |8 l! d! {7 R; b

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

! p; U" z7 J; h: p; D6 Q4 }4 `

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

2 p0 v# p7 [7 g8 B; @9 e5 l

二、 客 户 机 程 序

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

( v. E- x3 ^9 B' z

在clientview.h 中 加 入 代 码：

＃include “winsock.h"

添 加 变 量:

CString m_data[1000];

HANDLE m_hListenThread;

, Z# @) o+ _: ~# |- o# ^

SOCKET m_sock;

1 S0 b1 \* _) {6 G

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

$ _9 p6 b1 G7 t3 I8 G

int count;

4 V: R/ E# U! m9 |8 Q4 W% g

CSize sizeTotal;

5 G9 R* b8 y+ s; [% T. r

BOOL flag;

- b$ \- T3 E% V& J8 v

5 o$ U. k3 ?* X- |$ `. t. s

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

; p+ [. B+ l/ T1 @8 U1 ~1 p1 O) g+ A

CClientView::CClientView()

{ // TOD add construction code here

Isconnect=FALSE;

5 w: g5 t9 C" x: p5 |

sizeTotal.cy=350;

% D1 T A0 n; X- }8 w4 @1 i

sizeTotal.cx=300;

* S6 v: w0 y% c: f

flag=FALSE;

+ F) P+ }/ Q1 L7 T/ C% X/ X

}

0 x* r5 r1 D H; J( g7 s% \

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

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

$ X! m" T* D. _* m& ~4 G

void CClientView::OnDial()

{// TOD Add your command handler code here

: n2 n6 v8 n. _

count=5;

if(m_bInitialized)

8 @( C4 t3 ~% n7 x

{ AfxMessageBox(“Already dialing");

' |* ~: U6 a, g& }3 B' ~

return;}

, m- E4 c( b. F% T

Cdial dial;

* @4 v" a' M( X0 Z5 K

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

7 w& y! N0 H; ]5 c: d

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

- M7 F; L+ Y; w9 F" t2 a9 k

(INADDR_ANY);

, R8 n) T$ [+ X- X8 {

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

; h# T2 z. E$ K, \- l9 g

(dial.m_HostAddress);

4 r F/ A0 w( O* r+ a' q% o

m_saSrvr.sin_port=htons(5050);

+ `/ z& `/ o% X" p. u

int status;

WSADATA wsaData;

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

% T& s0 j# x" P6 g3 `

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

+ Q* g) p, W: s, S, P, A

{ m_data[0] ＋=“Succeeded";

. v0 D; i( g3 R3 t# }' v# f. R4 g; c

m_bInitialized=TRUE;}

2 B% [+ Z0 U1 b# w% F

else

/ a4 o" j% r( t6 d5 J* o

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

2 Z# P8 ?! D+ z" w

if(m_sock==INVALID_SOCKET)

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

* ]: p" j1 E& L1 D! H

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

sa.sin_family=AF_INET;

$ X/ J1 o4 k- K# U U+ R+ o

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

& M* ^+ ~: G- H

sa.sin_port=htons(0);

9 M9 N0 C" ^" s9 U6 l/ @* @

if(bind(m_sock,(PSOCKADDR)

* V7 C! o9 X- L: n

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

- p% t& G6 h6 s5 e% ~

{ m_data[2] ＋=“Failed";

+ Q; l6 G( f# [" \$ q9 q

closesocket(m_sock)；}

m_data[2] ＋=“Succeeded";

' R. F1 n! }- S% _4 D) }

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

unsigned long idThread;

' D/ @. y* C5 S8 d: r

m_hListenThread=CreateThread(NULL 0,

' M* {" F' a( l5 m9 @, V+ K

(LPTHREAD_START_ROUTINE)Listen,

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

; e2 n5 c2 ]& n4 W8 {% I6 J

if(m_hListenThread)

& b$ n5 B4 X( T( I! E! T7 L

{ m_data[3] ＋=“Succeeded";

; X3 A/ S+ G; i0 y5 V

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

else

& F( f& }! W6 q" h1 Y

m_data[4] ＋=“Failed";

InvalidateRect(NULL);

}

}

) o% |6 |/ K6 c, b2 B5 E9 D" @! r

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

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

3 f, d- {9 @ O# m

＃include dial.h

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

4 @$ K+ k9 G) _3 w& f1 O5 n2 i

void CClientView::OnUpdateDial(CCmdUI ＊

$ N$ s; I0 V& [% V4 @5 z

pCmdUI)

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

8 B* h& c( ?8 r( ~8 @1 l: \/ a

pCmdUI －>Enable(TRUE);

if(Isconnect)

' a1 b3 [" E* _ T; h

pCmdUI －>Enable(FALSE);

1 T6 C* l* \6 Z) p( `, [

}

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

$ }# z# Y6 _) F2 d

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

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

pView －>InvalidateRect(NULL);

wsprintf(msg,“A: ");

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

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

5 F# y% V* f% n; ]8 w: l! i

int saSrvrLen ,nchar;

while(1)

9 L6 P( Y/ h! _

{saSrvrLen=sizeof(pView －>m_saSrvr);

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

8 d) v% ~% b8 ]+ W4 Y$ X

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

if(nchar<0)

8 B7 a: R3 x, U7 s9 D0 x

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

; ?" y* Q( _! W+ o

“Error in recvform";

. W7 b/ O$ w# L" i, g' o0 d! l

pView －>InvalidateRect(NULL);}

) T U* C8 ?& t( i: [

else

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

! s6 G& a) R0 s7 p& \+ s9 `

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

- g0 I& c9 k8 n

pView －>InvalidateRect(NULL);

; b1 ]% G3 A2 o: d; g3 e( _

}

}

return(0);

}

1 T+ i* ?% n& B. E9 j, M- b- e

& u8 E, n) j, @) S; L/ D

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

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

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

( s# Y+ ^( r- k6 q- }

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

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

下 的 网 络 中 执 行。