查看: 2513|回复: 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);

8 \+ Y9 U% e$ F; n% u
y ＋=20；}
( k/ r* {% c A# Z4 w) ?
// TOD add draw code for native data here
2 J3 U# ]+ c* s) U& e
}
9 {5 R! N) m. K, f( ^1 h o1 e7 e1 K

5 b8 p9 h) J: ?' @8 W4 [
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
, U% X7 X2 {' W) W ~) v ^$ c
----最后编译程序, 就可以得到Server.exe 程序。
7 G# [' L& l9 C- | @

6 c8 d6 _2 P, r3 \- F! C- a% t3 M/ I
二、客户机程序
0 M. {6 _6 ?- B, `! X
创建一个名为“client" 的项目, 单文档界面。
$ Y. u* v5 l8 v
在clientview.h 中加入代码：
, m: C5 `7 Z- D: f6 K
＃include “winsock.h"
7 I6 n$ _" ~) C: f
添加变量:
+ y4 ?7 }+ x4 H* J, B! X
CString m_data[1000];
! j0 v1 k' i: U4 A& t: E
HANDLE m_hListenThread;
( Q1 }8 o' I- g' K: v7 T5 ?# J
SOCKET m_sock;
/ t5 k! ~0 H1 B6 u0 i9 S, L
SOCKADDR_IN m_saSrvr;
) d+ M3 E1 S- _% k) T) o9 d: m0 i
BOOL Isconnect;
& Q/ e* e. ^7 \. _9 A7 ?9 F% y
int count;
" Y% s/ K9 M1 a* \, C! @
CSize sizeTotal;
! l1 Q" v7 E0 y2 j$ v4 ?
BOOL flag;
% i$ X# o& H' M9 i0 X. \

