服务器与客户机互传消息

韩冰

# \9 r2 f( v5 T8 g

一、 服 务 器 程 序

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

在serverview.h 中 加 入 代 码：

/ n9 O% W( z7 h+ I

＃include “winsock.h"

添 加 变 量：

% r0 z2 [/ z+ W) D* Y" L- s

CSize sizeTotal;// 控 制 滚 动 条

int count;// 信 息 条 数

$ S' x4 e! O7 D! l9 V9 m. a4 e d

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

3 Q3 c: W+ m( V7 W$ `8 V7 ?

char Hostname[260];

4 Z! W! P+ t: P& p2 Q

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

SOCKET m_sock;

5 Z$ [) l |0 B. w& Q

HANDLE m_hListenThread;// 线 程

/ g; b# {, p# l: P% Q* F& q

BOOL m_bInitialized;// 是 否 初 始 化

3 b3 A" u/ `. u

WSADATA WSAData;

BOOL flag;

% U3 E s. O3 |# ]: C, _5 o

SOCKADDR_IN saClnt;

3 ?0 g0 T% p! w/ Y' K# t

int saClntLen;

1 K/ D+ ^5 `' i1 Z: T6 K

BOOL Isconnect;// 是 否 连 接

$ A/ L' J9 }: b- O& A) E

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

字：

* G \; x& a- C7 H8 u- G) v

CServerView::CServerView()

{ // TOD add construction code here

; i: z9 k) u: }% v% h9 K

Isconnect=FALSE;

4 e$ d$ k& b1 r* C, z

flag=FALSE;

sizeTotal.cy=350;

5 r3 V* A* a; c

sizeTotal.cx=300;

m_hListenThread;

count=5;

/ p5 X! g7 A4 f2 t; ]: H" S7 _- G

int status;

1 j: l# e3 o- |% Q( Q) M

WSADATA wsaData;

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

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

3 |5 p* Y# F) H, f; n

{ m_data[0] ＋=“Succeeded";

' F# h3 w2 ]3 O

m_bInitialized=TRUE;

}

: V; q$ ], j2 {

else

{ m_bInitialized=FALSE;

}

m_sock=socket(AF_INET,SOCK_DGRAM,0);

/ p# X, A& Z; Y) N

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

if(m_sock==INVALID_SOCKET)

{ m_data[1] ＋=“Failed";

}

; _4 [- C1 s* s/ H1 I

m_data[1] ＋=“Succeeded";

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

7 ]% l5 B# @3 Y0 E& Q' d" I

sockaddr_in sa;

sa.sin_family=AF_INET;

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

sa.sin_port=htons(5050);

if(bind(m_sock,(PSOCKADDR)

& o& s9 o J3 ~: M

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

{ m_data[2] ＋=“Failed";

closesocket(m_sock);

9 {9 M5 y+ k c0 ?, X

}

2 r- X8 O' l; P4 ]

m_data[2] ＋=“Succeeded";

4 u4 J; T: i9 _- |7 P, J2 d/ d% H

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

unsigned long idThread;

; R* A5 i! l* _& o7 Z3 r/ a1 {% H& m

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

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

}

else

/ p! ]# S6 j/ z( d" U' M; v$ k

m_data[4] ＋=“Failed";

}

0 R# }. p B5 ?+ z* s, Q. l( r+ q

% A2 S* X3 z6 J7 l+ b6 N x

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

CServerView:: ～CServerView()

# R" ^: V3 [1 d9 X1 P

{ if(m_bInitialized)

$ }& X% u Q$ i- j$ G, v

WSACleanup();

closesocket(m_sock);

, ~! B3 V- ~2 C" {

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

2 z5 l) e. \/ g4 |- D( q" y0 K9 H

}

, l+ [3 _) u( L

' x6 t1 Y1 W% \; }) t

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

# o' T8 }+ ^0 [) Q: l' w

long WINAPI Listen(CServerView ＊pView)

7 d1 t1 u O. ~% F4 z

{ char msg[2000]=“";

0 t( m) { F* _+ A8 F( r

int nchar;

1 g6 L' E: M* R/ P

SOCKADDR_IN saClnt;

int saClntLen;

& m6 C! g/ Q7 }4 b: |* Z' C

while(1)

{ saClntLen=sizeof(saClnt);

* l' h! l3 ^9 A! H

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

(PSOCKADDR) ＆saClnt, ＆saClntLen);

: ]& Y* C/ m5 P x' ]# [3 l& L( v

if(nchar<0)

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

=“Error in recvfrom\n";

( W# J0 H6 X' a

pView －>InvalidateRect(NULL);

) F& E* e/ j/ _( x

}

else

{switch(msg[0])

6 p# V5 Q" l6 k$ u

{

case ‘A':

$ s! Q: h$ X% }8 ]" w- e1 W

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

% |- ~9 G8 X- f4 \

inet_ntoa(saClnt.sin_addr));

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

4 W8 f! G6 r4 k d

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

% R) M/ ~ m/ `7 O3 v; e3 M: u

pView －>Isconnect=TRUE;

+ Y! I; t" {/ h2 o

pView －>saClnt=saClnt;

7 l u6 v" K9 n" p% F6 Z" {

pView －>saClntLen=saClntLen;

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

% C4 n1 c% ?8 }; Y" Z0 X3 }- M/ ~

＆saClnt,saClntLen);

