服务器与客户机互传消息

韩冰

# t. I) z% U4 k. t$ d

一、 服 务 器 程 序

5 \% i- H# z% j/ L% {: t' C

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

在serverview.h 中 加 入 代 码：

6 J$ M5 |. |4 k7 ]. ?

＃include “winsock.h"

! f$ j! @" G# S8 a7 ]

添 加 变 量：

4 E% z1 D& ? y( o( w; Z

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

" L ^2 F. ?8 C U' [9 D

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

char Hostname[260];

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

6 s$ Y5 q, a2 A& F0 ]6 @1 X

SOCKET m_sock;

. h1 i5 R, y! a4 ^

HANDLE m_hListenThread;// 线 程

' Y: i2 U0 G: p% S5 d5 ?6 m* q

BOOL m_bInitialized;// 是 否 初 始 化

/ g( I2 b. p' C2 y, P: i9 O4 x% N

WSADATA WSAData;

BOOL flag;

2 B; D6 T; } |* E7 Q0 G* u2 c

SOCKADDR_IN saClnt;

int saClntLen;

% C4 a$ k) N t3 B4 l

BOOL Isconnect;// 是 否 连 接

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

字：

. [) [0 A" f5 ?! K- {& W

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

( Y! l* F, J8 `

flag=FALSE;

sizeTotal.cy=350;

0 q* N% K+ l$ `3 C2 O0 j

sizeTotal.cx=300;

m_hListenThread;

2 X2 T1 s7 C4 U/ ^2 A

count=5;

* [3 ]; t( P4 S

int status;

WSADATA wsaData;

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

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

{ m_data[0] ＋=“Succeeded";

9 d- U/ X. L( p/ }

m_bInitialized=TRUE;

: ~+ I+ U6 ^( G

}

else

{ m_bInitialized=FALSE;

}

6 D: A6 T0 ^- Z

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

6 u& V7 K; Z5 |% c6 `. ?* }0 p4 p

if(m_sock==INVALID_SOCKET)

* q: n& }4 [( r& P4 X0 @6 a

{ m_data[1] ＋=“Failed";

& p) ]) g& @4 L- s$ Y

}

% x0 `7 y: h h# y9 |4 B# @/ Z+ q

m_data[1] ＋=“Succeeded";

: c+ Q+ @2 U8 f* N

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

sockaddr_in sa;

sa.sin_family=AF_INET;

( S/ ?: e) C4 Z& X9 N% j" d

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

- n& X2 e* n1 c! x

sa.sin_port=htons(5050);

9 a8 ~$ c9 n4 u$ m, c

if(bind(m_sock,(PSOCKADDR)

" r7 A: {$ t$ ` G. F

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

{ m_data[2] ＋=“Failed";

closesocket(m_sock);

% K# Q0 ]6 {( g

}

m_data[2] ＋=“Succeeded";

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

0 q1 ?) x; v- s. \) g+ Z6 K, ^

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

+ Z0 ^# m4 u9 e3 n( J

(void if(m_hListenThread)

# Z- j _; f7 g

{ m_data[3] ＋=“Succeeded";

; k' l) T9 z4 V% G" ?

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

) f7 W+ j m6 f/ F- e7 w

}

else

- v1 o8 a% R" D# v) ]% W* c

m_data[4] ＋=“Failed";

}

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

CServerView:: ～CServerView()

{ if(m_bInitialized)

WSACleanup();

' r, S! L g( @

closesocket(m_sock);

; u5 K+ I Q2 ?, T# W o _% i' q/ N

if(m_hListenThread)

/ h; O2 B, @9 t. z6 T/ Z2 h

::TerminateThread(m_hListenThread,0);

}

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

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

int nchar;

& W- \' Z+ U' _

SOCKADDR_IN saClnt;

# K7 M8 z. G0 v6 y$ Q3 H

int saClntLen;

while(1)

{ saClntLen=sizeof(saClnt);

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

6 X; e P% ]! ^; @0 h6 E

(PSOCKADDR) ＆saClnt, ＆saClntLen);

if(nchar<0)

\; ~7 T& J2 \2 t

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

8 M' Z' ^; w7 s

=“Error in recvfrom\n";

8 t8 E5 ?; N" }& Q1 i

pView －>InvalidateRect(NULL);

}

, G9 K3 G; q* ~

else

. _$ `5 r2 q$ p4 | B

{switch(msg[0])

_% R" I5 M, o, E7 M, ^; c

{

case ‘A':

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

inet_ntoa(saClnt.sin_addr));

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

- x0 |9 ~/ s' q- f# K% N

pView －>flag=TRUE;

; M3 p: L3 ^- `- U0 Q$ L2 @

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

- i6 H: c# n- O4 n5 K6 i

pView －>saClntLen=saClntLen;

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

' j7 V3 `& c) H B3 `0 A7 I8 u6 H# Q

＆saClnt,saClntLen);

