数学建模社区-数学中国

标题: 服务器与客户机互传消息 [打印本页]

---

作者: 韩冰    时间: 2005-1-26 01:16
标题: 服务器与客户机互传消息

一、 服 务 器 程 序

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

在serverview.h 中 加 入 代 码：

! Y' W5 b: H a0 i6 J4 X+ ?8 Y

＃include “winsock.h"

& X5 K7 {0 M4 _# N* L5 a( d2 ~! C

添 加 变 量：

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

% g7 H$ M i. i9 x

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

char Hostname[260];

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

" K6 ]! X; B' Q

SOCKET m_sock;

, l& D" J5 ~! o) B( v

HANDLE m_hListenThread;// 线 程

BOOL m_bInitialized;// 是 否 初 始 化

# P' ]& d$ z6 \% V! D9 S3 @! v

WSADATA WSAData;

1 T8 Z& L# B5 W$ y( [* I

BOOL flag;

SOCKADDR_IN saClnt;

' e3 W/ a) R8 e* u$ n

int saClntLen;

BOOL Isconnect;// 是 否 连 接

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

* Y, K+ m& ?/ T8 q8 G/ E# m, N! O% ~

字：

CServerView::CServerView()

7 D/ e7 Q; h: ?! T

{ // TOD add construction code here

Isconnect=FALSE;

4 m* R- e% [9 O' t& U

flag=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

* A0 Y2 {' t2 j2 M& A% ^

m_hListenThread;

count=5;

( c) \- }) [2 ^, w5 d

int status;

WSADATA wsaData;

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

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

F$ C6 S9 U7 J J# d

{ m_data[0] ＋=“Succeeded";

; P+ ~5 r7 N. K6 j7 B

m_bInitialized=TRUE;

3 @! }$ R* c$ [

}

else

{ m_bInitialized=FALSE;

' X) C: e9 q {* p+ p& e

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

: K3 B" M( I4 }# R0 B

}

m_data[1] ＋=“Succeeded";

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

1 N1 ^. D) A* ~; n4 p7 o

sockaddr_in sa;

2 w7 B) k! ^. F" V3 B& t, m6 P

sa.sin_family=AF_INET;

' M$ u- g3 H' e+ n7 m" W

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

sa.sin_port=htons(5050);

% _4 l# \0 T* c: y- V, A; x( V+ N

if(bind(m_sock,(PSOCKADDR)

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

8 H( p0 b4 @" F; U. R8 [) C

{ m_data[2] ＋=“Failed";

y3 k) J- r+ X' H, d

closesocket(m_sock);

. v# y- }8 }, t, B+ {; S$ _* n( t

}

m_data[2] ＋=“Succeeded";

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

* G! S. D W9 k2 A+ u3 s4 _

unsigned long idThread;

6 J3 y) x4 c# Y$ B, X

m_hListenThread=CreateThread(NULL,0,

% }- x, _$ o' y2 Y7 h4 r+ r5 J

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

" B; W% Y3 a( p9 f( ?: P

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

9 c- ]. i- p$ M

}

else

m_data[4] ＋=“Failed";

$ F( G( i0 y( |

}

" r [ M3 H3 z r

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

CServerView:: ～CServerView()

% p0 F! v8 g2 l4 D

{ if(m_bInitialized)

WSACleanup();

closesocket(m_sock);

" u( h9 r6 R4 |& t1 f

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

" Z6 i* e7 l3 ]* X" L

}

6 E% U9 P% J# e% \& r

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

7 E9 B% O/ y+ k& P

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

( ^8 w, v1 L! d/ x7 A

int nchar;

SOCKADDR_IN saClnt;

int saClntLen;

while(1)

. B$ S& x0 P4 t2 f6 |

{ saClntLen=sizeof(saClnt);

' n+ }1 I( {2 o6 {# O# u

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

; h2 ]1 E+ p6 D/ J. V$ P

(PSOCKADDR) ＆saClnt, ＆saClntLen);

3 i7 e$ U, ?8 H+ E

if(nchar<0)

& j1 e, Q4 _9 w# a2 L9 ~/ R

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

! R' h1 I* P/ J

=“Error in recvfrom\n";

( m5 b2 H2 q# J- m$ C# s

pView －>InvalidateRect(NULL);

4 K: M; @5 F& h3 n

}

- x' F- O K3 S9 p* e( S

else

{switch(msg[0])

{

( l1 N' u9 D: \5 |' b8 }

case ‘A':

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

, h- t+ C# k2 Y; J" W/ ]

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

; g. a# A8 \2 U8 E0 ]7 _; _: F

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

( A7 A3 F9 w! t

pView －>saClnt=saClnt;

1 F; f. ?) J' U) ~( o

pView －>saClntLen=saClntLen;

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

7 g9 F# g3 T1 P; E1 P6 u

＆saClnt,saClntLen);

break;

- ~. e. k0 @& Z! T

# J; R e* n: g' W2 f

case ‘D':

7 {7 K6 |! j, g( y

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

4 W8 I6 t3 g$ b0 u

inet_ntoa(saClnt.sin_addr));

) e7 ^2 e! G2 Q' ?! k3 B6 i

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

" \. ^* b5 U5 u$ d

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

6 {. }* i" q% u Z. X) a

pView －>Isconnect=FALSE;

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

＆saClnt,saClntLen);

1 T' R7 t& P6 c* N

break;

- M, H4 R( d9 @! J

case ‘R':

" n5 x' h2 i: k) i% T' r; p- d6 `

saClntLen=sizeof(saClnt);

2 H5 `3 p+ v! Y% s* |! N8 R

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

% f& b1 `4 Y( t4 K* y0 \

pView －>flag=TRUE;

$ H- R7 h9 p( W

pView －>InvalidateRect(NULL);

/ I0 ], T8 g) Q1 U' G8 _0 I

break;

8 \# p9 W- V p" d+ L* w# C

default:

break;

5 W0 S o* ~) V3 O$ S4 ~

}

}