8 A5 ?/ y1 C/ w2 x G' ]. B9 i

break;

% E! K7 y2 t0 u% f) g

case ‘D':

' Y6 D7 i7 \2 {) ?

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

( ~, D X8 B N0 V% f' I+ m" m, n

inet_ntoa(saClnt.sin_addr));

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

, t6 w/ {5 H4 v+ A2 V9 a

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

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

＆saClnt,saClntLen);

5 R, y3 g. k3 |, g8 F4 m- `' B4 e

break;

" c/ y1 L4 v( ?; X% }6 S

case ‘R':

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

break;

1 T+ [0 g9 y0 t% T) T. A

( V$ E% i# @- }2 \& A

default:

+ i& S7 |5 [5 x* f( Z$ g' ?1 o

break;

}

/ E1 O* [2 Q! _

}

}

3 o' e: j* |: e s8 c8 J

return(0);

}

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

　 　void CServerView::OnIp()

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

$ u: M# `: f8 t7 s6 S

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

; J* q% m0 S% t4 s; F# ]( L Z2 h

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

, s- m# N6 G+ _7 M

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

; K7 ?6 ?2 Z! \6 q$ w0 w

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

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

* T$ Q. m/ \$ _/ l, L

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

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

　 　CString out;

　 　out.Format(Hostaddress);

7 u0 T+ \4 R# D8 Y; p B% \

　 　AfxMessageBox(out);

　 　}

}

}

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

　 　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

- n" E' [; H- K7 b3 }- R

char msg[2000];

Csend Sendmessage;

$ n" q; A3 X. |2 E/ t3 u

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;

" e* [% R7 y0 q

　 　flag=TRUE;

2 B% S m7 k* H4 Z/ z7 o

　 　InvalidateRect(NULL);

　 　}

$ G8 _* x4 |0 E

}

% y- g/ ~2 P, T: v# }/ X

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

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

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

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

f. h" e! u5 m, y9 x. h6 n& X

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

$ q8 [! X( Q+ l9 P9 f5 q: V; ?& f

pCmdUI －>Enable(TRUE);

}

再 窗 口 显 示 消 息:

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

0 G+ ?, }; ~2 G) n/ j! }9 b

{sizeTotal.cy ＋=20;

5 S% e# U4 G" _, ]

for(int j=65;j

TextOut(10,y,m_data);

- r4 k8 d, d! Q7 A( R6 \9 T

y ＋=20；}

2 K/ f3 ?+ v4 z- g# x1 V

// TOD add draw code for native data here

( |% R( k: y! S

}

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

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

4 x+ W. U/ l: M8 d

二、 客 户 机 程 序

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

; }- ^7 v) ?; l D5 }3 C0 D

在clientview.h 中 加 入 代 码：

) n6 |+ L# `# j5 s8 i8 [" m) |

＃include “winsock.h"

* q7 p8 A2 P& B3 C1 g

添 加 变 量:

CString m_data[1000];

HANDLE m_hListenThread;

1 L, E* _& @% C3 }( i

SOCKET m_sock;

# Y3 [8 {6 z6 l* \8 {

SOCKADDR_IN m_saSrvr;

BOOL Isconnect;

int count;

CSize sizeTotal;

BOOL flag;

$ ]2 s. Y9 G# W6 d5 A

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

CClientView::CClientView()

{ // TOD add construction code here

Isconnect=FALSE;

' r+ j' [, }6 m8 t1 H

sizeTotal.cy=350;

sizeTotal.cx=300;

) Z+ k5 F# [5 x. r1 w& ^

flag=FALSE;

}

- g# I, U ^& Y

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

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

