利用流式套接字實(shí)現(xiàn)文件的傳輸

1、網(wǎng)絡(luò)編程技術(shù)實(shí)驗(yàn)報(bào)告實(shí)驗(yàn)名稱實(shí)驗(yàn)四利用流式套接字傳輸文件實(shí)驗(yàn)隊(duì)別姓名學(xué)號(hào)實(shí)驗(yàn)日期2015.12.11實(shí)驗(yàn)報(bào)告要求：1.實(shí)驗(yàn)?zāi)康?.實(shí)驗(yàn)要求3.實(shí)驗(yàn)環(huán)境4.實(shí)驗(yàn)作業(yè)5.問題及解決6.思考問題7.實(shí)驗(yàn)體會(huì)【實(shí)驗(yàn)?zāi)康摹? .掌握定長(zhǎng)與變長(zhǎng)流式套接字的使用方法2 .加深對(duì)流式套接字的掌握3 .掌些解決實(shí)際問題的能力【實(shí)驗(yàn)要求】客戶端向服務(wù)器發(fā)起socket連接，并建立數(shù)據(jù)傳輸通道客戶端向服務(wù)器發(fā)送要傳輸?shù)奈募Q，以"#"字符結(jié)尾，服務(wù)器逐字接收，直到接收到#（變長(zhǎng)數(shù)據(jù)）客戶端向服務(wù)器發(fā)送文件長(zhǎng)度，4字節(jié)（定長(zhǎng)數(shù)據(jù)）工戶端向服務(wù)器文件內(nèi)容（變長(zhǎng)數(shù)據(jù)）報(bào)務(wù)端接收完文件后，向客戶端發(fā)送

2、ok,以示成功接收客戶端接收到OKB,關(guān)閉套接字報(bào)務(wù)器關(guān)閉套接字【實(shí)驗(yàn)環(huán)境】Devc【實(shí)驗(yàn)作業(yè)】客戶端：nttcp_client_fun_echo(FILE*fp,SOCKETs)intiResult;charsendlineMAXLINE,recvlineMAXLINE;charfile20;charflong4;inti=0;/文件名發(fā)送控制/初始化緩沖區(qū)FILE*f;/寫文件指針char*buff;/讀入文件內(nèi)容uint32_tnFileLen;/文1£度printf("請(qǐng)輸入文件名：n");scanf("%s",&file);f

3、=fopen(file,"rb");if(f=NULL)printf("打開文件失敗或文件不存在！n");fseek(f,0,SEEK_END);nFileLen=ftell;rewind;回到到文件頭部buff=(char*)malloc(nFileLen);iResult=fread(buff,1,nFileLen,f);if(iResult!=nFileLen)printf("讀入文件錯(cuò)誤！n");return0;memset(sendline,0,MAXLINE);memset(recvline,0,MAXLINE);whil

4、e(i!=nFileLen)recvlinei=*buff;i+；buff+;/文件名傳輸結(jié)束sprintf(sendline,"%s#%d%s",file,nFileLen,recvline);%d",WSAGetLastError();iResult=send(s,sendline,sizeof(sendline),0);if(iResult=SOCKET_ERROR)printf("send函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào):return-1;fclose(fp);printf("文件發(fā)送完成！n");returniResult;1報(bào)務(wù)器：n

