利用流式套接字實(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)康?2.實(shí)驗(yàn)要求 3.實(shí)驗(yàn)環(huán)境 4.實(shí)驗(yàn)作業(yè) 5.問(wèn)題及解決 6.思考問(wèn)題 7.實(shí)驗(yàn)體會(huì)【實(shí)驗(yàn)?zāi)康摹?.掌握定長(zhǎng)與變長(zhǎng)流式套接字的使用方法2.加深對(duì)流式套接字的掌握3.掌握一些解決實(shí)際問(wèn)題的能力【實(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ù)）服務(wù)端接收

2、完文件后，向客戶端發(fā)送ok，以示成功接收客戶端接收到OK后，關(guān)閉套接字服務(wù)器關(guān)閉套接字【實(shí)驗(yàn)環(huán)境】Dev c【實(shí)驗(yàn)作業(yè)】客戶端:int tcp_client_fun_echo(FILE *fp,SOCKET s)int iResult;char sendlineMAXLINE,recvlineMAXLINE;char file20;char flong4;int i=0;/文件名發(fā)送控制 /初始化緩沖區(qū) FILE *f;/寫(xiě)文件指針 char *buff;/讀入文件內(nèi)容 uint32_t nFileLen;/文件長(zhǎng)度printf("請(qǐng)輸入文件名：n");scanf(&quo

3、t;%s",&file);f=fopen(file,"rb"); if(f=NULL)printf("打開(kāi)文件失敗或文件不存在！n");fseek(f,0,SEEK_END);nFileLen=ftell(f);rewind(f);/回到到文件頭部 buff=(char *)malloc(nFileLen);iResult=fread(buff,1,nFileLen,f);if(iResult!=nFileLen)printf("讀入文件錯(cuò)誤！n");return 0; memset(sendline,0,MAXLI

4、NE);memset(recvline,0,MAXLINE);while(i!=nFileLen)recvlinei=*buff;i+;buff+;/文件名傳輸結(jié)束 sprintf(sendline,"%s#%d%s",file,nFileLen,recvline);iResult=send(s,sendline,sizeof(sendline),0);if(iResult=SOCKET_ERROR)printf("send函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：%d",WSAGetLastError();return -1;fclose(fp);printf("

5、;文件發(fā)送完成！n"); return iResult;服務(wù)器：int tcp_server_fun_echo(SOCKET s)FILE *fp;int i=0;char flong4; int iResult = 0;uint32_t nFileLen=1;char recvlineMAXLINE;char file10;memset(file,0,sizeof(file);memset(recvline,0,sizeof(recvline);for(;)iResult=recv(s,&filei,1,0);if(iResult=SOCKET_ERROR)printf(&

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

7、1;sscanf(flong,"%d",&nFileLen);iResult=recv(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"); return iResult;頭文件（上次的實(shí)驗(yàn)報(bào)告中已經(jīng)寫(xiě)過(guò)）：#ifndef p_h/預(yù)處理指令，防止重復(fù)包含頭文件 #includ

8、e<stdio.h>#include<time.h>#include<ws2tcpip.h>#include<winsock2.h>#include<windows.h>#pragma coment(lib,"ws2_32.lib") using namespace std;class CSocketFrame public: int start_up(); int clean_up(); int set_address(char *hname,char *sname,struct sockaddr_in *sap

9、,char *protocol); int quit(SOCKET s); SOCKET tcp_server(ULONG uIP,USHORT uPort); SOCKET tcp_server(char *hname,char *sname); SOCKET tcp_client(char *hname,char *sname); SOCKET tcp_client(ULONG uIP,USHORT uPort);int CSocketFrame:start_up(void)WORD wVersionRequested; WSADATA wsaData; int iResult; wVer

10、sionRequested=MAKEWORD(2,2); iResult=WSAStartup(wVersionRequested,&wsaData); if(iResult!=0) printf("WSAStartup 調(diào)用錯(cuò)誤，錯(cuò)誤號(hào):%dn",WSAGetLastError(); return -1; /* if(LOBYTE(wsaData.wVersion!=2|HIBYTE(wsaData.wVersion)!=2) printf("無(wú)法找到可用的WSD版本n"); WSACleanup(); return -1; /告訴用戶無(wú)法找到

11、可用的WSD else printf("WS2.2初始化成功！n"); */ return 0;int CSocketFrame:clean_up(void)int iResult;iResult=WSACleanup();if(iResult=SOCKET_ERROR)/WSACleanup()調(diào)用失敗 printf("WSACleanup 調(diào)用錯(cuò)誤，錯(cuò)誤號(hào):%dn",WSAGetLastError(); return -1; elseprintf("Winsocket dll釋放成功！n") ;return 0;int CSock

12、etFrame:set_address(char *hname,char *sname,struct sockaddr_in *sap,char *protocol)struct servent *sp;struct hostent *hp;char *endptr;unsigned short 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)/如果hna

13、me不為空，轉(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("未知的主機(jī)名，錯(cuò)誤號(hào)：%dn",WSAGetLastError();return -1; sap->sin_addr=*(struct in_addr *)hp->h_addr;elsesap->sin_addr.S_un.S_addr=ulAddr;else/如果調(diào)

14、用者沒(méi)有指明一個(gè)主機(jī)名或地址，則設(shè)為通配地址sap->sin_addr.s_addr=htonl(INADDR_ANY);/嘗試轉(zhuǎn)換sname為一個(gè)整數(shù) port=(unsigned short)strtol(sname,&endptr,0);if(*endptr='0')/如果成功轉(zhuǎn)化為網(wǎng)絡(luò)字節(jié)序sap->sin_port=htons(port); else/如果失敗，則假定是一個(gè)服務(wù)名稱，通過(guò)getservbyname()函數(shù)獲得端口號(hào)sp=getservbyname(sname,protocol);if(sp=NULL)printf("未知服

15、務(wù)，錯(cuò)誤號(hào)：%dn",WSAGetLastError();return -1;sap->sin_port=sp->s_port; return 0;int CSocketFrame:quit(SOCKET s)int iResult=0;iResult=closesocket(s);if(iResult=SOCKET_ERROR)printf("closesocket 調(diào)用錯(cuò)誤，錯(cuò)誤號(hào):%dn",WSAGetLastError(); return -1;iResult=clean_up();return iResult;SOCKET CSocketFr

16、ame:tcp_server(char *hname,char *sname)SOCKET ListenSocket;int iResult=0;sockaddr_in local; const int on=1;/為服務(wù)器的本機(jī)地址設(shè)置用戶輸入的地址以及端口號(hào)if(set_address(hname,sname,&local,(char*)"tcp")!=0)return -1;/創(chuàng)建套接字ListenSocket=socket(AF_INET,SOCK_STREAM,0);if(ListenSocket=INVALID_SOCKET) printf("

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

18、iResult=listen(ListenSocket,SOMAXCONN);if(iResult=SOCKET_ERROR)printf("Listen函數(shù)調(diào)用錯(cuò)誤！錯(cuò)誤號(hào)：%dn",WSAGetLastError();quit(ListenSocket);return -1; return ListenSocket;SOCKET CSocketFrame:tcp_server(ULONG uIP,USHORT uPort)SOCKET ListenSocket=INVALID_SOCKET;int iResult=0;sockaddr_in local;const in

19、t on=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(ListenSocket=INVALID_SOCKET)printf("socket函數(shù)調(diào)用錯(cuò)誤，錯(cuò)誤號(hào)：%dn",WSAGetLastError();clean_up();r

20、eturn -1; /綁定服務(wù)器地址iResult=bind(ListenSocket,(struct sockaddr *) & 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īng)狀態(tài)，監(jiān)聽(tīng)隊(duì)列長(zhǎng)度為NLISTENiResult=listen(ListenSocket,SOMAXCONN);if(iResult=SOCKET_ERROR)printf("

21、;Listen函數(shù)調(diào)用錯(cuò)誤！錯(cuò)誤號(hào)：%dn",WSAGetLastError();quit(ListenSocket);return -1; return ListenSocket;SOCKET CSocketFrame:tcp_client(char *hname,char *sname)int iResult=0;struct sockaddr_in peer;SOCKET ClientSocket;/為服務(wù)器的地址peer設(shè)置用戶輸入的地址以及端口號(hào)if(set_address(hname,sname,&peer,(char *)"tcp")!=0)

22、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,(struct sockaddr *) & peer,sizeof(peer);if(iResult=SOCKET_ERROR)printf("connect函數(shù)調(diào)用錯(cuò)

23、誤！錯(cuò)誤號(hào)：%dn",WSAGetLastError();quit(ClientSocket);return -1; return ClientSocket;SOCKET CSocketFrame:tcp_client(ULONG uIP,USHORT uPort)int iResult=0;struct sockaddr_in peer;SOCKET ClientSocket;/為服務(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)