查看: 2553|回复: 0

服务器与客户机互传消息

字体大小: 正常放大

韩冰

823 主题	3 听众	4048 积分

我的地盘我做主

该用户从未签到

电梯直达

1^#

发表于 2005-1-26 01:16 |只看该作者 |倒序浏览

|招呼Ta 关注Ta

一、服务器程序

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

在serverview.h 中加入代码：

＃include “winsock.h"

添加变量：

CSize sizeTotal;// 控制滚动条

int count;// 信息条数

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

char Hostname[260];

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

SOCKET m_sock;

HANDLE m_hListenThread;// 线程

BOOL m_bInitialized;// 是否初始化

WSADATA WSAData;

BOOL flag;

SOCKADDR_IN saClnt;

int saClntLen;

BOOL Isconnect;// 是否连接

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

字：

CServerView::CServerView()

{ // TOD add construction code here

Isconnect=FALSE;

flag=FALSE;

sizeTotal.cy=350;

sizeTotal.cx=300;

m_hListenThread;

count=5;

int status;

WSADATA wsaData;

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

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

{ 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";

}

m_data[1] ＋=“Succeeded";

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

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)

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

{ m_data[2] ＋=“Failed";

closesocket(m_sock);

}

m_data[2] ＋=“Succeeded";

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

unsigned long idThread;

m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

(void if(m_hListenThread)

{ m_data[3] ＋=“Succeeded";

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

}

else

m_data[4] ＋=“Failed";

}

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

CServerView:: ～CServerView()

{ if(m_bInitialized)

WSACleanup();

closesocket(m_sock);

if(m_hListenThread)

::TerminateThread(m_hListenThread,0);

}

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

long WINAPI Listen(CServerView ＊pView)

{ char msg[2000]=“";

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)

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

=“Error in recvfrom\n";

pView －>InvalidateRect(NULL);

}

else

{switch(msg[0])

{

case ‘A':

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

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=TRUE;

pView －>saClnt=saClnt;

pView －>saClntLen=saClntLen;

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

＆saClnt,saClntLen);

break;

case ‘D':

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

inet_ntoa(saClnt.sin_addr));

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

pView －>Isconnect=FALSE;

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

＆saClnt,saClntLen);

break;

case ‘R':

saClntLen=sizeof(saClnt);

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

pView －>flag=TRUE;

pView －>InvalidateRect(NULL);

break;

default:

break;

}

return(0);

}

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

　　void CServerView::OnIp()

{int WSAReturn;

WSAReturn=WSAStartup( 0x0101, ＆WSAData );

if( WSAReturn == 0 ){

gethostname( Hostname, 260 );

struct hostent ＊pHostEnt;

pHostEnt = gethostbyname( Hostname);

if( pHostEnt != NULL ){

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

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

　　CString out;

　　out.Format(Hostaddress);

　　AfxMessageBox(out);

　　}

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

　　void CServerView::OnSendmessage()

{// TOD Add your command handler code here

char msg[2000];

Csend Sendmessage;

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;

　　flag=TRUE;

　　InvalidateRect(NULL);

　　}

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

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

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

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

void CServerView::OnUpdateSendmessage(CCmdUI ＊

pCmdUI)

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

pCmdUI －>Enable(FALSE);

if(Isconnect)

pCmdUI －>Enable(TRUE);

}

再窗口显示消息:

void CServerView::OnDraw(CDC ＊ pDC)

{ if(flag)

{sizeTotal.cy ＋=20;

for(int j=65;j

TextOut(10,y,m_data);

- o8 E4 ?' _( n$ t
y ＋=20；}
% A& b7 S R4 j& } y+ I3 e' R, G
// TOD add draw code for native data here
$ C: U8 k% e. ]% k/ } M/ d8 D
}
) C" ~, n2 ^" v% p& s# ?# ]+ U' l6 A

& C% @$ O. b, ?: X- p
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
: j$ z% p6 l" D- x1 o
----最后编译程序, 就可以得到Server.exe 程序。
4 V O; W* H- D+ v