. b. e) F- S4 v) {' l/ b' s7 i

}

return(0);

* U0 q% q* T9 M0 D1 m. p5 }) }

}

5 c- D) b; j" k) `. x

4 v z! a0 R' @' t

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

6 T( h( F& J/ X" c. e7 B( q3 s

　 　void CServerView::OnIp()

6 l0 U, n- @8 q4 g5 S0 A S2 C- B1 W

{int WSAReturn;

0 N) ?3 J9 P# S! @7 {1 P/ L2 z

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

, z' i# Y) }- ^- X9 D0 d

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

- J! h1 t8 s8 E+ J$ _

struct hostent ＊pHostEnt;

2 w U$ T O- U2 u: b( f

pHostEnt = gethostbyname( Hostname);

- @/ p7 D' {$ e2 w4 G) Y

if( pHostEnt != NULL ){

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

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

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

! d. N7 C' K% B# Q

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

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

　 　CString out;

　 　out.Format(Hostaddress);

1 d$ O& Y! P" M

　 　AfxMessageBox(out);

　 　}

}

}

+ \# q* j, u0 U

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

　 　void CServerView::OnSendmessage()

2 ^6 m' G6 K4 u

{// TOD Add your command handler code here

7 L0 @7 m F1 H5 Z

char msg[2000];

3 O2 @) Y4 y/ ^! E) l

Csend Sendmessage;

; b6 l. s! B5 \6 R) W& t G

if(Sendmessage.DoModal()==IDOK

# v+ y& O7 i( |, r

＆ ＆!Sendmessage.m_Message.IsEmpty())

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

: O1 O- _5 |* ^

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

7 D ?( e: ~: l* G

＆saClnt,saClntLen);

$ ]" t/ j; h, N1 X) D% l

　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

; q# s- P c3 O" u

　 　flag=TRUE;

6 j% a, k1 x3 j$ @* ?7 {' b

　 　InvalidateRect(NULL);

, ^0 G/ T* r7 d1 l( f2 f

　 　}

$ b0 q$ }& w: Y+ K) \

}

4 @2 \0 F% i3 P% o7 r) ^( }

y! a* p& Y9 r, ?! F; B) E1 }& T

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

/ d* |- A6 x7 A5 P) q, ?

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

) M: g6 ?- \0 y+ o% v

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

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

! p! C5 K2 m7 W7 S: \* B5 I: E* }

pCmdUI)

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

! i8 y3 x- P. @7 V. ]7 }

pCmdUI －>Enable(FALSE);

: h+ L$ O- V( E. D8 Q& m

if(Isconnect)

pCmdUI －>Enable(TRUE);

4 n! h: V) J4 D$ Z2 y

}

# O: c% h5 W- a; U7 X: N! S1 j5 C7 E

