VC6.0 网络程序设计 UDP 文件传输 客户端与服务器端

//服务器端 #include<stdio.h> #pragma comment(lib,"WS2_32.lib") #include<Winsock2.h> #include<string.h> #include<memory.h> #include <string.h> #include <conio.h> FILE *fp; #define MAX_BUF 60000 //发送数据的最大大小 int main() { WSAData wsadata; int err = WSAStartup(WINSOCK_VERSION,&wsadata); if(0 != err ) { return 0; } SOCKET sock; sock = socket(AF_INET, SOCK_DGRAM, 0); if(INVALID_SOCKET == sock) { WSACleanup(); return -1; } sockaddr_in localaddr; localaddr.sin_family = AF_INET; localaddr.sin_port = htons(20000); localaddr.sin_addr.s_addr = htonl(INADDR_ANY); err = bind(sock,(sockaddr *)&localaddr,sizeof(localaddr)); if(SOCKET_ERROR == err) { closesocket(sock); WSACleanup(); return -1; } sockaddr_in clientaddr; char rbuf[MAX_BUF]; memset(rbuf,0,MAX_BUF); int len = sizeof(SOCKADDR); int rbyte = recvfrom(sock,rbuf,MAX_BUF,0,(sockaddr *)&clientaddr,&len); if(SOCKET_ERROR == rbyte) { closesocket(sock); WSACleanup(); return -1; } char sendBuf[MAX_BUF]; fp= fopen(rbuf, "rb+" ); if(NULL == fp) { printf( "打开文件出错!" ); fclose(fp); } //利用文件定位函数计算文件大小 fseek(fp,0,2); long double fsizes=ftell(fp); fseek(fp,0,0); //文件传输 int rByte; do { if(fsizes > MAX_BUF) { fread(sendBuf,MAX_BUF,1,fp); rByte = sendto(sock,sendBuf,MAX_BUF,0,(sockaddr*)&clientaddr,sizeof(SOCKADDR)); if(SOCKET_ERROR == rByte) { closesocket(sock); WSACleanup(); return -1; } Sleep(5); printf("%d\n",rByte); } else { fread(sendBuf,fsizes,1,fp); rByte = sendto(sock,sendBuf,fsizes,0,(sockaddr*)&clientaddr,sizeof(SOCKADDR)); if(SOCKET_ERROR == rByte) { closesocket(sock); WSACleanup(); return -1; } printf("%d\n",rByte); break; } fsizes -= rByte; }while(1); //发送空报文 sendto(sock,sendBuf,0,0,(sockaddr*)&clientaddr,sizeof(SOCKADDR)); fclose(fp); closesocket(sock); WSACleanup(); return 0; }