$ X1 t/ T- m6 u/ Z' K& \
在构造函数中初始化变量:
/ P6 R3 S/ i, t7 k0 U" J |1 y' r
CClientView::CClientView()
! q, G- ^. ^9 ?4 V5 I# g8 U
{ // TOD add construction code here
& n' s+ K* g+ ]3 `
Isconnect=FALSE;
( V7 w0 M# ]8 Q, C% x& a/ T8 r( ]
sizeTotal.cy=350;
- ]* Y6 `& R& h# B- A" D' h3 R2 c
sizeTotal.cx=300;
~- N9 V# l" @2 Z
flag=FALSE;
* l! L$ R% r. [0 k4 a2 t/ R0 |! k
}
. K% {, a% {8 G2 l) I q8 ~9 K

; T u0 S: M, {% Q `. _
在析构函数中完成清除操作，代码如上。
9 [5 {6 \5 W; Z: \8 X& O4 n
在菜单中添加“ 拨号" 项:
7 }& B# B; a* h* U+ S4 a7 i
void CClientView::OnDial()
3 q, j0 ]% t2 [& c9 \8 d N
{// TOD Add your command handler code here
# ?3 [) N' I: z$ ?; _4 o1 U3 z
count=5;
, k6 q2 F! B+ Z/ W% a+ k
if(m_bInitialized)
+ q3 L7 J+ Q8 u
{ AfxMessageBox(“Already dialing");
6 y G% j1 ]" c
return;}
- z# p& m, y6 o+ a: U
Cdial dial;
% {. v" B( m1 m$ i; U
if(dial.DoModal()==IDOK
* o# M. F: Q8 ]- y1 ]) c9 t
＆＆!dial.m_HostAddress.IsEmpty())
" d% e1 ^" M X w
{m_saSrvr.sin_family=AF_INET;
8 Q {) O8 h6 v# p7 B9 i, e' ~
m_saSrvr.sin_addr.S_un.S_addr=htonl
+ C, d7 I% W1 a
(INADDR_ANY);
% e6 p4 F3 Y- ]6 G& \! f
m_saSrvr.sin_addr.S_un.S_addr=inet_addr
Y# z( |: Q, P+ L
(dial.m_HostAddress);
+ B- x) }1 Y$ i" V9 i q3 v8 G( E( j
m_saSrvr.sin_port=htons(5050);
; A! q- p* U I
int status;
+ q3 c% R, K4 F
WSADATA wsaData;
" N4 `) @1 S2 v' M. j
m_data[0]=“initializing Windows Sockets DLL....";
5 o' l+ C" s# \7 a
if((status=WSAStartup(0x0101, ＆wsaData))==0)
7 {. k, {8 Y9 D+ N4 k1 E G
{ m_data[0] ＋=“Succeeded";
! ?+ G+ N% _* o1 V% k5 s
m_bInitialized=TRUE;}
. l* s" G) t. A1 v2 z4 M: C) a
else
2 Z9 W. `/ z& j0 X
{ m_bInitialized=FALSE;}
/ z3 C$ j# |, ^# I
m_sock=socket(AF_INET,SOCK_DGRAM,0);
/ j3 U* i; b$ S3 L0 s
m_data[1]=“Creating socket....";
0 E* {0 a) |4 h
if(m_sock==INVALID_SOCKET)
, O! O$ D) r* A1 z
{ m_data[1] ＋=“Failed";}
- B* `* I% l; R/ r d! t
m_data[1] ＋=“Succeeded";
/ R, w2 | \4 P% a2 K0 j5 O, I
m_data[2]=“Binding socket....";
2 b( e8 t: B: @4 ?
sockaddr_in sa;
, }2 W* R' x. o( Z# S! W
sa.sin_family=AF_INET;
: v; O' j7 h' D' |9 U/ w8 I& e
sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
' o* @/ k8 W9 e$ ^1 [; R- S
sa.sin_port=htons(0);
" J5 ^1 v! e- d
if(bind(m_sock,(PSOCKADDR)
% [) F+ D: i% t) N8 m2 [, w
＆sa,sizeof(sa))==SOCKET_ERROR)
8 v% Y7 U4 @$ s3 L( q
{ m_data[2] ＋=“Failed";
8 w1 }9 f. v6 d5 _6 K" A. x% e4 b9 K
closesocket(m_sock)；}
6 n7 C8 _6 d6 q( @' B4 D
m_data[2] ＋=“Succeeded";
/ x% P* O% M0 y8 L0 F0 |
m_data[3]=“Creating listener thread....";
7 B5 P O7 y: S+ a, ]- U
unsigned long idThread;
% z( {7 B2 g5 E; y. k
m_hListenThread=CreateThread(NULL 0,
8 I( H7 {. e$ j$ T- l, \
(LPTHREAD_START_ROUTINE)Listen,
7 a# p I: x7 n, P" J4 ?
(void ＊)this,0, ＆idThread);
7 u" b1 w% J) K" I
if(m_hListenThread)
; ^1 ?- H" i8 t! e( [! g
{ m_data[3] ＋=“Succeeded";
/ O$ T/ I$ u( D, u2 f9 J
m_data[4] ＋=“Waiting....";}
8 ]. B; j) I4 e0 f
else
) K) ?8 A" F* ^4 V
m_data[4] ＋=“Failed";
6 u3 A# J+ w5 }; ^1 K
InvalidateRect(NULL);
/ q/ J( B2 n$ U# A) e5 }
}
+ N( z' C7 p! W$ z- t) V" B/ X
}
, p# m3 T+ R \2 C0 o

+ f5 c: a- F3 z0 o0 w, r, ~
添加一个拨号对话框, 名为dial, 有一个文本框用来写IP 地
% s: B: M, N! e7 X Z9 b! a$ F
址. 并在clientview.cpp 中添加代码:
* n4 k1 a# F3 J" \- w
＃include dial.h
& p/ Z" p# D; T

5 t4 `1 U. g# x3 \/ V- f
在拨号项添加一个判断函数:
& R: V |8 y# u4 G
void CClientView::OnUpdateDial(CCmdUI ＊
, U7 y$ f5 I0 t- X' M
pCmdUI)
9 L2 z, f8 G8 ~4 f
{// TOD Add your command update UI handler code here
6 P a/ {6 b4 H% m% s
pCmdUI －>Enable(TRUE);
2 ~* f, s% E. E* _1 u* o5 O3 y
if(Isconnect)
P8 F$ r0 [6 r' f7 b8 b
pCmdUI －>Enable(FALSE);
4 M* g* t% \- t0 X, b9 | f _
}
+ Y- }4 r9 D7 y( @

# o; o# |* W. K0 Z& j5 [
添加接收与发送消息的线程:
( q( E+ ~% N, l+ C
long WINAPI Listen(CClientView ＊pView)
0 A; N! z5 {' z6 i$ z
{ char msg[2000];
- C) R/ i& M% r" N: R' y
pView －>m_data[5]=“Sending ATTACH command";
. r9 T' [( A% D0 T
pView －>InvalidateRect(NULL);
1 `8 l K! {0 T$ J. F% s6 }
wsprintf(msg,“A: ");
A& Z# ^- d: m, u+ e ~" Q/ k3 s
sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)
- Z$ o0 w: ] k2 G
＆pView －>m_saSrvr,sizeof(pView －>m_saSrvr));
- @- c, _& y7 y+ @" ` N: ?# m
int saSrvrLen ,nchar;
. c, s+ c8 w6 b" j* ?2 O
while(1)
8 A. q0 K2 X7 v/ R' I
{saSrvrLen=sizeof(pView －>m_saSrvr);
0 b+ a* T" R& i. p4 C2 [6 Q) x, u: }
nchar=recvfrom(pView －>m_sock,msg,1024,0,
1 \+ h4 x& u) Y
(PSOCKADDR) ＆pView －>m_saSrvr, ＆saSrvrLen);
3 k6 ?8 }& L& q3 B" ]
if(nchar<0)
e9 ]9 v" h# @& l" q& b
{ pView －>m_data[pView －>count ＋＋]=
* T9 H! u/ w0 s9 X, f
“Error in recvform";
$ P, Q' q5 g- r6 ^2 X
pView －>InvalidateRect(NULL);}
& C. j3 P* I5 M% B
else
5 k+ b9 j; S3 D
{ pView －>m_data[pView －>count ＋＋]=msg;
% V1 `/ H) A# b9 g4 _+ p
pView －>Isconnect=TRUE;
5 ]: W3 U3 s2 F# V3 D! {" i4 h
pView －>flag=TRUE;
\# a+ E* ~( v3 X2 `6 R
pView －>InvalidateRect(NULL);
/ e7 e$ F( r5 C3 p
}
. p$ g9 a" P+ x, {% I F
}
% d/ v3 ~5 M% \. s
return(0);
' w1 p. N3 X' J3 k H
}
& d+ Z A4 ^, }4 U* J5 F% R" P, L

5 `( Z* B2 O0 B+ y- {& |0 v$ Z$ d
同主程序一样做一个发送消息项, 代码如上。
$ i1 p: d* o/ H1 c4 I- I9 D9 i4 u* u
显示程序也与主程序一样, 代码如上。
; Q9 g _( m% |2 a/ y
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
$ l+ ^- q) ~; J) Q; K
编译程序便可得到client.exe 程序。
j5 f. G9 {5 Q( t- T
----server.exe 和 client.exe 做完后, 就可以在具有 TCP/IP 协议
( G: E8 |: |" ]/ d, ~2 x
下的网络中执行。