文件传输协议的简单设计与实现(c语言)

文件传输协议的简单设计与实现(c语言,VC6.0)

[align=left]使用Socket进行Client/Server程序设计的一般连接过程是这样的：Server端Listen(监听)某个端口是否有连接请求，Client端向Server端发出Connect(连接)请求，Server端向Client端发回Accept（接受）消息。一个连接就建立起来了。Server端和Client端都可以通过Send，Write等方法与对方通信。
　　对于一个功能齐全的Socket，都要包含以下基本结构，其工作过程包含以下四个基本的步骤：
　　（1） 创建Socket；
　　（2） 打开连接到Socket的输入/出流；
　　（3） 按照一定的协议对Socket进行读/写操作；
　　（4） 关闭Socket.
　　第三步是程序员用来调用Socket和实现程序功能的关键步骤，其他三步在各种程序中基本相同。
/****************client.c****************/[/align]
[align=left]#include <winsock2.h>[/align]
[align=left]#include <stdio.h>[/align]
[align=left]#include <stdlib.h>[/align]
[align=left]#pragma comment(lib,"ws2_32.lib")[/align]
[align=left]#define DEFAULT_PORT 2302[/align]
[align=left]#define DEFAULT_BUFFER 2048[/align]
[align=left]#define DEFAULT_MESSAGE "This is a test of the emergency / broadcasting system"[/align]
[align=left]char szServerip[128], // Server to connect to[/align]
[align=left] szMessage[1024]; // Message to send to sever[/align]
[align=left]int iPort = DEFAULT_PORT; // Port on server to connect to[/align]
[align=left]//DWORD dwCount = DEFAULT_COUNT; // Number of times to send message[/align]
[align=left]BOOL bSendOnly = FALSE; // Send data only; don't receive[/align]
[align=left]int dirfun();[/align]
[align=left]int getfun();[/align]
[align=left]int putfun();[/align]
[align=left]int pwdfun();[/align]
[align=left]int cdfun();[/align]
[align=left]int mdfun();[/align]
[align=left]int delfun();[/align]
[align=left]int usafun();[/align]
[align=left] [/align]
[align=left]void usage()[/align]
[align=left]{[/align]
[align=left] printf("usage: client [-p:x] [-s:IP] [-n:x] [-o]/n/n");[/align]
[align=left] printf(" -p:x Remote port to send to/n");[/align]
[align=left] printf(" -s:IP Server's IP address or hostname/n");[/align]
[align=left] printf(" -n:x Number of times to send message/n");[/align]
[align=left] printf(" -o Send messages only; don't receive/n");[/align]
[align=left] ExitProcess(1);[/align]
[align=left]}[/align]
[align=left]void ValidateArgs(int argc, char **argv)[/align]
[align=left]{[/align]
[align=left] int i;[/align]
[align=left] [/align]
[align=left] for(i = 1; i < argc; i++)[/align]
[align=left] {[/align]
[align=left] if ((argv[i][0] == '-') || (argv[i][0] == '/'))[/align]
[align=left] {[/align]
[align=left] switch (tolower(argv[i][1]))[/align]
[align=left] {[/align]
[align=left] case 'p': // Remote port[/align]
[align=left] if (strlen(argv[i]) > 3)[/align]
[align=left] iPort = atoi(&argv[i][3]);[/align]
[align=left] break;[/align]
[align=left] case 's': // Server[/align]
[align=left] if (strlen(argv[i]) > 3)[/align]
[align=left] strcpy(szServerip, &argv[i][3]);[/align]
[align=left] break;[/align]
[align=left] case 'n': // Number of times to send message[/align]
[align=left] if (strlen(argv[i]) > 3)[/align]
[align=left] //dwCount = atol(&argv[i][3]);[/align]
[align=left] break;[/align]
[align=left] case 'o': // Only send message; don't receive[/align]
[align=left] bSendOnly = TRUE;[/align]
[align=left] break;[/align]
[align=left] default:[/align]
[align=left] usage();[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left]}[/align]
[align=left]int main(int argc, char **argv)[/align]
[align=left]{[/align]
[align=left] WSADATA wsd;[/align]
[align=left] SOCKET sClient;[/align]
[align=left] char szBuffer[DEFAULT_BUFFER];[/align]
[align=left] int ret;[/align]
[align=left] //unsigned int i;[/align]
[align=left] //int j;[/align]
[align=left] struct sockaddr_in server;[/align]
[align=left] struct hostent *host = NULL;[/align]
[align=left] char choice[5],choice2[40];[/align]
[align=left] // Parse the command line and load Winsock[/align]
[align=left] //[/align]
[align=left] argv[1]="-s:127.0.0.1";[/align]
[align=left] strcpy(szServerip, &argv[1][3]);[/align]
[align=left] //ValidateArgs(argc, argv);[/align]
[align=left] if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)[/align]
[align=left] {[/align]
[align=left] printf("Failed to load Winsock library!/n");[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] //strcpy(szMessage, DEFAULT_MESSAGE);[/align]
[align=left] //[/align]
[align=left] // Create the socket, and attempt to connect to the server[/align]
[align=left] //[/align]
[align=left] sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);[/align]
[align=left] if (sClient == INVALID_SOCKET)[/align]
[align=left] {[/align]
[align=left] printf("socket() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] server.sin_family = AF_INET;[/align]
[align=left] server.sin_port = htons(iPort);[/align]
[align=left] printf("server.sin_port=%u/n",server.sin_port);[/align]
[align=left] server.sin_addr.s_addr = inet_addr(szServerip);[/align]
[align=left] //[/align]
[align=left] // If the supplied server address wasn't in the form[/align]
[align=left] // "aaa.bbb.ccc.ddd" it's a hostname, so try to resolve it[/align]
[align=left] //[/align]
[align=left] if (server.sin_addr.s_addr == INADDR_NONE)[/align]
[align=left] {[/align]
[align=left] host = gethostbyname(szServerip);[/align]
[align=left] if (host == NULL)[/align]
[align=left] {[/align]
[align=left] printf("Unable to resolve server: %s/n", szServerip);[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] CopyMemory(&server.sin_addr, host->h_addr_list[0],[/align]
[align=left] host->h_length);[/align]
[align=left] }[/align]
[align=left] if (connect(sClient, (struct sockaddr *)&server, [/align]
[align=left] sizeof(server)) == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("connect() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] //显示接通信息[/align]
[align=left] //[/align]
[align=left] //[/align]
[align=left] //for(j=0;j<2;j++)[/align]
[align=left] //[/align]
[align=left] {[/align]
[align=left] ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);[/align]
[align=left] if (ret == 0) // Graceful close[/align]
[align=left] return 0;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 0;[/align]
[align=left] }[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] printf("%s/n",szBuffer);[/align]
[align=left] if(ret<15)[/align]
[align=left] {[/align]
[align=left] ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);[/align]
[align=left] if (ret == 0) // Graceful close[/align]
[align=left] return 0;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] //printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 0;[/align]
[align=left] }[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] printf("%s/n",szBuffer);[/align]
[align=left] }[/align]
[align=left] //printf("DEFAULT_BUFFER=%d/n",DEFAULT_BUFFER);[/align]
[align=left] [/align]
[align=left] }[/align]
[align=left] while(1)[/align]
[align=left] { [/align]
[align=left] puts("------------------------------------------");[/align]
[align=left] printf("ftp> ");[/align]
[align=left] scanf("%s", choice);[/align]
[align=left] [/align]
[align=left] [/align]
[align=left] if(strncmp(choice,"dir",3)==0||strncmp(choice,"DIR",2)==0)[/align]
[align=left] {[/align]
[align=left] dirfun(sClient);[/align]
[align=left] continue;[/align]
[align=left] } [/align]
[align=left] else if(strncmp(choice,"pwd",3)==0||strncmp(choice,"PWD",3)==0)[/align]
[align=left] {[/align]
[align=left] [/align]
[align=left] pwdfun(sClient);[/align]
[align=left] continue;[/align]
[align=left] }[/align]
[align=left] else if(strncmp(choice,"?",1)==0)[/align]
[align=left] {[/align]
[align=left] usafun(sClient);[/align]
[align=left] continue;[/align]
[align=left] }[/align]
[align=left] else if(strncmp(choice,"quit",4)==0||strncmp(choice,"QUIT",2)==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] scanf("%s", choice2);[/align]
[align=left] if(strncmp(choice,"get",3)==0||strncmp(choice,"GET",3)==0)[/align]
[align=left] {[/align]
[align=left] getfun(sClient,choice2);[/align]
[align=left] continue;[/align]
[align=left] }[/align]
[align=left] else if(strncmp(choice,"put",3)==0||strncmp(choice,"PUT",3)==0)[/align]
[align=left] {[/align]
[align=left] putfun(sClient,choice2);[/align]
[align=left] continue;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] else if(strncmp(choice,"cd",2)==0||strncmp(choice,"CD",2)==0)[/align]
[align=left] {[/align]
[align=left] cdfun(sClient,choice2);[/align]
[align=left] continue;[/align]
[align=left] }[/align]
[align=left] else if(strncmp(choice,"md",2)==0||strncmp(choice,"MD",2)==0)[/align]
[align=left] {[/align]
[align=left] mdfun(sClient,choice2);[/align]
[align=left] continue;[/align]
[align=left] }[/align]
[align=left] else if(strncmp(choice,"del",3)==0||strncmp(choice,"DEL",3)==0)[/align]
[align=left] {[/align]
[align=left] delfun(sClient,choice2);[/align]
[align=left] continue;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] //else[/align]
[align=left] puts("输入错误，请重新输入");[/align]
[align=left] fflush(stdin);[/align]
[align=left] fflush(stdin);[/align]
[align=left] printf("/n"); [/align]
[align=left] printf("/n");[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] closesocket(sClient);[/align]
[align=left] [/align]
[align=left] WSACleanup();[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int dirfun(SOCKET sClient)[/align]
[align=left]{[/align]
[align=left] int ret;[/align]
[align=left] char *MSG="dir$";char szBuffer[80];[/align]
[align=left] strcpy(szMessage, MSG);[/align]
[align=left] [/align]
[align=left] ret = send(sClient, szMessage, strlen(szMessage), 0);[/align]
[align=left] if (ret == 0)[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("send() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] //printf("Send %d bytes/n", ret);[/align]
[align=left] //printf("bSendOnly=%d/n",bSendOnly);[/align]
[align=left] while(!bSendOnly)[/align]
[align=left] {[/align]
[align=left] //读取流并显示 [/align]
[align=left] //ret = recv(sClient, szBuffer, 80, 0);[/align]
[align=left] //printf("%s",szBuffer);[/align]
[align=left] ret = recv(sClient, szBuffer, 80, 0);[/align]
[align=left] if (ret == 0) // Graceful close[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] [/align]
[align=left] [/align]
[align=left] if(strncmp(szBuffer,"226 Close",strlen("226 Close"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] printf("%s",szBuffer);[/align]
[align=left] if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] }[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int getfun(SOCKET sClient,char filename[40])[/align]
[align=left]{[/align]
[align=left] int ret;[/align]
[align=left] FILE *fpre;[/align]
[align=left] char szBuffer[80]; [/align]
[align=left] szMessage[0]='/0';[/align]
[align=left] strcat(szMessage, "get$");[/align]
[align=left] //strcat(szMessage, "//");[/align]
[align=left] strcat(szMessage,filename);[/align]
[align=left] //printf("MSG[4]=%c/n",szMessage[4]);[/align]
[align=left] [/align]
[align=left] //szMessage[0]='g';szMessage[1]='e';szMessage[2]='t';[/align]
[align=left] //[/align]
[align=left] //szMessage[4]='m';szMessage[5]='e';szMessage[6]='.';szMessage[7]='t';[/align]
[align=left] //[/align]
[align=left] //szMessage[8]='x';szMessage[9]='t';szMessage[10]='/0';[/align]
[align=left] ret = send(sClient, szMessage, strlen(szMessage)+1, 0);[/align]
[align=left] if (ret == 0)[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("send() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] printf("Send %d bytes/n", ret);[/align]
[align=left] ret = recv(sClient, szBuffer, 80, 0);[/align]
[align=left] /*if (ret == 0) // Graceful close[/align]
[align=left] break;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] break;[/align]
[align=left] }*/[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] printf("%s/n",szBuffer);[/align]
[align=left] if(strncmp( szBuffer,"125 Transfering...",strlen("125 Transfering...") )==0)[/align]
[align=left] {[/align]
[align=left] if( (fpre=fopen(filename,"w")) == NULL )[/align]
[align=left] {[/align]
[align=left] printf("open errer");[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] printf("bSendOnly=%d/n",bSendOnly);[/align]
[align=left] while(!bSendOnly)[/align]
[align=left] {[/align]
[align=left] //读取流并显示[/align]
[align=left] ret = recv(sClient, szBuffer, 80, 0);[/align]
[align=left] if (ret == 0) // Graceful close[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] [/align]
[align=left] //printf("%s",szBuffer); [/align]
[align=left] if(strncmp(szBuffer,"226 Transfer",strlen("226 Transfer"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] fprintf(fpre,"%s",szBuffer);[/align]
[align=left] }[/align]
[align=left] printf("%s/n",szBuffer);[/align]
[align=left] fclose(fpre);[/align]
[align=left] }[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int putfun(SOCKET sClient,char filename[40])[/align]
[align=left]{[/align]
[align=left] int ret;//int i;[/align]
[align=left] FILE *fpse;//char *filename;[/align]
[align=left] //char *MSG="get/0me.txt";[/align]
[align=left] [/align]
[align=left] char szBuffer[80],temp_buffer[80];[/align]
[align=left] //sprintf(szMessage, "get/0","te.txt/0");[/align]
[align=left] szMessage[0]='/0';[/align]
[align=left] strcat(szMessage, "put$");[/align]
[align=left] strcat(szMessage,filename);[/align]
[align=left] ret = send(sClient, szMessage, strlen(szMessage)+1, 0);[/align]
[align=left] if (ret == 0)[/align]
[align=left] return 0;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("send() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] //printf("Send %d bytes/n", ret);[/align]
[align=left] //filename="me.txt";[/align]
[align=left] printf("filename=%s/n",filename);[/align]
[align=left] if( (fpse=fopen(filename,"r")) == NULL )[/align]
[align=left] {[/align]
[align=left] printf("open errer");[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] else[/align]
[align=left] {[/align]
[align=left] printf("The file %s found,ready to transfer./n",filename);[/align]
[align=left] //i=0;[/align]
[align=left] while (fgets(temp_buffer,80,fpse)!=NULL)[/align]
[align=left] {[/align]
[align=left] sprintf(szBuffer,"%s",temp_buffer); [/align]
[align=left] send(sClient, szBuffer, 80, 0);[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] sprintf(szBuffer, "226 Transfer completed... /r/n"); [/align]
[align=left] ret = send(sClient, szBuffer, strlen(szBuffer), 0);[/align]
[align=left] [/align]
[align=left] fclose(fpse);[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int pwdfun(SOCKET sClient)[/align]
[align=left]{[/align]
[align=left] int ret;[/align]
[align=left] char *MSG="pwd$";[/align]
[align=left] char szBuffer[160];[/align]
[align=left] strcpy(szMessage, MSG);[/align]
[align=left] ret = send(sClient, szMessage, strlen(szMessage), 0);[/align]
[align=left] if (ret == 0)[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("send() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] printf("Send %d bytes/n", ret);[/align]
[align=left] printf("bSendOnly=%d/n",bSendOnly);[/align]
[align=left] while(!bSendOnly)[/align]
[align=left] {[/align]
[align=left] //读取流并显示[/align]
[align=left] ret = recv(sClient, szBuffer, 160, 0);[/align]
[align=left] if (ret == 0) // Graceful close[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] printf("%s/n",szBuffer);[/align]
[align=left] [/align]
[align=left] if(strncmp(szBuffer,"226 Close",strlen("226 Close"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int cdfun(SOCKET sClient,char pathname[40])[/align]
[align=left]{[/align]
[align=left] int ret;[/align]
[align=left] [/align]
[align=left] szMessage[0]='/0';[/align]
[align=left] strcat(szMessage, "cd$");[/align]
[align=left] strcat(szMessage,pathname);[/align]
[align=left] ret = send(sClient, szMessage, strlen(szMessage)+1, 0);[/align]
[align=left] if (ret == 0)[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("send() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] printf("Send %d bytes/n", ret);[/align]
[align=left] [/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int mdfun(SOCKET sClient,char pathname[20])[/align]
[align=left]{[/align]
[align=left] int ret;char szBuffer[160];[/align]
[align=left] //char *MSG="md$";[/align]
[align=left] szMessage[0]='/0';[/align]
[align=left] strcat(szMessage, "md$");[/align]
[align=left] //strcat(szMessage, "//");[/align]
[align=left] strcat(szMessage,pathname);[/align]
[align=left] //strcpy(szMessage, MSG);[/align]
[align=left] [/align]
[align=left] ret = send(sClient, szMessage, strlen(szMessage)+1, 0);[/align]
[align=left] if (ret == 0)[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("send() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] printf("Send %d bytes/n", ret);[/align]
[align=left] while(!bSendOnly)[/align]
[align=left] {[/align]
[align=left] //读取流并显示 [/align]
[align=left] ret = recv(sClient, szBuffer, 80, 0);[/align]
[align=left] if (ret == 0) // Graceful close[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] [/align]
[align=left] printf("%s",szBuffer); [/align]
[align=left] if(strncmp(szBuffer,"226 Close",strlen("226 Close"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] }[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int delfun(SOCKET sClient,char name[20])[/align]
[align=left]{[/align]
[align=left] int ret;char szBuffer[80];[/align]
[align=left] szMessage[0]='/0';[/align]
[align=left] strcat(szMessage, "del$");[/align]
[align=left] [/align]
[align=left] strcat(szMessage,name);[/align]
[align=left] ret = send(sClient, szMessage, strlen(szMessage)+1, 0);[/align]
[align=left] if (ret == 0)[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("send() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] printf("Send %d bytes/n", ret);[/align]
[align=left] while(!bSendOnly)[/align]
[align=left] {[/align]
[align=left] ret = recv(sClient, szBuffer, 80, 0);[/align]
[align=left] if (ret == 0) // Graceful close[/align]
[align=left] return 1;[/align]
[align=left] else if (ret == SOCKET_ERROR)[/align]
[align=left] {[/align]
[align=left] printf("recv() failed: %d/n", WSAGetLastError());[/align]
[align=left] return 1;[/align]
[align=left] }[/align]
[align=left] szBuffer[ret] = '/0';[/align]
[align=left] [/align]
[align=left] if(strncmp(szBuffer,"del ok",strlen("del ok"))==0)[/align]
[align=left] {[/align]
[align=left] printf("del %s ok/n",name);[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] printf("%s",szBuffer);[/align]
[align=left] if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0)[/align]
[align=left] {[/align]
[align=left] break;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] }[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
[align=left]int usafun()[/align]
[align=left]{[/align]
[align=left] puts("------------------------------------------");[/align]
[align=left] puts("get：取远方的一个文件");[/align]
[align=left] puts("put：传给远方一个文件");[/align]
[align=left] puts("pwd：显示远主当前目录");[/align]
[align=left] puts("dir：列出远方当前目录");[/align]
[align=left] puts("md ：在远方新建文件夹");[/align]
[align=left] puts("cd ：改变远方当前目录");[/align]
[align=left] puts("？ ：显示你提供的命令");[/align]
[align=left] puts("quit ：退出返回");[/align]
[align=left] return 0;[/align]
[align=left]}[/align]
//int quit()

/****************server.c****************/
#include <stdio.h>
#include <winsock.h>
#include <stdlib.h>
#pragma comment(lib,"ws2_32.lib")
WSADATA wsd;
char sbuffer[80],rbuffer[80];//send and receive buffers
int n,bytes;//counters
SOCKET newsocket,ns_data;
struct sockaddr_in remoteaddr; //remoteaddr_data;
int port_connect=0;//port connect flag
char path[80]="";
char order[100]="";
//SOCKET s_data_port;
int sy_error=1; // use for indicate Syntax error
//server functions
int sdirfun(SOCKET newsocket);
int sgetfun(SOCKET newsocket);
int sputfun(SOCKET newsocket);
int spwdfun(SOCKET newsocket);
int scdfun(SOCKET newsocket);
int smdfun(SOCKET newsocket);
int sdelfun(SOCKET newsocket);
void HandleError(char *func);
//server functions end

//MAIN
int main(int argc, char *argv[])
{
struct sockaddr_in localaddr;//local address structure
SOCKET s;//s_data;//welcome socket and welcome socket for data connection,and port connection for connect to client
int addr_inlen;//address lenght variable
if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
{
WSACleanup();
printf("WSAStartup failed/n");
}
memset(&localaddr,0,sizeof(localaddr));//clear localaddr
s = socket(PF_INET, SOCK_STREAM, 0);

if (s <0)
{
printf("socket failed/n");
}

localaddr.sin_family = AF_INET;

if(argc == 2)
localaddr.sin_port = htons((u_short)atoi(argv[1]));
else
localaddr.sin_port = htons(2302);
localaddr.sin_addr.s_addr = INADDR_ANY;

if (bind(s,(struct sockaddr *)(&localaddr),sizeof(localaddr)) < 0)
{
printf("Bind failed!/n");
}

//INFINITE LOOP
while (1)
{ // while loop 1
//LISTEN
listen(s,3);

addr_inlen = sizeof(remoteaddr);
//ACCEPT main connection (control connection)
newsocket = accept(s,(struct sockaddr *)(&remoteaddr),&addr_inlen);
if (newsocket == INVALID_SOCKET) break;
printf("connected to %s at port %d /n",inet_ntoa(remoteaddr.sin_addr),ntohs(localaddr.sin_port));
//Respond with welcome message, FTP client requires those
sprintf(sbuffer,"200 Welcome /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
sprintf(sbuffer,"530 Log in /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
//INFINITE LOOP
while (1) // while loop 2
{
n = 0;
sy_error=1;
while (1) // while loop 3
{
//RECEIVE
bytes = recv(newsocket, &rbuffer
, 1, 0);
printf("rbuffer[%d]=%c/n",n,rbuffer
);
if ((bytes < 0) || (bytes == 0))
break;
if (rbuffer
== '$')
{
rbuffer
= '/0';
break;
}
if (rbuffer
!= '/r')
n++;

} // end of while loop 3
if ((bytes < 0) || (bytes == 0))
break;
printf("#The Server receives:# '%s' from client /n", rbuffer);

//THE FTP COMMANDS HERE

//LIST
if(strncmp(rbuffer,"dir",3)==0)
{
sdirfun(newsocket);

}
//当前目录
if(strncmp(rbuffer,"pwd",3)==0)
{
spwdfun(newsocket);
}
//改变目录
if (strncmp(rbuffer,"cd",2)==0)
{
scdfun(newsocket);
}

//GET
if (strncmp(rbuffer,"get",3)==0)
{
sgetfun(newsocket);

}
//PUT
if (strncmp(rbuffer,"put",3)==0)
{
sputfun(newsocket);
}
//MD
if (strncmp(rbuffer,"md",2)==0)
{
smdfun(newsocket);
}
if (strncmp(rbuffer,"del",3)==0)
{
sdelfun(newsocket);
}
//QUIT
if (strncmp(rbuffer,"quit",4)==0)
{
printf("quit /n");
sprintf(sbuffer, "221 Bye bye ... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
sy_error=0;
break;
}

//Syntax error
if (sy_error==1)
{
printf("command unrecognized, non-implemented!/n");
sprintf(sbuffer, "500 Syntax error. /n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
}

} // end of while loop 2

//CLOSE CONTROL SOCKET
closesocket(newsocket);
printf("disconnected from %s at port %d, close control socket./n",inet_ntoa(remoteaddr.sin_addr),ntohs(localaddr.sin_port));

} // end of while loop 1
//CLOSE WELCOME SOCKET
closesocket(s);
printf("Welcome sockets close");
return 0;
}
int sdirfun(SOCKET newsocket)
{
char temp_buffer[80];
printf("Equivalent to dir /n");
order[0]='/0';
strcat(order,"dir ");
strcat(order,path);
strcat(order," >tmp.txt");
system(order);
FILE *fin;
fin=fopen("tmp.txt","r");
sprintf(sbuffer, "125 Transfering... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
while (fgets(temp_buffer,80,fin)!=NULL)
{
sprintf(sbuffer,"%s",temp_buffer); //
if (port_connect==0)
send(newsocket, sbuffer, strlen(sbuffer), 0);
}
fclose(fin);
sprintf(sbuffer, "226 Transfer completed... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
system("del tmp.txt");
//CLOSE the ns_data SOCKET or data port SOCKET
if(port_connect==0)
{
closesocket(ns_data);
sprintf(sbuffer,"226 Close the data socket... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
ns_data = socket(AF_INET, SOCK_STREAM, 0);
}

sy_error=0;
return 0;
}
int sgetfun(SOCKET newsocket)
{
printf("RETR mode./r/n");

int i=4,k=0;
char filename[20],temp_buffer[80];
// identify the filename from rbuffer after the word "RETR "
while (1) // while loop 4
{
//RECEIVE
bytes = recv(newsocket, &rbuffer[i], 1, 0);
printf("rbuffer[i]=%c/n",rbuffer[i]);

if ((bytes < 0) || (bytes == 0))
break;
filename[k]=rbuffer[i];
if (rbuffer[i] == '/0')
{ /*end on LF*/
filename[k] = '/0';
break;
}
if (rbuffer[i] != '/r')
{
i++;
k++;/*ignore CR's*/
}
} // end of while loop 4
order[0]='/0';
strcat(order,path);
if(strlen(path)>0)
strcat(order,"//");
strcat(order,filename);

char *p_filename=order;
FILE *fp;
if( (fp=fopen(p_filename,"r")) == NULL )
{
sprintf(sbuffer, "Sorry, cannot open %s. Please try again./r/n",filename);
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
sprintf(sbuffer, "226 Transfer completed... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
return 1;
}
else
{
printf("The file %s found,ready to transfer./n",filename);
sprintf(sbuffer, "125 Transfering... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
while (fgets(temp_buffer,80,fp)!=NULL)
{

sprintf(sbuffer,"%s",temp_buffer); //
if (port_connect==0)

send(newsocket, sbuffer, strlen(sbuffer), 0);

}//end of while
fclose(fp);

sprintf(sbuffer, "226 Transfer completed... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
}
sy_error=0;
return 0;
}
int sputfun(SOCKET newsocket)
{
printf("Equivalent to put. /n");

int i=4,k=0;
char filename[20];
// identify the filename from rbuffer after the word "RETR "
while (1)
{
bytes = recv(newsocket, &rbuffer[i], 1, 0);
if ((bytes < 0) || (bytes == 0))
break;
filename[k]=rbuffer[i];
if (rbuffer[i] == '/0')
{ /*end on LF*/
filename[k] = '/0';
break;
}
if (rbuffer[i] != '/r')
{
i++;
k++;/*ignore CR's*/
}
} // end of while

order[0]='/0';
strcat(order,path);
if(strlen(path)>0)
strcat(order,"//");
strcat(order,filename);
printf("filename=%s,",order);
char *p_filename=order;
FILE *fpse;
if( (fpse=fopen(order,"w")) == NULL )
{
printf("open errer");
return 1;
}
else
{
printf("The file %s found,ready to transfer./n",filename);

while(1)
{
//读取流并显示
int ret;
ret = recv(newsocket, rbuffer, 80, 0);
if (ret == 0) // Graceful close
return 0;
else if (ret == SOCKET_ERROR)
{
printf("recv() failed: %d/n", WSAGetLastError());
return 0;
}
if(strncmp(rbuffer,"226 Transfer",strlen("226 Transfer"))==0)
{
break;
}
fprintf(fpse,"%s",rbuffer);
}
printf("RBUFFER=%s",rbuffer);
fclose(fpse);
}
sy_error=0;
return 0;
}
int spwdfun(SOCKET newsocket)
{
printf("Equivalent to pwd /n");
//order[0]='/0';
//strcat(order,"dir ");
//strcat(order,path);
//strcat(order,);
system("cd >tmp.txt");
FILE *fin;
fin=fopen("tmp.txt","r+");
sprintf(sbuffer, "125 Transfering... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);

char temp_buffer[160];
while (fgets(temp_buffer,80,fin)!=NULL)
{
temp_buffer[strlen(temp_buffer)-1]='/0';
printf("temp_buffer=%s",temp_buffer);
///////////////////////////////目录判定
if(path[0]!='/0')
sprintf(sbuffer,"%s//%s",temp_buffer,path);
else
sprintf(sbuffer,"%s",temp_buffer);
///////////////////////////////
if (port_connect==0)
//send(ns_data, sbuffer, strlen(sbuffer), 0);
send(newsocket, sbuffer, strlen(sbuffer), 0);

}
fclose(fin);

sprintf(sbuffer, "226 Transfer completed... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
system("del tmp.txt");
//CLOSE the ns_data SOCKET or data port SOCKET
if(port_connect==0)
{
closesocket(ns_data);
sprintf(sbuffer,"226 Close the data socket... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
ns_data = socket(AF_INET, SOCK_STREAM, 0);
}

sy_error=0;
return 0;
}
int scdfun(SOCKET newsocket)
{

int i=3,k=0;char name[20],name2[20];
int j,count=0;//path overfollow
int pathlen;
printf("Equivalent to cd /n");
while (1)
{
//RECEIVE

bytes = recv(newsocket, &rbuffer[i], 1, 0);
printf("rbuffer[i]=%c/n",rbuffer[i]);
printf("bytes=%d/n",bytes);
if ((bytes < 0) || (bytes == 0))
break;
name[k]=rbuffer[i];
name2[k]=rbuffer[i];
if (rbuffer[i] == '/0')
{
name[k] = '/0';
name2[k] = '/0';
break;
}
if (rbuffer[i] != '/r')
{
i++;
k++;
}
}//end while
if(path[0]!='/0')
strcat(path,"//");
strcat(path,name);
if(strncmp(name2,"..",2)==0)
{

pathlen=strlen(path);
for(j=pathlen-1;j>=0;j--)
{
if(path[j]=='//')
{
path[j]='/0';
count++;
}
if(count==2)
{
//path[j]='/0';
break;
}
}
printf("%d=/n",j);
path[j+1]='/0';
}
printf("path=%s",path);

sy_error=0;
return 0;
}
int smdfun(SOCKET newsocket)
{
char name[20];
int i=3,k=0;
printf("Equivalent to md /n");
while (1) // while loop 3
{
//RECEIVE
bytes = recv(newsocket, &rbuffer[i], 1, 0);
printf("rbuffer[i]=%c/n",rbuffer[i]);
printf("bytes=%d/n",bytes);
if ((bytes < 0) || (bytes == 0))
break;
name[k]=rbuffer[i];
if (rbuffer[i] == '/0')
{ /*end on LF*/
name[k] = '/0';
break;
}
if (rbuffer[i] != '/r')
{
i++;
k++;/*ignore CR's*/
}
}
order[0]='/0';
strcat(order,"md ");
strcat(order,path);
if(strlen(path)>0)
strcat(order,"//");
strcat(order,name);
system(order);

//CLOSE the ns_data SOCKET or data port SOCKET
if(port_connect==0)
{
//closesocket(ns_data);
sprintf(sbuffer,"226 Close the data socket... /r/n");
bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
//ns_data = socket(AF_INET, SOCK_STREAM, 0);
}
sy_error=0;

return 0;
}
int sdelfun(SOCKET newsocket)
{

int i=3,k=0;char name[20];

printf("Equivalent to del /n");
while (1)
{
//RECEIVE

bytes = recv(newsocket, &rbuffer[i], 1, 0);
printf("rbuffer[i]=%c/n",rbuffer[i]);
printf("bytes=%d/n",bytes);
if ((bytes < 0) || (bytes == 0))
break;
name[k]=rbuffer[i];

if (rbuffer[i] == '/0')
{
name[k] = '/0';

break;
}
if (rbuffer[i] != '/r')
{
i++;
k++;
}
}//end while
order[0]='/0';
strcat(order,"rd ");

strcat(order,path);
if(path[0]!='/0')
strcat(path,"//");
strcat(order,name);
system(order);
sprintf(sbuffer,"del ok... /r/n");

bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);
if (bytes == SOCKET_ERROR)
{
HandleError("recv()");
sy_error=1;
return 1;
}
sy_error=0;
return 0;
}
void HandleError(char *func)
{
char info[65]= {0};
_snprintf(info, 64, "%s: %d/n", func, WSAGetLastError());
printf(info);
}