( r; _% \* X1 t, A8 W1 f5 k

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

{sizeTotal.cy ＋=20;

9 s& ^. P! l1 G; |. X* t

for(int j=65;j

& L1 N2 P- H, X) x2 s

TextOut(10,y,m_data);

y ＋=20；}

// TOD add draw code for native data here

9 f: G; |* G6 j1 n) w+ ?

}

) U9 R- [6 z$ A4 y& G

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

2 M4 _- B; f! A+ H1 A( J+ i

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

* k9 h! R' `; s' C* p2 f

二、 客 户 机 程 序

W( h' F" i0 |9 l, q8 O4 A

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

在clientview.h 中 加 入 代 码：

+ J5 B$ [2 H& g& u( ]% ~

＃include “winsock.h"

添 加 变 量:

CString m_data[1000];

4 I0 Q3 E* X( N7 q1 V3 A7 j5 b

HANDLE m_hListenThread;

& W: r* f% q+ v. c- L

SOCKET m_sock;

( g- i* A; _4 g; m! ]6 N

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

$ l- W/ j$ f9 U, p$ V& `& r

int count;

; z3 b+ w4 y1 A0 h9 f, v# U% b

CSize sizeTotal;

5 j2 D- k* _: J

BOOL flag;

& h' ?- P ~' S$ P5 J R# L

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

1 T E; ]8 O; H, Z6 d

CClientView::CClientView()

{ // TOD add construction code here

Isconnect=FALSE;

5 h# L) v8 B l5 b7 I( u

sizeTotal.cy=350;

% p& C2 o9 F) O* n) x- g

sizeTotal.cx=300;

0 Z* K& G0 ^( b/ h" j0 Q

flag=FALSE;

}

) E* X/ M6 @' ]/ j

; a' d2 X& ^0 n0 m+ L) O8 Q

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

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

5 }' G R! Q, c

void CClientView::OnDial()

+ n( F8 P- A5 J3 ], {6 B6 j: @

{// TOD Add your command handler code here

count=5;

if(m_bInitialized)

{ AfxMessageBox(“Already dialing");

return;}

Cdial dial;

if(dial.DoModal()==IDOK

u* k, u! e2 P" K3 T1 C

＆ ＆!dial.m_HostAddress.IsEmpty())

5 B' f6 X1 V: F% d/ F3 h5 ]

{m_saSrvr.sin_family=AF_INET;

; Q0 k/ ]/ m G8 @( U. U

m_saSrvr.sin_addr.S_un.S_addr=htonl

- ^/ h" V6 B f$ X

(INADDR_ANY);

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

5 O3 N q3 j; Z- |5 n3 D0 B

(dial.m_HostAddress);

- \$ H1 U# j( {6 P; Q; {

m_saSrvr.sin_port=htons(5050);

5 u7 e, ~& r* ]6 ]+ l) a7 b, \9 W

int status;

WSADATA wsaData;

: \9 r4 m& m( C7 }+ l7 b

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

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

" \2 K; [+ v) X

{ m_data[0] ＋=“Succeeded";

4 y6 }) \5 b0 b% G* V8 W

m_bInitialized=TRUE;}

else

{ m_bInitialized=FALSE;}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

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

if(m_sock==INVALID_SOCKET)

7 W H4 Y6 ^: W0 s0 r

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

m_data[1] ＋=“Succeeded";

, ]7 W# a9 J6 E/ V, ^& S

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

& Q' B: n& ^& e7 @9 N

sockaddr_in sa;

( C/ W& ~3 I* k3 r7 B, Q0 ^

sa.sin_family=AF_INET;

, C8 R" k" N5 d

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

sa.sin_port=htons(0);

if(bind(m_sock,(PSOCKADDR)

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

% ]. U$ a I3 N6 X2 e$ e& ?

{ m_data[2] ＋=“Failed";

) O6 N) c* K" _: v- C

closesocket(m_sock)；}

7 \0 l: }% }3 q# B# J9 ~- }

m_data[2] ＋=“Succeeded";

, H) Y; x1 M( }! M! h' a

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

unsigned long idThread;

5 S6 }7 j8 n5 } R: V

m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

9 ?$ @+ G8 \3 A8 q; Q- e

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

) C- c& i+ M) N9 I7 b

if(m_hListenThread)

1 I7 q& s7 W) l% {$ A

{ m_data[3] ＋=“Succeeded";

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

else

m_data[4] ＋=“Failed";

3 V2 ?% I, l! z6 u# A

InvalidateRect(NULL);

' F: k6 c+ k. v

}

}

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

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

＃include dial.h

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

void CClientView::OnUpdateDial(CCmdUI ＊

( P6 D8 y" S1 j$ y; C

pCmdUI)

9 x5 n! r& E i

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

pCmdUI －>Enable(TRUE);

if(Isconnect)

pCmdUI －>Enable(FALSE);

4 j1 Y& s2 @- Y# D7 ?

}

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

. o% y0 L. t# y

long WINAPI Listen(CClientView ＊pView)

$ m! r& p- B% i5 I( u/ X4 L

{ char msg[2000];

- \0 e" m3 t7 m6 \5 ]

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

pView －>InvalidateRect(NULL);

Z2 |0 s& c0 |# O

wsprintf(msg,“A: ");

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

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

; v: ]* q. W( M1 a

int saSrvrLen ,nchar;

while(1)

{saSrvrLen=sizeof(pView －>m_saSrvr);

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

& ^0 b& {. P' R% x

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

- k7 z0 J# y4 ^( ~: c6 K4 P. Y

if(nchar<0)

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

/ o* {* l# j g2 E9 a2 E

“Error in recvform";

pView －>InvalidateRect(NULL);}

else

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

pView －>Isconnect=TRUE;

9 O( F1 Y4 G6 ]( C

pView －>flag=TRUE;

4 j) T# t1 C6 q, K" i4 b, s/ M& M

pView －>InvalidateRect(NULL);

}

}

9 Q7 T' t: M4 Q. x

return(0);

}

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

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

/ `; m5 r) |! |

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

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

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

( l" `9 r% S" I! ^+ f2 v1 h

下 的 网 络 中 执 行。

---

欢迎光临 数学建模社区-数学中国 (http://www.madio.net/)

Powered by Discuz! X2.5