服务器与客户机互传消息

韩冰

一、 服 务 器 程 序

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

在serverview.h 中 加 入 代 码：

＃include “winsock.h"

4 S" d+ Y7 f! O+ U: r7 L2 n' `

添 加 变 量：

' z1 B0 f- r- o

CSize sizeTotal;// 控 制 滚 动 条

5 k; Z% j4 X# }6 ^- X- h

int count;// 信 息 条 数

: W0 [6 o. O# G

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

char Hostname[260];

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

9 e4 d: [4 G5 v6 ~

SOCKET m_sock;

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

& d1 {( x$ p5 I% r7 k+ [) Z! x

WSADATA WSAData;

9 ^- r: k. s, r6 m, s: H8 A

BOOL flag;

( h% H5 u+ R/ C+ {: v# Q* R

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

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

字：

; n8 ~2 J% `8 C

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

flag=FALSE;

X/ Y: m7 H+ D# \

sizeTotal.cy=350;

sizeTotal.cx=300;

m_hListenThread;

9 `+ x* y1 d1 Q3 z+ w# l7 y

count=5;

int status;

7 u& u+ E7 F+ S0 ]0 B p. ?) [

WSADATA wsaData;

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

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

{ m_data[0] ＋=“Succeeded";

+ w& F, v4 R! K. O K$ y

m_bInitialized=TRUE;

}

else

0 \) {" w: p' `# N

{ m_bInitialized=FALSE;

. s, o2 v: x3 D9 C2 ?: g

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

if(m_sock==INVALID_SOCKET)

6 c0 `# d' k& i/ I2 F- t T$ u

{ m_data[1] ＋=“Failed";

3 l; {* X4 _ N

}

) T3 B' }; ^) A3 g3 T# R

m_data[1] ＋=“Succeeded";

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

sockaddr_in sa;

sa.sin_family=AF_INET;

" C+ A6 B# I" v. R& u

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

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

4 b) _" w8 N$ n0 q- s# g' j

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

6 V& r5 G; K" N

{ m_data[2] ＋=“Failed";

" T b9 v$ Q- p% I

closesocket(m_sock);

' v8 s1 G/ G- E+ Z3 m5 Z

}

) ` V5 `4 i+ |

m_data[2] ＋=“Succeeded";

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

+ _! e& j# s, W- G5 t' K

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

+ a- }9 i! f4 k/ E, B; F+ g

(LPTHREAD_START_ROUTINE)Listen,

* a) \6 M- I8 u# o& q# G: g- D

(void if(m_hListenThread)

: {0 P% l3 d7 T$ @

{ m_data[3] ＋=“Succeeded";

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

# {' m9 q% w& U7 x0 G

}

else

0 D& F9 O0 S$ o7 t) N/ g8 R

m_data[4] ＋=“Failed";

}

& X7 V5 C8 a* Z9 l. j6 h

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

CServerView:: ～CServerView()

{ if(m_bInitialized)

2 v" T" [( z5 A# P) S

WSACleanup();

6 v8 | U( l% x+ C) [! c5 B

closesocket(m_sock);

- ~8 M! Y7 x6 F! J$ U- `

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

# }3 x0 a( B N. c

}

6 U# P# D& P6 w- R) e/ C, U: G- W

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

4 {# \ `( r4 u. _7 J# Z# d) B! R

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

; Q, H2 L* T$ f5 I( N1 v" O2 J

int nchar;

SOCKADDR_IN saClnt;

int saClntLen;

while(1)

{ saClntLen=sizeof(saClnt);

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

if(nchar<0)

, o) b0 _% [! w& C0 g

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

=“Error in recvfrom\n";

I5 J7 z# V% Z% @7 _7 `. w u

pView －>InvalidateRect(NULL);

}

else

* j# w/ @6 f. J" U. |

{switch(msg[0])

/ n- q& u# E5 C6 d

{

case ‘A':

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

; Z5 M9 c$ o3 G- s# ]7 s% |

inet_ntoa(saClnt.sin_addr));

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

" p3 R: P& h2 T+ ?3 D: O+ R1 V

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

& o- k; j+ ~5 K( d* Y) V. s

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

3 k7 v% R$ ]! L. a. V& F

break;

# c5 x( f3 U0 `4 {' u

case ‘D':

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

inet_ntoa(saClnt.sin_addr));

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

2 X# b* [7 m6 {' x& v& ]

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

- t& n" ?: g; Y3 Y

pView －>Isconnect=FALSE;

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

1 P+ V) M1 ?6 b) p; i+ ^1 X# j

＆saClnt,saClntLen);

0 P/ r% E2 u4 v4 [$ T6 h5 N

break;

2 X# c) d# {" j' T1 j

case ‘R':

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

! z7 \( C8 C2 |( E8 l

pView －>InvalidateRect(NULL);

( n3 T7 J) |. H6 P

break;

8 L, `7 u9 }$ y/ J& i) e, q8 K- Y

default:

break;

Z( H4 @1 A. U0 `

}

}

3 R9 O9 _& z: c5 K2 U

}

return(0);

9 b' ?4 h( X( V

}

; }. @1 v5 i2 Y& b6 D" E+ W

2 F7 Z2 l, _3 y4 r

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

' \" _$ l g$ p m" z( f" s

　 　void CServerView::OnIp()

r; B8 S0 s5 t- ^8 J5 f* H

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

$ f1 j9 s1 i8 Z8 e; Y

struct hostent ＊pHostEnt;

$ m! m7 y3 m/ c5 V7 Y

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

2 Y- p0 B, T) ]; V3 \: a2 c$ ]

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

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

]7 j$ N$ t6 |# D% H

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

