服务器回射程序设计

服务器回射程序设计网络编程技术实验报告实验名称实验四基于数据报套接字的回射程序设计与实验队别姓名学号实验日期2015.12.9实验报告要求：1.实验目的2.实验要求3.实验环境4.实验作业5.问题及解决6.思考问题7.实验体会【实验目的】巩固套接字编程熟悉流式套接字编程【实验要求】使用流式套接字编程实现回射程序，具体包括：1. 客户端：主动请求建立连接，接收界面输入字符串，发送数据给服务器，接收服务器返回的应答，输出显示。2. 服务器：在指定端口上提供服务，接收客户端的发送的回射请求字符串，将接收到的内容回射给客户端，输出显示。3. 提炼出网络操作的基本功能，构造网络操作类，修改原有程序【实验环境】DEVC++【实验作业】网络操作类设计：classCSocketFrame{public:intstart_up(); intclean_up(); intset_address(char*hname,char*sname,structsockaddr_in*sap,char*protocol); intquit(SOCKETs); SOCKETtcp_server(ULONGuIP,USHORTuPort); SOCKETtcp_server(char*hname,char*sname); SOCKETtcp_client(char*hname,char*sname); SOCKETtcp_client(ULONGuIP,USHORTuPort);};intCSocketFrame::start_up(void){ WORDwVersionRequested; WSADATAwsaData; intiResult; wVersionRequested=MAKEWORD(2,2); iResult=WSAStartup(wVersionRequested,&wsaData); if(iResult!=0) { printf("WSAStartup调用错误，错误号:%d\n",WSAGetLastError());服务器回射程序设计全文共11页，当前为第1页。 return-1;服务器回射程序设计全文共11页，当前为第1页。 } /* if(LOBYTE(wsaData.wVersion!=2||HIBYTE(wsaData.wVersion)!=2)) { printf("无法找到可用的WSD版本\n"); WSACleanup(); return-1; //告诉用户无法找到可用的WSD } else { printf("WS2.2初始化成功！\n"); }*/ return0;}intCSocketFrame::clean_up(void){ intiResult; iResult=WSACleanup(); if(iResult==SOCKET_ERROR) { //WSACleanup()调用失败 printf("WSACleanup调用错误，错误号:%d\n",WSAGetLastError()); return-1; } else printf("Winsocketdll释放成功！\n"); return0;}intCSocketFrame::set_address(char*hname,char*sname,structsockaddr_in*sap,char*protocol){ structservent*sp; structhostent*hp; char*endptr; unsignedshortport; unsignedlongulAddr=INADDR_NONE; //将地址结构socketsddr_in初始化为0，并将地址族设为AF_INET memset(sap,0,sizeof(*sap)); sap->sin_family=AF_INET; if(hname!=NULL) {服务器回射程序设计全文共11页，当前为第2页。 //如果hname不为空，转化地址格式服务器回射程序设计全文共11页，当前为第2页。 ulAddr=inet_addr(hname); if(ulAddr==INADDR_NONE||ulAddr==INADDR_ANY) { //调用错误，调用gethostbyname获得主机地址 hp=gethostbyname(hname); if(hp==NULL) { printf("未知的主机名，错误号：%d\n",WSAGetLastError()); return-1; } sap->sin_addr=*(structin_addr*)hp->h_addr; } else sap->sin_addr.S_un.S_addr=ulAddr; } else //如果调用者没有指明一个主机名或地址，则设为通配地址 sap->sin_addr.s_addr=htonl(INADDR_ANY); //尝试转换sname为一个整数 port=(unsignedshort)strtol(sname,&endptr,0); if(*endptr=='\0') { //如果成功转化为网络字节序 sap->sin_port=htons(port); } else { //如果失败，则假定是一个服务名称，通过getservbyname()函数获得端口号 sp=getservbyname(sname,protocol); if(sp==NULL) { printf("未知服务，错误号：%d\n",WSAGetLastError()); return-1; } sap->sin_port=sp->s_port; } return0;}intCSocketFrame::quit(SOCKETs){ intiResult=0; iResult=closesocket(s); if(iResult==SOCKET_ERROR)服务器回射程序设计全文共11页，当前为第3页。 {服务器回射程序设计全文共11页，当前为第3页。 printf("closesocket调用错误，错误号:%d\n",WSAGetLastError()); return-1; } iResult=clean_up(); returniResult;}SOCKETCSocketFrame::tcp_server(char*hname,char*sname){ SOCKETListenSocket; intiResult=0; sockaddr_inlocal; constinton=1; //为服务器的本机地址设置用户输入的地址以及端口号 if(set_address(hname,sname,&local,(char*)"tcp")!=0) return-1; //创建套接字 ListenSocket=socket(AF_INET,SOCK_STREAM,0); if(ListenSocket==INVALID_SOCKET) { printf("socket函数调用错误，错误号：%d\n",WSAGetLastError()); WSACleanup(); return-1; } //绑定服务器地址 iResult=bind(ListenSocket,(structsockaddr*)&local,sizeof(local)); if(iResult==-1) { printf("bind函数调用错误！错误号：%d\n",WSAGetLastError()); closesocket(ListenSocket); WSACleanup(); return-1; } //设置函数为监听状态，监听队列长度为NLISTEN iResult=listen(ListenSocket,SOMAXCONN); if(iResult==SOCKET_ERROR) { printf("Listen函数调用错误！错误号：%d\n",WSAGetLastError()); quit(ListenSocket); return-1; } returnListenSocket;}SOCKETCSocketFrame::tcp_server(ULONGuIP,USHORTuPort)服务器回射程序设计全文共11页，当前为第4页。{服务器回射程序设计全文共11页，当前为第4页。 SOCKETListenSocket=INVALID_SOCKET; intiResult=0; sockaddr_inlocal; constinton=1; //为服务器的本机地址设置用户输入的地址以及端口号 memset(&local,0,sizeof(local)); local.sin_family=AF_INET; local.sin_addr.S_un.S_addr=htonl(uIP); local.sin_port=htons(uPort); ListenSocket=socket(AF_INET,SOCK_STREAM,0); if(ListenSocket==INVALID_SOCKET) { printf("socket函数调用错误，错误号：%d\n",WSAGetLastError()); clean_up(); return-1; } //绑定服务器地址 iResult=bind(ListenSocket,(structsockaddr*)&local,sizeof(local)); if(iResult==SOCKET_ERROR) { printf("bind函数调用错误！错误号：%d\n",WSAGetLastError()); quit(ListenSocket); return-1; } //设置函数为监听状态，监听队列长度为NLISTEN iResult=listen(ListenSocket,SOMAXCONN); if(iResult==SOCKET_ERROR) { printf("Listen函数调用错误！错误号：%d\n",WSAGetLastError()); quit(ListenSocket); return-1; } returnListenSocket;}SOCKETCSocketFrame::tcp_client(char*hname,char*sname){ intiResult=0; structsockaddr_inpeer; SOCKETClientSocket; //为服务器的地址peer设置用户输入的地址以及端口号 if(set_address(hname,sname,&peer,(char*)"tcp")!=0) return-1; //创建套接字服务器回射程序设计全文共11页，当前为第5页。 ClientSocket=socket(AF_INET,SOCK_STREAM,0);服务器回射程序设计全文共11页，当前为第5页。 if(ClientSocket==INVALID_SOCKET) { printf("socket函数调用错误，错误号：%d\n",WSAGetLastError()); clean_up(); return-1; } //请求建立连接 iResult=connect(ClientSocket,(structsockaddr*)&peer,sizeof(peer)); if(iResult==SOCKET_ERROR) { printf("connect函数调用错误！错误号：%d\n",WSAGetLastError()); quit(ClientSocket); return-1; } returnClientSocket;}SOCKETCSocketFrame::tcp_client(ULONGuIP,USHORTuPort){ intiResult=0; structsockaddr_inpeer; SOCKETClientSocket; //为服务器的地址peer设置用户输入的地址以及端口号 memset(&peer,0,sizeof(peer)); peer.sin_family=AF_INET; peer.sin_addr.S_un.S_addr=htonl(uIP); peer.sin_port=htons(uPort); //创建套接字 ClientSocket=socket(AF_INET,SOCK_STREAM,0); if(ClientSocket==INVALID_SOCKET) { printf("socket函数调用错误，错误号：%d\n",WSAGetLastError()); clean_up(); return-1; } //请求建立连接 iResult=connect(ClientSocket,(structsockaddr*)&peer,sizeof(peer)); if(iResult==SOCKET_ERROR) { printf("connect函数调用错误！错误号：%d\n",WSAGetLastError()); quit(ClientSocket); return-1; } returnClientSocket;服务器回射程序设计全文共11页，当前为第6页。}服务器回射程序设计全文共11页，当前为第6页。服务器代码设计：#defineMAXLINE10000#defineECHOPORT"7210"inttcp_server_fun_echo(SOCKETs){ intiResult=0; charrecvline[MAXLINE]; do { memset(recvline,0,MAXLINE); //接收数据 iResult=recv(s,recvline,MAXLINE,0); if(iResult>0) { printf("服务器接收到数据：%s\n",recvline); //回射程序已经收到的数据 iResult=send(s,recvline,iResult,0); if(iResult==SOCKET_ERROR) { printf("send函数调用错误，错误号：%ld\n",WSAGetLastError()); iResult=-1; } else printf("服务器发送数据%s\n",recvline); } else { if(iResult==0) printf("对方连接关闭，退出\n"); else { printf("recv函数调用错误，错误号：%d\n",WSAGetLastError()); iResult=-1; } break; } }while(iResult>0); returniResult;}intmain(intargc,char*argv[]){ CSocketFrameframe;服务器回射程序设计全文共11页，当前为第7页。 intiResult=0;服务器回射程序设计全文共11页，当前为第7页。 SOCKETListenSocket,ConnectSocket; //输入参数合法性检查 if(argc!=1) { printf("usage:EchoTCPServer"); return-1; } //初始化 frame.start_up(); //创建服务器的流式套接字并在指定端口号上监听 ListenSocket=frame.tcp_server((char*)NULL,(char*)ECHOPORT);//改成全部任意 if(ListenSocket==-1) return-1; printf("服务器准备好回射服务。。。\n"); for(;;) { ConnectSocket=accept(ListenSocket,NULL,NULL); if(ConnectSocket!=INVALID_SOCKET) { //建立连接成功 printf("\r\n建立连接成功\n\n"); //回射 iResult=tcp_server_fun_echo(ConnectSocket); //如果出错，关闭当前连接的套接字，继续接受其他客户端的请求 if(iResult==-1) printf("当前连接已关闭或出错！\n"); } else { printf("accept函数调用错误，错误号：%d\n",WSAGetLastError()); frame.quit(ListenSocket); return-1; } //关闭套接字 if(closesocket(ConnectSocket)==SOCKET_ERROR) printf("closesocket函数调用错误，错误号：%d\n",WSAGetLastError()); } frame.quit(ListenSocket); return0;}客户端代码设计：#defineECHOPORT"7210"#defineMAXLINE10000服务器回射程序设计全文共11页，当前为第8页。inttcp_client_fun_echo(FILE*fp,SOCKETs)服务器回射程序设计全文共11页，当前为第8页。{ intiResult; charsendline[MAXLINE],recvline[MAXLINE]; //初始化缓冲区 memset(sendline,0,MAXLINE); memset(recvline,0,MAXLINE); //循环发送用户输入的数据，并接受服务器返回的应答，直到用户输入Q结束 while(fgets(sendline,MAXLINE,fp)!=NULL) { if(*sendline=='Q') { printf("inputend!\n"); //用户发送数据结束 iResult=shutdown(s,SD_SEND); if(iResult==SOCKET_ERROR) { printf("shutdown函数调用错误，错误号：%d",WSAGetLastError()); } return0; } iResult=send(s,sendline,strlen(sendline),0); if(iResult==SOCKET_ERROR) { printf("send函数调用错误，错误号：%d",WSAGetLastError()); return-1; } printf("\r\n客户端发送数据：%s\r\n",sendline); memset(recvline,0,MAXLINE); iResult=recv(s,recvline,MAXLINE,0); if(iResult>0) printf("客户端收到数据：%s\r\n",recvline); else { if(iResult==0) printf("服务器终止！\n"); else printf("recv函数调用错误，错误号：%d",WSAGetLastError()); break; } memset(sendline,0,MAXLINE); } returniResult;}服务器回射程序设计全文共11页，当前为第9页。intmain(intargc,char*argv[])服务器回射程序设计全文共11页，当前为第9页。{ CSocketFrameframe; intiResult;