1 `- {& o- p& u. R2 H1 Y
二、客户机程序
) V6 {6 q+ h2 T m) W( U0 E
创建一个名为“client" 的项目, 单文档界面。
: ]1 d' G$ |& s) }- T6 O
在clientview.h 中加入代码：
+ d1 b1 L' w% l; N( N( F# ]% W1 G
＃include “winsock.h"
$ k& K+ Q/ ?) u+ I1 h) F
添加变量:
7 Z$ l, L( d( Q3 m
CString m_data[1000];
+ E- v V0 H1 A; A
HANDLE m_hListenThread;
4 e8 x& M/ n0 _3 J5 @2 ]
SOCKET m_sock;
; z$ G1 B3 f0 v; A* T! s7 {7 c
SOCKADDR_IN m_saSrvr;
: Q1 T* n5 t4 W- G. F' j
BOOL Isconnect;
i( Z) f% t8 \3 l
int count;
' g1 o9 O/ P( r: F1 ?2 }6 D
CSize sizeTotal;
3 U$ N% u/ ~# A" \: H/ Q
BOOL flag;
8 h/ a# ]! @+ v

0 X2 K* W: S8 w) M
在构造函数中初始化变量:
- {9 p2 \" {& {( ~
CClientView::CClientView()
/ P, `. H9 E8 p
{ // TOD add construction code here
, P m* B6 u, D3 t6 T2 F9 ~
Isconnect=FALSE;
! E% f0 y* B' Y+ g
sizeTotal.cy=350;
6 S( `* ]2 {4 Y
sizeTotal.cx=300;
" D* V& g; ~7 j
flag=FALSE;
1 a" M- M/ ~- {! Y
}
% S6 G. k8 {- U0 R4 j% N

" o" D8 x$ U9 M" b0 J
在析构函数中完成清除操作，代码如上。
. R. `3 s# k" V3 F1 X
在菜单中添加“ 拨号" 项:
) E, ~' Y g" f) q! A0 U
void CClientView::OnDial()
5 B- \0 E7 U9 W# c% F4 |
{// TOD Add your command handler code here
( y; V2 G7 o) |$ V' n
count=5;
/ h2 h4 Q2 ?0 n2 u, J _. W2 N8 F
if(m_bInitialized)
# G/ @& ~0 w; } i' N
{ AfxMessageBox(“Already dialing");
( l) d0 b r( A6 ^1 V( n' b
return;}
8 Y t+ q& B9 G. ?/ @, ]
Cdial dial;
( i, q6 O! T" A) Z
if(dial.DoModal()==IDOK
( z4 c: h. e1 o& e7 S& p+ \, k
＆＆!dial.m_HostAddress.IsEmpty())
8 f" X$ d( W: c' J
{m_saSrvr.sin_family=AF_INET;
" X7 ?, `9 D0 d. Z4 k& B
m_saSrvr.sin_addr.S_un.S_addr=htonl
- y# Q" c& l* B2 T' q
(INADDR_ANY);
0 ]/ q; P/ i: c- D( ^0 w
m_saSrvr.sin_addr.S_un.S_addr=inet_addr
" x9 N- ^5 p" l) N+ m; k/ d; g; i+ x
(dial.m_HostAddress);
8 e, W! W) z0 x
m_saSrvr.sin_port=htons(5050);
* E0 T. r/ b- {$ p. ?7 C5 ]1 ~
int status;
7 b9 u$ h U- A6 Z$ G( x$ l
WSADATA wsaData;
' A/ @" L/ G2 r* g& M1 `
m_data[0]=“initializing Windows Sockets DLL....";
3 v6 g$ t! Z6 \! w
if((status=WSAStartup(0x0101, ＆wsaData))==0)
9 g2 P( A: r8 I8 v9 K4 C; Z
{ m_data[0] ＋=“Succeeded";
2 ~& w8 r. U: i2 g) F, k7 R" |0 j
m_bInitialized=TRUE;}
+ y' O+ B; j2 L5 c0 a
else
8 j$ N& C3 P/ f y1 D" r
{ m_bInitialized=FALSE;}
' o) h: Z* r) Z4 l$ V$ D8 F
m_sock=socket(AF_INET,SOCK_DGRAM,0);
* m, w) V/ s% ~0 Z
m_data[1]=“Creating socket....";
: r# j6 ]* V' t( Y7 p
if(m_sock==INVALID_SOCKET)
& G4 H. X, r0 U4 K* I* G
{ m_data[1] ＋=“Failed";}
; o5 x8 S; x; s6 q- Y
m_data[1] ＋=“Succeeded";
& W1 X* ?$ s; i6 T
m_data[2]=“Binding socket....";
H5 g& E# p4 f7 n& g
sockaddr_in sa;
) ^5 a R7 D+ G) I1 ]
sa.sin_family=AF_INET;
+ f* a: n% t1 k8 g6 G: i
sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
, }0 t! M5 `, b3 v$ o- i# o; R! \
sa.sin_port=htons(0);
# c8 h. Z$ h4 ?* E: r- l% g' U
if(bind(m_sock,(PSOCKADDR)
) x1 a' x- P; T6 ~$ Z+ t7 `
＆sa,sizeof(sa))==SOCKET_ERROR)
& d2 P& h, Y t/ E! s1 t3 M) a! f
{ m_data[2] ＋=“Failed";
6 @5 _9 r" }$ o& q& i. P' C' R
closesocket(m_sock)；}
. u9 m9 B/ D3 A* y4 @9 B. R+ m
m_data[2] ＋=“Succeeded";
$ W: H+ H- h( a4 E: }' C- S1 D
m_data[3]=“Creating listener thread....";
% h2 E3 K7 @% K5 P9 T! x0 @
unsigned long idThread;
7 s5 t5 f6 C) j+ V+ q+ B* Z I
m_hListenThread=CreateThread(NULL 0,
3 `6 x% a2 L4 C8 r* S) }
(LPTHREAD_START_ROUTINE)Listen,
" x# {; M) k4 W/ Y" f! f
(void ＊)this,0, ＆idThread);
: N7 y' w) L& f' j: M* M. u
if(m_hListenThread)
( x3 Y; q% h3 l& o
{ m_data[3] ＋=“Succeeded";
* ]# W: ~. P' s" w5 |* z( [$ C
m_data[4] ＋=“Waiting....";}
( ?4 Q+ H3 N1 x
else
3 L' t) q9 w% {' `2 \; z
m_data[4] ＋=“Failed";
# F8 h4 h# b( Q: Z1 M: G( s) z
InvalidateRect(NULL);
5 f( ?' G; m( s2 b6 Q8 j
}
$ f0 z: j4 i, L0 z/ H* G" q
}
, o/ d0 g6 E9 [& |/ X+ p

* A6 @5 ?: B: H6 e1 e+ B
添加一个拨号对话框, 名为dial, 有一个文本框用来写IP 地
' @! U' q* |6 R4 P. U! a# w( L
址. 并在clientview.cpp 中添加代码:
. F( f2 Z% g* z# C0 F
＃include dial.h
W0 {/ d* _" L3 T$ W' h# Z

9 F w9 l. c2 |
在拨号项添加一个判断函数:
! a& p! n6 o4 j8 `" G2 s
void CClientView::OnUpdateDial(CCmdUI ＊
8 ?- l9 v8 M4 o, A+ x4 R8 ~" m5 ~
pCmdUI)
2 f0 B: k0 K: F: c+ D6 `9 N$ ^
{// TOD Add your command update UI handler code here
3 u* G' H* o& f9 s3 }# |
pCmdUI －>Enable(TRUE);
% B: T1 C V6 x u" R3 \
if(Isconnect)
6 }8 _/ Y9 j2 D4 i
pCmdUI －>Enable(FALSE);
, I) o8 U l: v2 C" F- J, K
}
; ? U( R9 l7 P- V* \

6 V9 P8 R; t1 V, y7 D
添加接收与发送消息的线程:
% Q) ~ [- f2 U
long WINAPI Listen(CClientView ＊pView)
# e. v# _6 }2 u3 k% V1 E
{ char msg[2000];
9 z/ E- n" ~4 g3 M( X- I$ h
pView －>m_data[5]=“Sending ATTACH command";
$ P* ?3 f0 o: [5 j
pView －>InvalidateRect(NULL);
. M& b* r) S5 _! G8 \2 I8 ?3 R; A
wsprintf(msg,“A: ");
+ `: ~9 m P. a2 g2 y! X' w' y
sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)
8 J- M: p1 x N& N$ q4 m) C
＆pView －>m_saSrvr,sizeof(pView －>m_saSrvr));
4 ^0 Y# @' N. k+ z
int saSrvrLen ,nchar;
- c5 G" ^3 C+ k# n- U2 B6 ?
while(1)
1 e% b1 m x3 ?- _, D9 o$ M# w
{saSrvrLen=sizeof(pView －>m_saSrvr);
# d5 g* q( G- Q5 M4 i
nchar=recvfrom(pView －>m_sock,msg,1024,0,
4 \; n- _5 @* D6 H1 I/ E
(PSOCKADDR) ＆pView －>m_saSrvr, ＆saSrvrLen);
7 H- x8 G! m+ P# g5 \3 i7 B+ P! D
if(nchar<0)
, c# `' `/ O: q' m7 v. W
{ pView －>m_data[pView －>count ＋＋]=
( Q+ | m4 Y$ N2 F% ]0 E7 \
“Error in recvform";
- {& {1 z4 z' G, m
pView －>InvalidateRect(NULL);}
' E4 v0 e2 A2 r# \. C1 ]
else
! t. P6 d: f8 p% K
{ pView －>m_data[pView －>count ＋＋]=msg;
1 c2 F0 x" c9 t, U; }
pView －>Isconnect=TRUE;
& {) X" u- }6 s) E- l- `
pView －>flag=TRUE;
$ d# F( o6 P% F9 k( n4 i- u9 G4 P
pView －>InvalidateRect(NULL);
5 H% L* b* k3 C. _7 Y2 k
}
$ M0 d! G* u" b. J1 F7 u
}
+ K/ p4 \% `) A* I+ D, p
return(0);
9 Z9 Z+ v8 k9 h+ j# R
}
- Q7 \! P# W- X# X/ X, Y+ I5 F

- F. B7 k, u6 R" D) J7 g
同主程序一样做一个发送消息项, 代码如上。
4 m' J8 J. `: I0 O0 ^& |
显示程序也与主程序一样, 代码如上。
7 v- \( m# p' h
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
, P! @& o. y$ Y6 e' T
编译程序便可得到client.exe 程序。
C, ` s$ Q# V* F- c
----server.exe 和 client.exe 做完后, 就可以在具有 TCP/IP 协议
4 I: V6 y2 o& }/ v
下的网络中执行。