; q+ @7 ~; ^5 `! ?

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

" o7 @) B1 k. D1 M# c6 y0 J

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

　 　CString out;

5 t; @6 O8 P+ u7 e3 k

　 　out.Format(Hostaddress);

/ ~! q) p& M8 \, f$ y0 B& i5 Q- S

　 　AfxMessageBox(out);

2 i+ `3 `0 b v u0 i7 Y1 P* S5 m! c

　 　}

7 F8 h2 M* r. x% C

}

5 l H+ @# ~) |9 a/ \

}

8 M( h: L$ D1 B" }+ ^5 q) a

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

char msg[2000];

Csend Sendmessage;

6 w4 C9 f* I. t8 z4 H

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

( W4 t* Z9 u' ?' ~- F7 p9 n' h

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

$ ?# p* [" T! d W# J

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

＆saClnt,saClntLen);

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

　 　flag=TRUE;

　 　InvalidateRect(NULL);

　 　}

) A& x$ d5 T" q* I! w

}

, d T# z; h5 j' x5 q m5 q+ ~9 F% ]

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

: |% P) p. y; B6 d

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

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

) J- E6 Y) x9 i9 v

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

" F0 K3 L* y& N/ k1 F

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

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

pCmdUI －>Enable(FALSE);

4 [( S$ _ ~$ j/ V ?9 L

if(Isconnect)

. M: R/ q) l. O/ ]! [

pCmdUI －>Enable(TRUE);

* N Z. B' m0 l- ^5 `1 e8 n

}

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

0 K8 D1 C* h' ~/ E

