基于WSAAsyncSelect模型的通信程序设计Word文档下载推荐.doc
《基于WSAAsyncSelect模型的通信程序设计Word文档下载推荐.doc》由会员分享，可在线阅读，更多相关《基于WSAAsyncSelect模型的通信程序设计Word文档下载推荐.doc（8页珍藏版）》请在冰点文库上搜索。
服务器端：
#include<
stdio.h>
winsock2.h>
#pragmacomment（lib,"
WS2_32"
） //链接到WS2_32.lib
#include<
math.h>
#defineWM_SOCKETWM_USER+101 //自定义消息
classCInitSock
{
public:
CInitSock（BYTEminorVer=2,BYTEmajorVer=2）
{
//初始化WS2_32.dll
WSADATAwsaData;
WORDsockVersion=MAKEWORD（minorVer,majorVer）;
if（:
:
WSAStartup（sockVersion,&
wsaData）!
=0）
return;
}
~CInitSock（）
{
:
WSACleanup（）;
};
CInitSocktheSock;
//加载套接字库
LRESULTCALLBACKWindowProc（HWNDhWnd,UINTuMsg,WPARAMwParam,LPARAMlParam）;
boolisprime（intp）{//判断p是否为质数
intsq=（int）sqrt（p）;
boolflag=true;
inti;
for（i=2;
i<
=sq;
i++）{
if（p%i==0）{
flag=false;
break;
}
}
if（!
flag&
&
=sq）
returnfalse;
else
returntrue;
char*getallprime（intn）{//将num以内的所有质数放在同一字符串中
charszprime[4096]="
质数：
"
;
intlen=strlen（szprime）+strlen（"
"
）;
for（inti=2;
i<
=n;
i++）{
if（isprime（i））{
charsznum[10];
itoa（i,sznum,10）;
char*sztemp=strcat（szprime,sznum）;
len+=strlen（sznum）;
szprime[len-1]='
'
;
len+=strlen（"
}
//printf（"
%s\n"
szprime）;
returnszprime;
intmain（）
charszClassName[]="
MainWClass"
WNDCLASSEXwndclass;
//用描述主窗口的参数填充WNDCLASSEX结构
wndclass.cbSize=sizeof（wndclass）;
wndclass.style=CS_HREDRAW|CS_VREDRAW;
wndclass.lpfnWndProc=WindowProc;
wndclass.cbClsExtra=0;
wndclass.cbWndExtra=0;
wndclass.hInstance=NULL;
wndclass.hIcon=:
LoadIcon（NULL,IDI_APPLICATION）;
wndclass.hCursor=:
LoadCursor（NULL,IDC_ARROW）;
wndclass.hbrBackground=（HBRUSH）:
GetStockObject（WHITE_BRUSH）;
wndclass.lpszMenuName=NULL;
wndclass.lpszClassName=szClassName;
wndclass.hIconSm=NULL;
:
RegisterClassEx（&
wndclass）;
//创建主窗口
HWNDhWnd=:
CreateWindowEx（
0,
szClassName,
"
WS_OVERLAPPEDWINDOW,
CW_USEDEFAULT,
CW_USEDEFAULT,
CW_USEDEFAULT,
NULL,
NULL,
NULL,
NULL）;
if（hWnd==NULL）
MessageBox（NULL,"
创建窗口出错！
"
error"
MB_OK）;
return-1;
USHORTnPort=4567;
//此服务器监听的端口号
//创建监听套节字
SOCKETsListen=:
socket（AF_INET,SOCK_STREAM,IPPROTO_TCP）;
sockaddr_insin;
sin.sin_family=AF_INET;
sin.sin_port=htons（nPort）;
sin.sin_addr.S_un.S_addr=INADDR_ANY;
//绑定套节字到本地机器
if（:
bind（sListen,（sockaddr*）&
sin,sizeof（sin））==SOCKET_ERROR）
printf（"
Failedbind（）\n"
//将套接字设为窗口通知消息类型。
WSAAsyncSelect（sListen,hWnd,WM_SOCKET,FD_ACCEPT|FD_CLOSE）;
//进入监听模式
listen（sListen,5）;
//从消息队列中取出消息
MSGmsg;
while（:
GetMessage（&
msg,NULL,0,0））
//转化键盘消息
TranslateMessage（&
msg）;
//将消息发送到相应的窗口函数
DispatchMessage（&
//当GetMessage返回0时程序结束
returnmsg.wParam;
}
LRESULTCALLBACKWindowProc（HWNDhWnd,UINTuMsg,WPARAMwParam,LPARAMlParam）
switch（uMsg）
caseWM_SOCKET:
{
//取得有事件发生的套节字句柄
SOCKETs=wParam;
//查看是否出错
if（WSAGETSELECTERROR（lParam））
{
:
closesocket（s）;
return0;
}
//处理发生的事件
switch（WSAGETSELECTEVENT（lParam））
caseFD_ACCEPT:
//监听中的套接字检测到有连接进入
{
SOCKETclient=:
accept（s,NULL,NULL）;
:
WSAAsyncSelect（client,hWnd,WM_SOCKET,FD_READ|FD_WRITE|FD_CLOSE）;
}
break;
caseFD_WRITE:
caseFD_READ:
charszText[1024]={0};
if（:
recv（s,szText,1024,0）==-1）
:
else
{
printf（"
接收数据：
%s"
szText）;
char*szReply=getallprime（1000）;
//得到1000以内的所有质数
send（s,szReply,strlen（szReply）,0）;
//响应客户端，回以szReply
}
caseFD_CLOSE:
{
return0;
caseWM_DESTROY:
PostQuitMessage（0）;
return0;
//将我们不处理的消息交给系统做默认处理
return:
DefWindowProc（hWnd,uMsg,wParam,lParam）;
客户端：
//创建套节字
SOCKETs=:
if（s==INVALID_SOCKET）
Failedsocket（）\n"
//也可以在这里调用bind函数绑定一个本地地址，无则系统将会自动安排
//填写远程地址信息
sockaddr_inservAddr;
servAddr.sin_family=AF_INET;
servAddr.sin_port=htons（4567）;
//要连接的服务器地址
servAddr.sin_addr.S_un.S_addr=inet_addr（"
127.0.0.1"
//没有联网，直接使用127.0.0.1即可
connect（s,（sockaddr*）&
servAddr,sizeof（servAddr））==-1）
Failedconnect（）\n"
//发送数据
charbuf[]="
请输出从1到1000内所有的质数"
printf（"
发送数据：
buf）;
send（s,buf,strlen（buf）,0）;
Sleep（6）;
//接收数据
charbuff[3000];
intnRecv=:
recv（s,buff,3000,0）;
if（nRecv>
0）
buff[nRecv]='
\0'
接收到数据：
\n%s\n"
buff）;
//关闭套节字
return0;
执行结果：
五、实验小结
1.执行结果并非为质数，且出现重复
经过调试分析服务器端质数放在同一字符串的函数中，发现未将分隔符号“，”的长度加进去导致整个质数的输出结果出现混乱
2.客户端接收数据时发现349之后的质数未显示
查看判断是否为质数及所有质数放在同一字符串中的函数时发现并没有将之后的数据隔离，反复检查发现是客户端定义接收数据的长度时由于直接利用上次实验，未将长度增大，仅为256导致后面的数据未被接收
六、附录
《网络编程技术与应用》
升级会员 