服务器与客户机互传消息

韩冰

; U$ W+ j8 q: O6 @

一、 服 务 器 程 序

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

在serverview.h 中 加 入 代 码：

$ u0 t( r/ o/ O% t% w

＃include “winsock.h"

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

8 M. u# |. S+ N O. d

int count;// 信 息 条 数

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

" ~+ q* D0 x; z" h+ `$ C

char Hostname[260];

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

SOCKET m_sock;

' ^" h& z4 A ]

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

WSADATA WSAData;

# H" b% f! E% Z

BOOL flag;

& i C) p0 S K! U) d

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是 否 连 接

% K) ~ r; N$ d& r( Z% z

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

字：

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

flag=FALSE;

sizeTotal.cy=350;

# ^; N& I; l1 K

sizeTotal.cx=300;

m_hListenThread;

count=5;

int status;

WSADATA wsaData;

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

. ]: x* B2 ?) F. }

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

{ m_data[0] ＋=“Succeeded";

% R2 e9 i$ o/ V+ [; [" r( v$ j

m_bInitialized=TRUE;

! U6 q4 ?) @4 T4 ^) ]( k8 }/ S1 c

}

2 S5 M( |7 S+ n! B4 X) f

else

{ m_bInitialized=FALSE;

}

9 s5 Y* `* c5 c$ o' G8 \- x+ p$ J

m_sock=socket(AF_INET,SOCK_DGRAM,0);

' ^, N" H$ i) E: E& X/ b

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

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

}

m_data[1] ＋=“Succeeded";

7 ^' E. s9 l. B

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

sockaddr_in sa;

$ c* }. j2 v& E

sa.sin_family=AF_INET;

?6 O$ j/ [" V

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

" j R9 }% W/ K1 v9 A, t

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

1 n3 |6 p6 j- A) b" p

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

{ m_data[2] ＋=“Failed";

closesocket(m_sock);

# O" U" C }+ _0 U: n

}

m_data[2] ＋=“Succeeded";

: \2 f- J- u+ D) y/ A

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

5 I8 d* e( N4 x: e: O& ^& @

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

, L. c: J3 d7 C! S. n) l3 [

(void if(m_hListenThread)

4 o- _6 A' l. I! a3 x/ [

{ m_data[3] ＋=“Succeeded";

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

5 n( Z: ~% l9 [! m) t

}

+ w E! f! g0 _( o. \) C+ M

else

m_data[4] ＋=“Failed";

}

3 _; x$ G4 ?2 n1 O

+ q. q' g8 o5 n6 W

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

4 `2 o, k6 X, a% S4 L7 u6 }- R

CServerView:: ～CServerView()

{ if(m_bInitialized)

WSACleanup();

7 P7 ~; {' Q( x% M5 K: G

closesocket(m_sock);

if(m_hListenThread)

! }( Z: {' j' B) h0 v: {$ V" t

::TerminateThread(m_hListenThread,0);

( U4 c$ f1 ]2 E

}

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

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

" {! i7 d- f$ S$ ^

int nchar;

SOCKADDR_IN saClnt;

int saClntLen;

) j) [4 I/ V; E- _, P) c

while(1)

{ saClntLen=sizeof(saClnt);

! w% D+ \7 W" S' r

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

; d6 @" I$ p5 q! j8 z* o, d* [

(PSOCKADDR) ＆saClnt, ＆saClntLen);

3 m" n2 N" M# t

if(nchar<0)

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

=“Error in recvfrom\n";

pView －>InvalidateRect(NULL);

: ]/ A' t: S6 _- R! |; a4 g

}

$ e/ ?* m- @, [' _

else

$ R+ Z6 _/ G2 k2 {

{switch(msg[0])

" `: v, r5 Q4 D6 E& V

{

$ H: k, M( Y2 I& M8 M: b: }% l

case ‘A':

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

/ L' X3 C0 v9 L2 P2 z2 k4 T `" }* a

inet_ntoa(saClnt.sin_addr));

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

- [1 g% ~8 u8 Z8 O- C( a. x" ~1 T

pView －>flag=TRUE;

/ k4 F2 x2 M' D$ j

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

9 L: R" ]9 Z5 i$ C9 Z! r

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

" |9 G8 n3 ]% |% p7 `; R# }7 J" i: f

＆saClnt,saClntLen);

break;

. p) N% C# V- F: A

8 c; L, ]' h- O& [7 B9 R8 s

case ‘D':

/ v: |: _. x: T1 K+ B. d6 B! I

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

% W3 ]; c* h" [: g9 I; b6 T' m

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