0 t1 O" Z! m$ [

break;

1 t c* \9 E$ S1 P) \4 y/ w

1 r; d0 `" @4 o! q" `* g/ m6 o: }

case ‘D':

- _, P; D5 W: }) U

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

) i# }" I3 R+ ]' L6 J/ u2 K% Z0 I; W

inet_ntoa(saClnt.sin_addr));

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

$ g% {3 _- c O/ ], t' i

pView －>flag=TRUE;

* k$ j/ p' \3 @, Q" I. F9 Z3 K

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

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

＆saClnt,saClntLen);

9 Q5 N, @* B# |' z- B/ W& g7 j8 y( v# \

break;

0 X& W* X* S$ J# n2 F( W" o& |) |

. |, |# n7 F: z7 A

case ‘R':

0 D |. b V' s. t8 b# S* Q

saClntLen=sizeof(saClnt);

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

. y- ~% r8 x3 x6 F1 E$ Z

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

break;

% P1 {& g7 L9 ?7 n" A

default:

% R. m. m! S1 }! O. c5 E

break;

- z" r* ?" }- w8 t. l* G3 W3 U c

}

}

; D9 B' W2 ~7 |

}

' w4 n9 }/ ?1 ?6 O- B: V1 [

return(0);

/ U0 w; \! R1 ` n

}

- \$ m3 e$ s' V, ^! j9 H

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

　 　void CServerView::OnIp()

8 H5 M5 v! O: Z0 q t

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

* @+ \ i0 L% U' L* e- r

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

- E( T; i0 t( |

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

4 l3 c# F" L' g1 {

if( pHostEnt != NULL ){

9 T$ w6 e* G4 Z% \& L% e

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

# ~7 u P9 e2 @9 I# ^

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

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

) t$ p4 S! {" t$ _; _; I

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

A$ _% @$ o2 o* ~) n2 l! {$ \

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

! X: C- H& Q1 H* D. r4 q

　 　CString out;

　 　out.Format(Hostaddress);

: j6 V" H8 X( b5 R) L- [; ~

　 　AfxMessageBox(out);

　 　}

}

}

3 ~* `' S7 U) F. _; B+ j

8 z' w4 s# }7 P3 [

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

, V7 s$ B+ L1 T, t& O

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

3 m/ r1 F; |. ?# h

char msg[2000];

: b+ F5 E7 `4 H' Q" f

Csend Sendmessage;

if(Sendmessage.DoModal()==IDOK

! n n3 H$ e) v

＆ ＆!Sendmessage.m_Message.IsEmpty())

. l4 q) p* ~9 [0 ?

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

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

' L$ k6 z8 H% l; ~& ?

＆saClnt,saClntLen);

: Y* l7 Q" {: C7 L& |8 S

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

8 b$ E/ N5 {! v6 y0 q

　 　flag=TRUE;

) N4 o* q. Y" L r# r

　 　InvalidateRect(NULL);

　 　}

}

% |/ k, s; e7 t Q

6 W8 i' r. E$ W; b1 [+ {6 q

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

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

, f2 [6 o6 s6 K( X$ i$ M: |

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

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

& J7 b$ ~) p0 y$ m+ N8 ?: C; w

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

i8 g! Y/ y/ k4 f! Z

pCmdUI －>Enable(FALSE);

* O5 ~! V3 ]1 O4 H- ?/ g# o8 D% l

if(Isconnect)

Z( S2 E" `0 J0 ^

pCmdUI －>Enable(TRUE);

! h# F t b4 W- h6 q

}

$ T3 f4 h1 M0 b8 o5 L. m' h

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

1 [& l$ i* i1 L

{ if(flag)

- N, \( v% U; k& a ~6 B/ O6 ~6 j

{sizeTotal.cy ＋=20;

for(int j=65;j

" E3 }$ E+ O, X/ g

TextOut(10,y,m_data);

y ＋=20；}

2 T. o4 \) v; x4 R

// TOD add draw code for native data here

) H7 b- ?& L' B+ J* I, S; V( [

}

, Z- _- K& x/ m7 h

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

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

, Q2 U) d4 j- j; `# x. p

二、 客 户 机 程 序

% X& V$ ^5 H! d* ~( h3 r

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

h( b+ ]3 `; q2 O

在clientview.h 中 加 入 代 码：

- w% ^! b" C* z5 ?7 U) q" Y

＃include “winsock.h"

9 [. Z M5 b; Q) Y( M

添 加 变 量:

CString m_data[1000];

HANDLE m_hListenThread;

! v# f- Y. A) u

SOCKET m_sock;

, f" b# q& Y4 O1 U* W% H

SOCKADDR_IN m_saSrvr;

5 o8 }% M+ L' e9 X+ y$ ?* h

BOOL Isconnect;

5 S2 ~4 ^* Y' `0 v

int count;

