服務(wù)器回射程序設(shè)計.

1、網(wǎng)絡(luò)編程技術(shù)實驗報告實驗名稱實驗四 基于數(shù)據(jù)報套接字的回射程序設(shè)計與實驗隊 別姓 名 學(xué) 號實驗日期2015.12.9實驗報告要求： 1.實驗?zāi)康?2.實驗要求 3.實驗環(huán)境 4.實驗作業(yè) 5.問題及解決 6.思考問題 7.實驗體會【實驗?zāi)康摹?. 鞏固套接字編程2. 熟悉流式套接字編程【實驗要求】使用流式套接字編程實現(xiàn)回射程序，具體包括：1.客戶端：主動請求建立連接，接收界面輸入字符串，發(fā)送數(shù)據(jù)給服務(wù)器，接收服務(wù)器返回的應(yīng)答，輸出顯示。2.服務(wù)器：在指定端口上提供服務(wù)，接收客戶端的發(fā)送的回射請求字符串，將接收到的內(nèi)容回射給客戶端，輸出顯示。3.提煉出網(wǎng)絡(luò)操作的基本功能，構(gòu)造網(wǎng)絡(luò)操作類，修改原

2、有程序 【實驗環(huán)境】 DEV C+【實驗作業(yè)】 網(wǎng)絡(luò)操作類設(shè)計：class CSocketFrame public: int start_up(); int clean_up(); int set_address(char *hname,char *sname,struct sockaddr_in *sap,char *protocol); int quit(SOCKET s); SOCKET tcp_server(ULONG uIP,USHORT uPort); SOCKET tcp_server(char *hname,char *sname); SOCKET tcp_client(cha

3、r *hname,char *sname); SOCKET tcp_client(ULONG uIP,USHORT uPort);int CSocketFrame:start_up(void)WORD wVersionRequested; WSADATA wsaData; int iResult; wVersionRequested=MAKEWORD(2,2); iResult=WSAStartup(wVersionRequested,&wsaData); if(iResult!=0) printf("WSAStartup 調(diào)用錯誤，錯誤號:%dn",WSAGetL

4、astError(); return -1; /* if(LOBYTE(wsaData.wVersion!=2|HIBYTE(wsaData.wVersion)!=2) printf("無法找到可用的WSD版本n"); WSACleanup(); return -1; /告訴用戶無法找到可用的WSD else printf("WS2.2初始化成功！n"); */ return 0;int CSocketFrame:clean_up(void)int iResult;iResult=WSACleanup();if(iResult=SOCKET_ERROR)

5、/WSACleanup()調(diào)用失敗 printf("WSACleanup 調(diào)用錯誤，錯誤號:%dn",WSAGetLastError(); return -1; elseprintf("Winsocket dll釋放成功！n") ;return 0;int CSocketFrame:set_address(char *hname,char *sname,struct sockaddr_in *sap,char *protocol)struct servent *sp;struct hostent *hp;char *endptr;unsigned sho

6、rt port;unsigned long ulAddr=INADDR_NONE;/將地址結(jié)構(gòu)socketsddr_in初始化為0，并將地址族設(shè)為AF_INETmemset(sap,0,sizeof(*sap);sap->sin_family=AF_INET;if(hname!=NULL)/如果hname不為空，轉(zhuǎn)化地址格式ulAddr=inet_addr(hname);if(ulAddr=INADDR_NONE|ulAddr=INADDR_ANY) /調(diào)用錯誤，調(diào)用gethostbyname獲得主機地址hp=gethostbyname(hname);if(hp=NULL)printf(

7、"未知的主機名，錯誤號：%dn",WSAGetLastError();return -1; sap->sin_addr=*(struct in_addr *)hp->h_addr;elsesap->sin_addr.S_un.S_addr=ulAddr;else/如果調(diào)用者沒有指明一個主機名或地址，則設(shè)為通配地址sap->sin_addr.s_addr=htonl(INADDR_ANY);/嘗試轉(zhuǎn)換sname為一個整數(shù) port=(unsigned short)strtol(sname,&endptr,0);if(*endptr='0

8、')/如果成功轉(zhuǎn)化為網(wǎng)絡(luò)字節(jié)序sap->sin_port=htons(port); else/如果失敗，則假定是一個服務(wù)名稱，通過getservbyname()函數(shù)獲得端口號sp=getservbyname(sname,protocol);if(sp=NULL)printf("未知服務(wù)，錯誤號：%dn",WSAGetLastError();return -1;sap->sin_port=sp->s_port; return 0;int CSocketFrame:quit(SOCKET s)int iResult=0;iResult=closesoc

9、ket(s);if(iResult=SOCKET_ERROR)printf("closesocket 調(diào)用錯誤，錯誤號:%dn",WSAGetLastError(); return -1;iResult=clean_up();return iResult;SOCKET CSocketFrame:tcp_server(char *hname,char *sname)SOCKET ListenSocket;int iResult=0;sockaddr_in local; const int on=1;/為服務(wù)器的本機地址設(shè)置用戶輸入的地址以及端口號if(set_address(

10、hname,sname,&local,(char*)"tcp")!=0)return -1;/創(chuàng)建套接字ListenSocket=socket(AF_INET,SOCK_STREAM,0);if(ListenSocket=INVALID_SOCKET) printf("socket函數(shù)調(diào)用錯誤，錯誤號：%dn",WSAGetLastError(); WSACleanup(); return -1; /綁定服務(wù)器地址iResult=bind(ListenSocket,(struct sockaddr *) & local,sizeof(lo

11、cal);if(iResult=-1) printf("bind函數(shù)調(diào)用錯誤！錯誤號：%dn",WSAGetLastError(); closesocket(ListenSocket); WSACleanup(); return -1; /設(shè)置函數(shù)為監(jiān)聽狀態(tài)，監(jiān)聽隊列長度為NLISTENiResult=listen(ListenSocket,SOMAXCONN);if(iResult=SOCKET_ERROR)printf("Listen函數(shù)調(diào)用錯誤！錯誤號：%dn",WSAGetLastError();quit(ListenSocket);return

12、 -1; return ListenSocket;SOCKET CSocketFrame:tcp_server(ULONG uIP,USHORT uPort)SOCKET ListenSocket=INVALID_SOCKET;int iResult=0;sockaddr_in local;const int on=1;/為服務(wù)器的本機地址設(shè)置用戶輸入的地址以及端口號memset(&local,0,sizeof(local);local.sin_family=AF_INET;local.sin_addr.S_un.S_addr=htonl(uIP);local.sin_port=hto

13、ns(uPort);ListenSocket=socket(AF_INET,SOCK_STREAM,0);if(ListenSocket=INVALID_SOCKET)printf("socket函數(shù)調(diào)用錯誤，錯誤號：%dn",WSAGetLastError();clean_up();return -1; /綁定服務(wù)器地址iResult=bind(ListenSocket,(struct sockaddr *) & local,sizeof(local);if(iResult=SOCKET_ERROR)printf("bind函數(shù)調(diào)用錯誤！錯誤號：%dn&

14、quot;,WSAGetLastError();quit(ListenSocket);return -1; /設(shè)置函數(shù)為監(jiān)聽狀態(tài)，監(jiān)聽隊列長度為NLISTENiResult=listen(ListenSocket,SOMAXCONN);if(iResult=SOCKET_ERROR)printf("Listen函數(shù)調(diào)用錯誤！錯誤號：%dn",WSAGetLastError();quit(ListenSocket);return -1; return ListenSocket;SOCKET CSocketFrame:tcp_client(char *hname,char *s

15、name)int iResult=0;struct sockaddr_in peer;SOCKET ClientSocket;/為服務(wù)器的地址peer設(shè)置用戶輸入的地址以及端口號if(set_address(hname,sname,&peer,(char *)"tcp")!=0)return -1;/創(chuàng)建套接字ClientSocket=socket(AF_INET,SOCK_STREAM,0);if(ClientSocket=INVALID_SOCKET)printf("socket函數(shù)調(diào)用錯誤，錯誤號：%dn",WSAGetLastError(

16、);clean_up();return -1; /請求建立連接 iResult=connect(ClientSocket,(struct sockaddr *) & peer,sizeof(peer);if(iResult=SOCKET_ERROR)printf("connect函數(shù)調(diào)用錯誤！錯誤號：%dn",WSAGetLastError();quit(ClientSocket);return -1; return ClientSocket;SOCKET CSocketFrame:tcp_client(ULONG uIP,USHORT uPort)int iRes

17、ult=0;struct sockaddr_in peer;SOCKET ClientSocket;/為服務(wù)器的地址peer設(shè)置用戶輸入的地址以及端口號memset(&peer,0,sizeof(peer);peer.sin_family=AF_INET;peer.sin_addr.S_un.S_addr=htonl(uIP);peer.sin_port=htons(uPort);/創(chuàng)建套接字ClientSocket=socket(AF_INET,SOCK_STREAM,0);if(ClientSocket=INVALID_SOCKET)printf("socket函數(shù)調(diào)用錯

18、誤，錯誤號：%dn",WSAGetLastError();clean_up();return -1; /請求建立連接 iResult=connect(ClientSocket,(struct sockaddr *) & peer,sizeof(peer);if(iResult=SOCKET_ERROR)printf("connect函數(shù)調(diào)用錯誤！錯誤號：%dn",WSAGetLastError();quit(ClientSocket);return -1; return ClientSocket;服務(wù)器代碼設(shè)計：#define MAXLINE 10000#

19、define ECHOPORT "7210"int tcp_server_fun_echo(SOCKET s)int iResult = 0;char recvlineMAXLINE;domemset(recvline, 0, MAXLINE);/接收數(shù)據(jù)iResult = recv(s, recvline, MAXLINE, 0);if (iResult > 0)printf("服務(wù)器接收到數(shù)據(jù)：%sn", recvline);/回射程序已經(jīng)收到的數(shù)據(jù)iResult = send(s, recvline, iResult, 0);if (iRes

20、ult = SOCKET_ERROR)printf("send 函數(shù)調(diào)用錯誤，錯誤號：%ldn", WSAGetLastError();iResult = -1;elseprintf("服務(wù)器發(fā)送數(shù)據(jù)%sn", recvline);elseif (iResult = 0)printf("對方連接關(guān)閉，退出n");elseprintf("recv 函數(shù)調(diào)用錯誤，錯誤號：%dn", WSAGetLastError();iResult = -1;break; while (iResult > 0);return i

21、Result;int main(int argc, char* argv)CSocketFrame frame;int iResult = 0;SOCKET ListenSocket, ConnectSocket;/輸入?yún)?shù)合法性檢查if (argc != 1)printf("usage:EchoTCPServer");return -1;/初始化frame.start_up();/創(chuàng)建服務(wù)器的流式套接字并在指定端口號上監(jiān)聽ListenSocket =frame.tcp_server(char *)NULL,(char *)ECHOPORT); /改成全部任意if (Lis

22、tenSocket = -1)return -1;printf("服務(wù)器準備好回射服務(wù)。n");for (;)ConnectSocket = accept(ListenSocket, NULL, NULL);if (ConnectSocket != INVALID_SOCKET)/建立連接成功printf("rn建立連接成功nn");/回射iResult = tcp_server_fun_echo(ConnectSocket);/如果出錯，關(guān)閉當(dāng)前連接的套接字，繼續(xù)接受其他客戶端的請求if (iResult = -1)printf("當(dāng)前連接已

23、關(guān)閉或出錯！n");elseprintf("accept 函數(shù)調(diào)用錯誤，錯誤號：%dn", WSAGetLastError();frame.quit(ListenSocket);return -1;/關(guān)閉套接字if (closesocket(ConnectSocket) = SOCKET_ERROR)printf("closesocket 函數(shù)調(diào)用錯誤，錯誤號：%dn", WSAGetLastError();frame.quit(ListenSocket);return 0;客戶端代碼設(shè)計：#define ECHOPORT "7210

24、"#define MAXLINE 10000int tcp_client_fun_echo(FILE *fp,SOCKET s)int iResult;char sendlineMAXLINE,recvlineMAXLINE;/初始化緩沖區(qū) memset(sendline,0,MAXLINE);memset(recvline,0,MAXLINE);/循環(huán)發(fā)送用戶輸入的數(shù)據(jù)，并接受服務(wù)器返回的應(yīng)答，直到用戶輸入Q結(jié)束while(fgets(sendline,MAXLINE,fp)!=NULL)if(*sendline='Q')printf("input end

25、!n");/用戶發(fā)送數(shù)據(jù)結(jié)束iResult=shutdown(s,SD_SEND);if(iResult=SOCKET_ERROR)printf("shutdown函數(shù)調(diào)用錯誤，錯誤號：%d",WSAGetLastError();return 0; iResult=send(s,sendline,strlen(sendline),0);if(iResult=SOCKET_ERROR)printf("send函數(shù)調(diào)用錯誤，錯誤號：%d",WSAGetLastError();return -1;printf("rn客戶端發(fā)送數(shù)據(jù)：%srn

26、",sendline);memset(recvline,0,MAXLINE);iResult=recv(s,recvline,MAXLINE,0);if(iResult>0)printf("客戶端收到數(shù)據(jù)：%srn",recvline);elseif(iResult=0)printf("服務(wù)器終止！n");elseprintf("recv函數(shù)調(diào)用錯誤，錯誤號：%d",WSAGetLastError();break;memset(sendline,0,MAXLINE); return iResult; int main(in