void CClientView::OnDial()

* m9 ~# U& s( L J! ?8 {

{// TOD Add your command handler code here

count=5;

if(m_bInitialized)

{ AfxMessageBox(“Already dialing");

return;}

Cdial dial;

2 k% J; K. I: u

if(dial.DoModal()==IDOK

＆ ＆!dial.m_HostAddress.IsEmpty())

{m_saSrvr.sin_family=AF_INET;

m_saSrvr.sin_addr.S_un.S_addr=htonl

- N' Y1 q$ y, `

(INADDR_ANY);

. Z$ B- e; B! U: U$ c3 C

m_saSrvr.sin_addr.S_un.S_addr=inet_addr

/ |2 U1 n% R# M2 ~& P7 b. f

(dial.m_HostAddress);

m_saSrvr.sin_port=htons(5050);

int status;

0 f* T! c+ t* s$ M+ v& @* ~

WSADATA wsaData;

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

& j; J3 Z3 V6 t6 e8 m3 q

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

( ^9 S, y9 C P3 |- ?: ]; l& ?

{ m_data[0] ＋=“Succeeded";

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)

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

! g6 t, {; h9 p- m; l

m_data[1] ＋=“Succeeded";

( A, i. P7 C1 J$ U8 k f% b

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

! R9 _. c3 z& V! F6 q8 T6 j

sockaddr_in sa;

sa.sin_family=AF_INET;

% p! z$ ]9 Z/ y+ X. U! k

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

sa.sin_port=htons(0);

- P$ U7 T: F# ^& D: Q' W

if(bind(m_sock,(PSOCKADDR)

" ]$ V; v# r; D( H, j4 U2 u

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

- U8 W: V4 f. `" f: Z' }

{ m_data[2] ＋=“Failed";

closesocket(m_sock)；}

' d/ C; ~) r) m& w+ P* C! D* T

m_data[2] ＋=“Succeeded";

# r; z$ Q) C1 L( r8 E

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

r, i0 Z. i* K, N

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

) v( g9 \8 W B' i5 C

if(m_hListenThread)

9 I3 V9 r' W0 m( K

{ m_data[3] ＋=“Succeeded";

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

else

m_data[4] ＋=“Failed";

1 h) {! m" g: n3 a4 I' k5 C

InvalidateRect(NULL);

}

}

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

7 D7 l2 w H# [$ d2 b# Y7 y

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

＃include dial.h

6 d4 x9 k% a$ e9 E

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

void CClientView::OnUpdateDial(CCmdUI ＊

pCmdUI)

% K' f' t" }4 e) X" s5 Q

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

2 q( T. z+ Q* x! @4 u& P

pCmdUI －>Enable(TRUE);

4 T& w; b/ l0 H; Z, D$ G

if(Isconnect)

6 j% e; U- i7 _

pCmdUI －>Enable(FALSE);

}

2 p8 d# j" ?( Q; X# q

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

long WINAPI Listen(CClientView ＊pView)

& A5 }1 O6 Z$ m; ~2 D& ?6 S1 o

{ char msg[2000];

+ Y6 W; v" x5 A* _% x

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

' O6 H2 g6 i$ |$ R7 V

pView －>InvalidateRect(NULL);

' l8 X! `4 C: a; P2 O9 a. j

wsprintf(msg,“A: ");

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

2 |1 [7 L4 m8 w, @) Q! e

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

2 O7 C* v1 _8 ` B5 h* c

int saSrvrLen ,nchar;

while(1)

* n; Q `1 c. c+ v

{saSrvrLen=sizeof(pView －>m_saSrvr);

! h7 g/ Z) D2 x& G; T

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

! `/ X8 [ R% p7 H

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

if(nchar<0)

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

e* ^0 T/ ]5 A5 k3 R( t, X+ g

“Error in recvform";

pView －>InvalidateRect(NULL);}

else

3 P$ O0 A$ A! r2 J. [' c9 O

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

pView －>Isconnect=TRUE;

pView －>flag=TRUE;

8 o& `8 d* X6 @ G1 g6 j$ |& u

pView －>InvalidateRect(NULL);

}

+ j; Z, W. o2 Y2 F) h$ j" u

}

0 Z7 ^2 {) |+ H! y6 b

return(0);

}

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

% D# \7 D* I0 b4 C, N9 Q2 R; N

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

3 r5 a; ~. I# n; U! b3 c% d

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

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

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

. H! {$ ~# S1 Q6 Z0 B/ t

下 的 网 络 中 执 行。