" c6 y* O* e% `/ d

pView －>Isconnect=FALSE;

, u) g7 B# i0 ^# K5 k9 L$ K

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

＆saClnt,saClntLen);

break;

) X0 ~5 y5 x) t* ?% j4 {

case ‘R':

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

- T" i: I5 j& s

break;

# Y# W; j& ]2 b4 u q5 m

8 D/ [3 q0 n0 B; |2 x4 {, l: R/ \1 U

default:

break;

7 I8 d1 T" G! b; R( B5 g

}

, d! N) n0 i) p; P+ d6 Y

}

4 C& v. J0 H N& U# G

}

' C* j U p5 ~$ o* a/ U2 u1 P- A! l

return(0);

}

3 t- z0 r: G( Z+ e2 S, D

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

& j: ]# F! r6 T2 ]# N5 @

　 　void CServerView::OnIp()

' h6 I* X* E, D$ Z. a$ u! ]& i+ [; w

{int WSAReturn;

( B4 l9 a. c4 I( x7 ~3 g

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

5 X6 f$ |! T. ^; {

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

$ a4 _( P* ?( O5 b

if( pHostEnt != NULL ){

, c% ~* `, Z: e4 j: I6 X% b

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

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

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

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

/ s& ?) H8 X! I9 M* k7 I- N

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

　 　CString out;

. |% D2 r1 T: u0 j# m9 I

　 　out.Format(Hostaddress);

　 　AfxMessageBox(out);

' R9 n1 y/ I! N$ H- x# |0 O

　 　}

% u4 \8 i$ F! N1 ?1 t: C

}

+ b- V, ? @: J, y9 p) a/ j

}

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

　 　void CServerView::OnSendmessage()

3 n4 [! _- l; u! A! p% `8 r7 n0 W

{// TOD Add your command handler code here

char msg[2000];

; y' j/ W! r/ j1 J8 s% y

Csend Sendmessage;

( e8 `0 V0 H7 g- Y

if(Sendmessage.DoModal()==IDOK

＆ ＆!Sendmessage.m_Message.IsEmpty())

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

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

＆saClnt,saClntLen);

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

3 f) V" g! ~+ f! |

　 　flag=TRUE;

' N2 z" S* L& i% i( E- l

　 　InvalidateRect(NULL);

　 　}

; k% {( Y& z* V, {: S3 k# H, @

}

; O. ?* u4 L" n! P2 o( _) I* G

% U/ R( {3 f& `) h( s0 w

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

1 w6 T2 R# i g% K r" L, c

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

; d( L2 H4 _. ]' X* L! q! l5 l

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

* j/ I/ }* B* B

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

2 E& a8 k9 [$ H# y* e+ l1 E3 }

void CServerView::OnUpdateSendmessage(CCmdUI ＊

* n4 t4 N9 x @& N3 s! H6 n

pCmdUI)

# C5 T1 L* u& K7 b6 M1 g* E

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

pCmdUI －>Enable(TRUE);

}

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

% a# E/ }$ h0 P4 N0 N

{ if(flag)

{sizeTotal.cy ＋=20;

- h N+ o% `. l0 `1 q; m& T3 W

for(int j=65;j

# _2 G* G! ~4 z7 _

TextOut(10,y,m_data);

y ＋=20；}

j1 ~- a( B+ M& F+ A1 j( M

// TOD add draw code for native data here

}

+ D6 m5 ~/ g; z | c/ `

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

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

. z, \1 ?+ L# I

二、 客 户 机 程 序

# Z5 z& i6 M+ L" t8 t

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

5 H5 o. p5 C2 P7 n) l1 M* t

在clientview.h 中 加 入 代 码：

7 H# j& R, h4 M' x

＃include “winsock.h"

# M% P: s' h, _/ K. @

添 加 变 量:

CString m_data[1000];

$ F. n- M5 z8 H6 _% {

HANDLE m_hListenThread;

SOCKET m_sock;

' }& V0 n, C, K" _# `: [' u: j- K

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

int count;

CSize sizeTotal;

- J! ~- l5 B3 Q, o3 C- ^. S

BOOL flag;

% ?0 U( A) R1 n; I2 j( H

( Z% V# X! |, V7 v5 x# R9 Q

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

CClientView::CClientView()

{ // TOD add construction code here

; ?: Q$ f @) \% \" F( o

Isconnect=FALSE;

sizeTotal.cy=350;

. g# o1 X3 P& O- o

sizeTotal.cx=300;

9 B% q* R( I9 A

flag=FALSE;

2 _' o* K( j0 D y% ?5 Z

}

/ G- [* D1 s* c( d# x

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

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

void CClientView::OnDial()

{// TOD Add your command handler code here

count=5;

3 A8 t8 {! t( Y" B. c* N/ h5 J3 V

if(m_bInitialized)

2 [1 t: K) b1 i6 N9 @5 g \# {

{ AfxMessageBox(“Already dialing");

6 F6 ^& B: z$ D1 i. v

return;}

Cdial dial;

if(dial.DoModal()==IDOK

) q& |/ Z7 ^! t4 ^4 W7 G3 r

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

; h! s0 a1 w- V

m_saSrvr.sin_addr.S_un.S_addr=htonl

* y9 n2 D# n/ E. U: S

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

- C, b' K' M( Y; R- A. |' j& S

m_saSrvr.sin_port=htons(5050);

5 V( j) b, a! Y1 n5 y; l2 F

int status;

7 Y6 G1 J9 X' R

WSADATA wsaData;

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

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

{ m_data[0] ＋=“Succeeded";

0 S4 u* ^/ S0 ^6 z

m_bInitialized=TRUE;}

else

{ m_bInitialized=FALSE;}

1 O* l8 A" d' |* I! _/ n

m_sock=socket(AF_INET,SOCK_DGRAM,0);

; l, a' J1 q0 n, J7 {) Z

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

3 J' \% q3 l u7 @$ F: v8 l o, g

if(m_sock==INVALID_SOCKET)

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

/ H$ |: S# m! E9 h8 ?* ?

m_data[1] ＋=“Succeeded";

: ~% [9 t: J5 b3 n% W, Z

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

/ P4 X. l$ }1 @9 L# Q

sockaddr_in sa;

$ x' P+ ]6 f8 `7 S: g& \

sa.sin_family=AF_INET;

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

sa.sin_port=htons(0);

/ X, l( \ J- B. L3 k3 u

if(bind(m_sock,(PSOCKADDR)

$ j2 X6 h4 E7 _. ?- {1 Y* |& S# [ A/ D

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

{ m_data[2] ＋=“Failed";

3 t* O ]% D: c y# N* i+ o

closesocket(m_sock)；}

8 d- x9 I0 ?$ w& F1 u- Q

m_data[2] ＋=“Succeeded";

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL 0,

v4 f" Y K: a* i7 n2 [

(LPTHREAD_START_ROUTINE)Listen,

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

if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

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

6 K8 p5 M4 m1 Q) G

else

2 [ p! f, E/ [7 e% C% {: |/ i

m_data[4] ＋=“Failed";

InvalidateRect(NULL);

; P; T& f$ i' b; e4 `+ c3 h) X

}

9 X. X' V* D4 d% v0 k$ X

}

7 y, C1 F6 B' `' l

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

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

# b Z2 R9 T; k3 a

＃include dial.h

( p1 U, X( @4 L0 z5 t4 P

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

7 H8 `2 m$ C3 |: h i; }

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

! I. J0 E6 a3 H

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

pCmdUI －>Enable(TRUE);

, N4 C2 x. U8 u L' Q+ Y9 r

if(Isconnect)

* O: z( ` _- k. I4 o2 N( \* H

pCmdUI －>Enable(FALSE);

}

. O* n$ I" q' L, x- Y+ Z" p5 I

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

long WINAPI Listen(CClientView ＊pView)

{ char msg[2000];

3 p7 z1 v2 c6 i: o8 @, z( p! Z3 O

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

int saSrvrLen ,nchar;

- B7 k4 V6 s9 P4 _) d

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

' M, k8 X/ }4 ^6 h C# b i

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

( O; ^ Q- v. ^. k6 i( I

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

if(nchar<0)

( ]( |% {, \1 Q& H

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

“Error in recvform";

pView －>InvalidateRect(NULL);}

else

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

pView －>Isconnect=TRUE;

4 g. U/ I5 G$ D1 S2 j/ `- w2 ]

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

}

}

return(0);

3 ]+ c; v# ^. o* y

}

$ Q9 E/ _4 G+ P! b+ _( R X

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

+ y6 @& B8 Z9 |

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

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

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

# E7 K" r: G; r( w L2 N7 T

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

下 的 网 络 中 执 行。