{sizeTotal.cy ＋=20;

: q, [& d; r e7 w' s/ Z

for(int j=65;j

TextOut(10,y,m_data);

y ＋=20；}

3 ~( ` u4 K& M, ]& m

// TOD add draw code for native data here

}

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

3 U1 j2 h" n' C8 x+ l% q7 O

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

, |( {' ?' b1 e

二、 客 户 机 程 序

, ~: `5 _6 F# o. h* W

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

3 ?6 ~; n- }; b( y9 F" U: v( ^

在clientview.h 中 加 入 代 码：

: R4 X1 Y- C& F# c8 y$ a

＃include “winsock.h"

添 加 变 量:

CString m_data[1000];

HANDLE m_hListenThread;

SOCKET m_sock;

SOCKADDR_IN m_saSrvr;

9 l/ U! `( ]2 V# B) B6 A

BOOL Isconnect;

}) B3 s- J# k, ]" t

int count;

% w+ y8 T* e* n* {, w

CSize sizeTotal;

BOOL flag;

, o1 O! k# d5 D; C' q0 p

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

CClientView::CClientView()

* c3 r. i- o" y4 b# o" c

{ // TOD add construction code here

Isconnect=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

+ m& M& M" |! P- W

flag=FALSE;

9 [) P, t% I7 k2 ]) V

}

# w; r& N% ^ K! O8 V: S: I$ t, j

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

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

void CClientView::OnDial()

1 m% Z) C8 t2 G, @

{// TOD Add your command handler code here

5 M( `( Z X) T4 _: u. ~

count=5;

' L3 z. Y! Y/ J5 f+ N! e

if(m_bInitialized)

/ k. r# R1 G( M5 a( \

{ AfxMessageBox(“Already dialing");

- I0 H; {( O- r6 e9 V$ {# Q% F

return;}

/ k- k; C1 }" x. j; m

Cdial dial;

; B- C% }, _7 s& k$ k2 H3 Z

if(dial.DoModal()==IDOK

, X# |. A' Y, b

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

1 S: [# L7 s" [; k1 K: O% T6 k

m_saSrvr.sin_addr.S_un.S_addr=htonl

. X9 O. v+ v8 ^0 m+ ^

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

m_saSrvr.sin_port=htons(5050);

4 N+ q5 g2 n" w+ l1 C

int status;

) U. H$ M0 }6 R! P8 G) x& G

WSADATA wsaData;

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

% }2 u$ z& \! d- X# w& @8 P* d/ o

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

{ m_data[0] ＋=“Succeeded";

m_bInitialized=TRUE;}

: \) h* w- g7 p& `1 e3 W

else

{ m_bInitialized=FALSE;}

& d; U5 S/ [- R) x2 U3 \

m_sock=socket(AF_INET,SOCK_DGRAM,0);

7 Y9 z' |& U3 M7 `, J. z

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

if(m_sock==INVALID_SOCKET)

' |# P8 F9 o. A5 h D) g

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

m_data[1] ＋=“Succeeded";

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

# \3 h; z/ ~3 i T1 Q3 `

sockaddr_in sa;

sa.sin_family=AF_INET;

/ v9 v4 J9 B. Z% F

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

sa.sin_port=htons(0);

2 H0 R& i7 @4 C+ m/ g- I$ L; H8 d

if(bind(m_sock,(PSOCKADDR)

; ]% B# @$ Z) f$ C6 Q1 Z

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

9 b# T* V, e6 S2 [7 B: a

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

' n$ ]5 N `: E0 m, D

m_data[2] ＋=“Succeeded";

5 z# k& h* g2 b6 W# f& h- `) @3 U. h

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

unsigned long idThread;

2 X1 p5 h7 ~0 A: }1 Y

m_hListenThread=CreateThread(NULL 0,

- p3 y% {& T ~6 Z8 }% V3 d: {% R& _

(LPTHREAD_START_ROUTINE)Listen,

+ |( J* T6 Z9 E1 u8 Z

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

if(m_hListenThread)

# C/ j$ G- T5 w5 E

{ m_data[3] ＋=“Succeeded";

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

else

m_data[4] ＋=“Failed";

9 x5 A5 s8 `0 C% x+ T9 P$ y

InvalidateRect(NULL);

}

}

\2 l, q$ Q4 D

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

* I* P+ t1 d: N; ^3 I

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

＃include dial.h

3 m h9 I+ V; u0 O* \1 ^8 Z

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

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

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

1 u; B: c- K1 K* \/ q; {3 N7 @

pCmdUI －>Enable(TRUE);

e9 ^) ^5 r, k. P/ v" R! A3 b

if(Isconnect)

! @+ h. ~ l, V! O1 o

pCmdUI －>Enable(FALSE);

}

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

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

' q6 Q: C/ }9 q, Z* \& P# [/ g

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

. [* z2 g0 f1 T$ C2 K _

pView －>InvalidateRect(NULL);

4 C2 D0 Q6 u. W" i; e/ `3 r: ~

wsprintf(msg,“A: ");

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

* y! u6 {. t. j j

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

& M# ]8 U5 R e3 y, p

int saSrvrLen ,nchar;

while(1)

( y+ G+ t! q, h6 W5 Y

{saSrvrLen=sizeof(pView －>m_saSrvr);

" s3 c$ B/ H* w6 o" Z7 G

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

! k; a2 a1 ]% d: B/ ^) c5 F( l6 i

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

6 ^& m* a, l4 z! r

if(nchar<0)

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

“Error in recvform";

2 b+ k3 j0 K7 L* f: m

pView －>InvalidateRect(NULL);}

$ w7 B! R* W: M9 e/ G. d

else

! r7 s5 \3 L5 p# a" `

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

, W$ [( `2 Q6 }- T# V

pView －>Isconnect=TRUE;

' V: v F* c3 @7 ]1 ^1 C

pView －>flag=TRUE;

! Z/ o8 D) W# v8 [8 R, ^1 U! l1 @

pView －>InvalidateRect(NULL);

}

9 j$ {9 d" n. }& C5 u0 l% j# N

}

+ x: o1 W2 W. B5 n

return(0);

2 v* s% w0 |) a3 s+ t) l3 d

}

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

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

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

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

9 a o* \, A ~

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

( `/ E2 l4 q1 s9 y/ r1 D# M

下 的 网 络 中 执 行。