5、ttcp_server_fun_echo(SOCKETs)1FILE*fp;inti=0;charflong4;intiResult=0;uint32_tnFileLen=1;charrecvlineMAXLINE;charfile10;memset(file,0,sizeof(file);memset(recvline,0,sizeof(recvline);for(;)iResult=recv(s,&filei,1,0);if(iResult=SOCKET_ERROR)printf("recv函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：d",WSAGetLastError();retu

6、rn-1;if(filei='#')break;elsei+；filei='0'fp=fopen(file,"w+");if(fp=NULL)printf("文件打開失??！")；/接收文件長(zhǎng)度iResult=recv(s,flong,4,0);if(iResult=SOCKET_ERROR)printf("recv函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：d",WSAGetLastError();return-1;sscanf(flong,"%d",&nFileLen);Result=recv(

7、s,recvline,nFileLen,0);if(iResult=SOCKET_ERROR)printf("recv函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：d",WSAGetLastError();return-1;fputs(recvline,fp);fclose(fp);printf("文件接收成功！n");returniResult;1頭文件(上次的實(shí)驗(yàn)報(bào)告中已經(jīng)寫過)：#ifndefp_h預(yù)處理指令，防止重復(fù)包含頭文件#include<stdio.h>#include<time.h>#include<ws2tcpip.h>#i

8、nclude<winsock2.h>#include<windows.h>#pragmacoment(lib,"ws2_32.lib")usingnamespacestd;classCSocketFramepublic:intstart_up();intclean_up();intset_address(char*hname,char*sname,structsockaddr_in*sap,char*protocol);intquit(SOCKETs);SOCKETtcp_server(ULONGuIP,USHORTuPort);SOCKETtcp_

9、server(char*hname,char*sname);SOCKETtcp_client(char*hname,char*sname);SOCKETtcp_client(ULONGuIP,USHORTuPort);ntCSocketFrame:start_up(void)WORDwVersionRequested;WSADATAwsaData;intiResult;wVersionRequested=MAKEWORD(2,2);iResult=WSAStartup(wVersionRequested,&wsaData);if(iResult!=0)(printf("WSA

10、Startup調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：dn",WSAGetLastError();return-1;)/*if(LOBYTE(wsaData.wVersion!=2|HIBYTE(wsaData.wVersion)!=2)(printf("無(wú)法找到可用的WS詼本n");WSACleanup();return-1;/告訴用戶無(wú)法找到可用的WSD)else(printf("WS2.2初始化成功！n");*/return0;ntCSocketFrame:clean_up(void)intiResult;iResult=WSACleanup();if(iRe

11、sult=SOCKET_ERROR)/WSACleanup()調(diào)用失敗printf("WSACleanup調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：dn",WSAGetLastError();return-1;elseprintf("Winsocketdll釋放成功！n");return0;1ntCSocketFrame:set_address(char*hname,char*sname,structsockaddr_in*sap,char*protocol)1structservent*sp;structhostent*hp;char*endptr;unsignedshort

12、port;unsignedlongulAddr=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)用錯(cuò)誤，調(diào)用gethostbyname獲得主機(jī)地址hp=gethostbyname(hname);if(hp=NULL)printf("

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

14、為網(wǎng)絡(luò)字節(jié)序sap->sin_port=htons(port);else/如果失敗，則假定是一個(gè)服務(wù)名稱，通過getservbyname()函數(shù)獲得端口號(hào)sp=getservbyname(sname,protocol);if(sp=NULL)printf("未知服務(wù)，錯(cuò)誤號(hào)：dn",WSAGetLastError();return-1;sap->sin_port=sp->s_port;return0;1ntCSocketFrame:quit(SOCKETs)1intiResult=0;iResult=closesocket(s);if(iResult=SO

15、CKET_ERROR)printf("closesocket調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：dn",WSAGetLastError();return-1;iResult=clean_up();returniResult;1SOCKETCSocketFrame:tcp_server(char*hname,char*sname)1SOCKETListenSocket;intiResult=0;sockaddr_inlocal;constinton=1;/為服務(wù)器的本機(jī)地址設(shè)置用戶輸入的地址以及端口號(hào)if(set_address(hname,sname,&local,(char*)&q

16、uot;tcp")!=0)return-1;/創(chuàng)建套接字ListenSocket=socket(AF_INET,SOCK_STREAM,0);if(ListenSocket=INVALID_SOCKET)printf("socket函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：dn",WSAGetLastError();WSACleanup();return-1;/綁定服務(wù)器地址iResult=bind(ListenSocket,(structsockaddr*)&local,sizeof(local);if(iResult=-1)printf("bind函數(shù)調(diào)用錯(cuò)誤！

17、錯(cuò)誤號(hào)：dn",WSAGetLastError();closesocket(ListenSocket);WSACleanup();return-1;/設(shè)置函數(shù)為監(jiān)聽狀態(tài)，監(jiān)聽隊(duì)列長(zhǎng)度為NLISTENiResult=listen(ListenSocket,SOMAXCONN);if(iResult=SOCKET_ERROR)printf("Listen函數(shù)調(diào)用錯(cuò)誤！錯(cuò)誤號(hào)：dn",WSAGetLastError();quit(ListenSocket);return-1;returnListenSocket;1SOCKETCSocketFrame:tcp_serve

18、r(ULONGuIP,USHORTuPort)1SOCKETListenSocket=INVALID_SOCKET;intiResult=0;sockaddr_inlocal;constinton=1;/為服務(wù)器的本機(jī)地址設(shè)置用戶輸入的地址以及端口號(hào)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(List

19、enSocket=INVALID_SOCKET)printf("socket函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：dn",WSAGetLastError();clean_up();return-1;/綁定服務(wù)器地址iResult=bind(ListenSocket,(structsockaddr*)&local,sizeof(local);if(iResult=SOCKET_ERROR)printf("bind函數(shù)調(diào)用錯(cuò)誤！錯(cuò)誤號(hào)：dn",WSAGetLastError();quit(ListenSocket);return-1;/設(shè)置函數(shù)為監(jiān)聽狀態(tài)，監(jiān)聽隊(duì)列長(zhǎng)

20、度為NLISTENiResult=listen(ListenSocket,SOMAXCONN);if(iResult=SOCKET_ERROR)printf("Listen函數(shù)調(diào)用錯(cuò)誤！錯(cuò)誤號(hào)：dn",WSAGetLastError();quit(ListenSocket);return-1;returnListenSocket;1SOCKETCSocketFrame:tcp_client(char*hname,char*sname)1intiResult=0;structsockaddr_inpeer;SOCKETClientSocket;/為服務(wù)器的地址peer設(shè)置用戶

21、輸入的地址以及端口號(hào)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)用錯(cuò)誤，錯(cuò)誤號(hào)：dn",WSAGetLastError();clean_up();return-1;/請(qǐng)求建立連接iResult=connect(ClientSocket,(structsockaddr*)&pe

22、er,sizeof(peer);if(iResult=SOCKET_ERROR)printf("connect函數(shù)調(diào)用錯(cuò)誤！錯(cuò)誤號(hào)：dn",WSAGetLastError();quit(ClientSocket);return-1;returnClientSocket;1SOCKETCSocketFrame:tcp_client(ULONGuIP,USHORTuPort)1intiResult=0;structsockaddr_inpeer;SOCKETClientSocket;/為服務(wù)器的地址peer設(shè)置用戶輸入的地址以及端口號(hào)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)用錯(cuò)誤，錯(cuò)誤號(hào)：dn",WSAG