2 d1 q- L, M e

CSize sizeTotal;

1 d8 Y" a4 |8 L: ^% L5 J3 y3 h) L& o6 V

BOOL flag;

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

CClientView::CClientView()

" R. Z1 x5 b8 p

{ // TOD add construction code here

Isconnect=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

: Z0 k v) V. H

flag=FALSE;

4 \3 ^7 l$ Q" V2 n4 @

}

& g! c0 O0 n8 a2 U9 B

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

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

void CClientView::OnDial()

4 F; ]7 }! v; m7 ]( B' B

{// TOD Add your command handler code here

+ q9 |! z. z O$ ?4 a) E

count=5;

if(m_bInitialized)

; {3 `3 b; z' i+ O# K% q" E1 {

{ AfxMessageBox(“Already dialing");

return;}

' N1 b; k/ F, m

Cdial dial;

if(dial.DoModal()==IDOK

' B- M4 j& L& K# F

＆ ＆!dial.m_HostAddress.IsEmpty())

) h3 Q( X/ B7 R1 S+ ?9 ?% y& w

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

, [4 g1 Q3 w1 L F; y: y

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

: j% T% g- Z4 K7 c: `

(dial.m_HostAddress);

5 U7 b+ a8 V) p3 P" B% x6 N z

m_saSrvr.sin_port=htons(5050);

( T7 P" D& f! V$ h

int status;

WSADATA wsaData;

1 j# g. @- Z. Z) h( ^, E# O

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

* A& \; Q) C6 ^

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

; F0 G- i1 m% H

{ m_data[0] ＋=“Succeeded";

6 _( M! G/ ^+ s

m_bInitialized=TRUE;}

3 U# T0 C# e5 t% s8 H; i& H

else

k" U9 `6 I9 a2 h5 n! e

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

g$ @; u: B: A9 G* d

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

$ L' H1 }- c1 w& q+ W) Q

if(m_sock==INVALID_SOCKET)

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

m_data[1] ＋=“Succeeded";

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

# A# {) g: P4 w( [( {: Y9 n0 d

sockaddr_in sa;

9 x/ J* O2 a6 V, i* K$ H- J

sa.sin_family=AF_INET;

: r* r+ ]: f+ _, i5 J5 P

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

* Z5 y) q0 Q$ T' l1 Z! M4 D

sa.sin_port=htons(0);

6 c! M, K1 G" Y! M I$ ]( }

if(bind(m_sock,(PSOCKADDR)

4 P" u: F9 Z- D- r

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

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

m_data[2] ＋=“Succeeded";

9 _, Y4 d& ~( B# v! e2 I& j

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

unsigned long idThread;

2 R1 t( d2 L2 @; E- J

m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

9 A0 y6 i1 y& ], H

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

# Z; }. n7 z; d) U& d& E9 Y5 p

if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

& F" @. L0 v. i) |

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

\9 r6 }( g# X+ \

else

m_data[4] ＋=“Failed";

8 [* W. J9 E: M, u

InvalidateRect(NULL);

}

}

1 q; m9 l; j& ?7 A4 j

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

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

7 n& T2 v& ^. `7 A3 U# u

＃include dial.h

8 T: _" F# |1 N7 f7 W$ c

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

! E# J y" ^7 J4 i y

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

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

pCmdUI －>Enable(TRUE);

( |9 [7 R! T( l/ V! Q8 n

if(Isconnect)

! Q( g8 G; P) z9 T8 D

pCmdUI －>Enable(FALSE);

/ ?0 A$ |: n1 Z! ]1 ~6 [3 y1 |

}

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

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

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

. Z" }- j# w. O% G" q2 @- r. w

pView －>InvalidateRect(NULL);

6 T# {7 x/ j+ f* k) [

wsprintf(msg,“A: ");

# j& N. Z% I/ [4 |/ x! L: ]* R, e

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

# [/ m! M8 |1 @7 c4 _( Y

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

int saSrvrLen ,nchar;

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

1 P2 d5 o5 {: Z. @& l) h

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

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

: ]5 W, G6 g4 }: _5 Y3 R# {# O

if(nchar<0)

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

. M' t: Z& q: f' O5 }$ U% ^6 [

“Error in recvform";

8 X. N; H, ?# B6 o2 J0 ] Y% |$ @

pView －>InvalidateRect(NULL);}

! ^$ V. t% U7 V* Y G, x

else

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

3 E; p+ V9 O$ n$ Y: G9 z

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

2 m# r6 Y* w q. f6 q

}

6 [+ A6 i7 p/ j, t0 |1 ^

}

Z5 c4 c, G; {

return(0);

}

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

8 v0 s) L- A: x6 W4 O$ j. T

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

/ ] G0 {4 n$ y) C3 a- x T

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

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

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

' t% y& j$ X5 h( _5 G# S, {) Y

下 的 网 络 中 执 行。