ftp服务器的简单实现（二）——客户端

客户端：

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdlib.h>

#define TRUE 1
#define dataLen 1024
char user_cmd[10], cmd_arg[20];
char buf[dataLen];

void cmd_pwd(int sock, int sockmsg);
void cmd_dir(int sock, int sockmsg);
void cmd_cd(int sock, int sockmsg, char *dirName);
void cmd_cdback(int sock, int sockmsg);
void cmd_help(int sock, int sockmsg);
void cmd_get(int sock, int sockmsg, char *fileName);
void cmd_put(int sock, int sockmsg, char *fileName);
void cmd_quit(int sock, int sockmsg);

int main(int argc, char *argv[])
{
	int cmd_len, arg_len;
	int sock, sockmsg;
	struct sockaddr_in server, servermsg;
	struct hostent *hp;

	sock = socket(AF_INET, SOCK_STREAM, 0);
	sockmsg = socket(AF_INET, SOCK_STREAM, 0);
	
	if(sock < 0 || sockmsg < 0)
	{
		perror("opening stream socket");
		exit(1);
	}

	printf("argc is %d, argv[1] is %s
",argc, argv[1]);

	hp = gethostbyname(argv[1]);
	//hp = gethostbyname("localhost");
	if(hp == 0)
	{
		fprintf(stderr, "%s:unknown host
", argv[1]);
		exit(2);
	}

	server.sin_family = AF_INET;
	server.sin_port = htons(atoi(argv[2]));
	memcpy((char*)&server.sin_addr, (char*)hp->h_addr, hp->h_length);
	
	servermsg.sin_family = AF_INET;
	servermsg.sin_port = htons(atoi(argv[2]) +1);
	memcpy((char*)&servermsg.sin_addr, (char*)hp->h_addr, hp->h_length);

	if(connect(sock, (struct sockaddr *)&server, sizeof(server)) < 0 ||
		connect(sockmsg, (struct sockaddr *)&servermsg, sizeof(servermsg)) < 0)
	{
		perror("connecting stream socket");
		exit(1);
	}

	while(TRUE)
	{
		memset(user_cmd, 0, 10);
		memset(cmd_arg, 0, 20);

		//First get the input character by user
		printf("command: ");
		scanf("%s", user_cmd);

		//Then get the command charater and argument
		if(strcmp(user_cmd, "quit") == 0)
		{
			cmd_quit(sock, sockmsg);
			close(sockmsg);
			close(sock);
			printf("connection closed

");
			exit(0);
		}
		else if(strcmp(user_cmd, "?") == 0)
		{
			cmd_help(sock, sockmsg);
		}
		else if(strcmp(user_cmd, "pwd") == 0)
		{
			printf("stcmp pwd --------------->>>
");
			cmd_pwd(sock, sockmsg);
		}
		else if(strcmp(user_cmd, "dir") == 0)
		{
			cmd_dir(sock, sockmsg);
		}
		else if(strcmp(user_cmd, "cd") == 0)
		{
			scanf("%s", cmd_arg);
			cmd_cd(sock, sockmsg, cmd_arg);
		}
		else if(strcmp(user_cmd, "cd..") == 0)
		{
			cmd_cdback(sock, sockmsg);
		}
		else if(strcmp(user_cmd, "get") == 0 )
		{
			scanf("%s", cmd_arg);
			cmd_get(sock, sockmsg, cmd_arg);
		}
		else if(strcmp(user_cmd, "put") == 0)
		{
			scanf("%s", cmd_arg);
			cmd_put(sock, sockmsg, cmd_arg);
		}
		else
		{
			printf("bad command!
");
		}
	}
}


void cmd_pwd(int sock, int sockmsg)
{
	//int numRead
	char dirName[30];
	write(sockmsg, user_cmd, sizeof(user_cmd));
	read(sock, dirName, 30);
	printf("dirName is ------->>  %s
", dirName);
}

//command dir
void cmd_dir(int sock, int sockmsg)
{
	int i, fileNum = 0;
	char fileInfo[50];

	write(sockmsg, user_cmd, sizeof(user_cmd));
	read(sock, &fileNum, sizeof(int));

	printf("---------------------------------------
");
	printf("file number : %d
", fileNum);
	if(fileNum > 0)
	{
		for(i=0; i<fileNum; i++)
		{
			memset(fileInfo, 0, sizeof(fileInfo));
			read(sock, fileInfo, sizeof(fileInfo));
			printf("%s
", fileInfo);
		}
		printf("-----------------------------------
");
	}
	else if(fileNum == 0)
	{
		printf("directory of server point is empty.
");
		return;
	}
	else
	{
		printf("error in command 'dir'
");
		return;
	}
} 

void cmd_cd(int sock, int sockmsg, char *dirName)
{
	char currentDirPath[200];
	write(sockmsg, user_cmd, sizeof(user_cmd));
	write(sockmsg, cmd_arg, sizeof(cmd_arg));
	printf("172 ----------->>
");
	read(sock, currentDirPath, sizeof(currentDirPath));
	printf("174 ------------>>
");
	printf("now is directory : %s
", currentDirPath);
}

//command cd..
void cmd_cdback(int sock, int sockmsg)
{
	write(sockmsg, user_cmd, sizeof(user_cmd));
}

//command quit
void cmd_quit(int sock, int sockmsg)
{
	write(sockmsg, user_cmd, sizeof(user_cmd));
}

//command help
void cmd_help(int sock, int sockmsg)
{
	char help[300];
	write(sockmsg, user_cmd, sizeof(user_cmd));
	read(sock, help, 300);

	printf("%s
", help);
}

//command get
void cmd_get(int sock, int sockmsg, char *fileName)
{
	int fd;
	long fileSize;
	char localFilePath[200];

	write(sockmsg, user_cmd, sizeof(user_cmd));
	write(sockmsg, cmd_arg, sizeof(cmd_arg));
	printf("%s
%s
", user_cmd, cmd_arg);

	memset(localFilePath, 0, sizeof(localFilePath));
	getcwd(localFilePath, sizeof(localFilePath));
	strcat(localFilePath, "/");
	strcat(localFilePath, fileName);

	fd = open(localFilePath, O_RDWR|O_CREAT, S_IREAD|S_IWRITE);
	if(fd!=-1)
	{
		memset(buf, 0, dataLen);
		read(sock, &fileSize, sizeof(long));
		while(fileSize > dataLen)
		{
			read(sock, buf, dataLen);
			write(fd, buf, dataLen);
			fileSize = fileSize - dataLen;
		}

		read(sock, buf, fileSize);
		write(fd, buf, fileSize);
		close(fd);
		printf("download completed
");
	}
	else
	{
		printf("open file %s failed
", localFilePath);
	}
}

//command put
void cmd_put(int sock, int sockmsg, char *fileName)
{
	write(sockmsg, user_cmd, sizeof(user_cmd));
	write(sockmsg, cmd_arg, sizeof(cmd_arg));

	int fd;
	long fileSize;
	int numRead;
	char filePath[200];

	struct stat fileSta;
	
	memset(filePath, 0, sizeof(filePath));
	getcwd(filePath, sizeof(filePath));

	strcat(filePath, "/");
	strcat(filePath, fileName);

	fd = open(filePath, O_RDONLY, S_IREAD);
	if(fd != -1)
	{
		fstat(fd, &fileSta);
		fileSize = (long)fileSta.st_size;

		write(sock, &fileSize, sizeof(long));
		memset(buf, 0, dataLen);
		while(fileSize > dataLen)
		{
			read(fd, buf, dataLen);
			write(sock, buf, dataLen);
			fileSize = fileSize -dataLen;
		}

		read(fd, buf, fileSize);
		write(sock, buf, fileSize);
		close(fd);
		printf("upload completed
");
	}
	else
	{
		printf("open file %s failed
", filePath);
	}
}

 编译的话，用gcc -g -o client client.c

运行的话，需要注意，需要两个参数：

./client localhost 3499

一个是本地主机，一个是端口号

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdlib.h>

#define TRUE 1
#define dataLen 1024
char user_cmd[10], cmd_arg[20];
char buf[dataLen];

void cmd_pwd(int sock, int sockmsg);
void cmd_dir(int sock, int sockmsg);
void cmd_cd(int sock, int sockmsg, char *dirName);
void cmd_cdback(int sock, int sockmsg);
void cmd_help(int sock, int sockmsg);
void cmd_get(int sock, int sockmsg, char *fileName);
void cmd_put(int sock, int sockmsg, char *fileName);
void cmd_quit(int sock, int sockmsg);

int main(int argc, char *argv[])
{
    int cmd_len, arg_len;
    int sock, sockmsg;
    struct sockaddr_in server, servermsg;
    struct hostent *hp;

    sock = socket(AF_INET, SOCK_STREAM, 0);
    sockmsg = socket(AF_INET, SOCK_STREAM, 0);
    
    if(sock < 0 || sockmsg < 0)
    {
        perror("opening stream socket");
        exit(1);
    }

    printf("argc is %d, argv[1] is %s ",argc, argv[1]);

    hp = gethostbyname(argv[1]);
    //hp = gethostbyname("localhost");
    if(hp == 0)
    {
        fprintf(stderr, "%s:unknown host ", argv[1]);
        exit(2);
    }

    server.sin_family = AF_INET;
    server.sin_port = htons(atoi(argv[2]));
    memcpy((char*)&server.sin_addr, (char*)hp->h_addr, hp->h_length);
    
    servermsg.sin_family = AF_INET;
    servermsg.sin_port = htons(atoi(argv[2]) +1);
    memcpy((char*)&servermsg.sin_addr, (char*)hp->h_addr, hp->h_length);

    if(connect(sock, (struct sockaddr *)&server, sizeof(server)) < 0 ||
        connect(sockmsg, (struct sockaddr *)&servermsg, sizeof(servermsg)) < 0)
    {
        perror("connecting stream socket");
        exit(1);
    }

    while(TRUE)
    {
        memset(user_cmd, 0, 10);
        memset(cmd_arg, 0, 20);

        //First get the input character by user
        printf("command: ");
        scanf("%s", user_cmd);

        //Then get the command charater and argument
        if(strcmp(user_cmd, "quit") == 0)
        {
            cmd_quit(sock, sockmsg);
            close(sockmsg);
            close(sock);
            printf("connection closed ");
            exit(0);
        }
        else if(strcmp(user_cmd, "?") == 0)
        {
            cmd_help(sock, sockmsg);
        }
        else if(strcmp(user_cmd, "pwd") == 0)
        {
            printf("stcmp pwd --------------->>> ");
            cmd_pwd(sock, sockmsg);
        }
        else if(strcmp(user_cmd, "dir") == 0)
        {
            cmd_dir(sock, sockmsg);
        }
        else if(strcmp(user_cmd, "cd") == 0)
        {
            scanf("%s", cmd_arg);
            cmd_cd(sock, sockmsg, cmd_arg);
        }
        else if(strcmp(user_cmd, "cd..") == 0)
        {
            cmd_cdback(sock, sockmsg);
        }
        else if(strcmp(user_cmd, "get") == 0 )
        {
            scanf("%s", cmd_arg);
            cmd_get(sock, sockmsg, cmd_arg);
        }
        else if(strcmp(user_cmd, "put") == 0)
        {
            scanf("%s", cmd_arg);
            cmd_put(sock, sockmsg, cmd_arg);
        }
        else
        {
            printf("bad command! ");
        }
    }
}


void cmd_pwd(int sock, int sockmsg)
{
    //int numRead
    char dirName[30];
    write(sockmsg, user_cmd, sizeof(user_cmd));
    read(sock, dirName, 30);
    printf("dirName is ------->>  %s ", dirName);
}

//command dir
void cmd_dir(int sock, int sockmsg)
{
    int i, fileNum = 0;
    char fileInfo[50];

    write(sockmsg, user_cmd, sizeof(user_cmd));
    read(sock, &fileNum, sizeof(int));

    printf("--------------------------------------- ");
    printf("file number : %d ", fileNum);
    if(fileNum > 0)
    {
        for(i=0; i<fileNum; i++)
        {
            memset(fileInfo, 0, sizeof(fileInfo));
            read(sock, fileInfo, sizeof(fileInfo));
            printf("%s ", fileInfo);
        }
        printf("----------------------------------- ");
    }
    else if(fileNum == 0)
    {
        printf("directory of server point is empty. ");
        return;
    }
    else
    {
        printf("error in command 'dir' ");
        return;
    }
}

void cmd_cd(int sock, int sockmsg, char *dirName)
{
    char currentDirPath[200];
    write(sockmsg, user_cmd, sizeof(user_cmd));
    write(sockmsg, cmd_arg, sizeof(cmd_arg));
    printf("172 ----------->> ");
    read(sock, currentDirPath, sizeof(currentDirPath));
    printf("174 ------------>> ");
    printf("now is directory : %s ", currentDirPath);
}

//command cd..
void cmd_cdback(int sock, int sockmsg)
{
    write(sockmsg, user_cmd, sizeof(user_cmd));
}

//command quit
void cmd_quit(int sock, int sockmsg)
{
    write(sockmsg, user_cmd, sizeof(user_cmd));
}

//command help
void cmd_help(int sock, int sockmsg)
{
    char help[300];
    write(sockmsg, user_cmd, sizeof(user_cmd));
    read(sock, help, 300);

    printf("%s ", help);
}

//command get
void cmd_get(int sock, int sockmsg, char *fileName)
{
    int fd;
    long fileSize;
    char localFilePath[200];

    write(sockmsg, user_cmd, sizeof(user_cmd));
    write(sockmsg, cmd_arg, sizeof(cmd_arg));
    printf("%s %s ", user_cmd, cmd_arg);

    memset(localFilePath, 0, sizeof(localFilePath));
    getcwd(localFilePath, sizeof(localFilePath));
    strcat(localFilePath, "/");
    strcat(localFilePath, fileName);

    fd = open(localFilePath, O_RDWR|O_CREAT, S_IREAD|S_IWRITE);
    if(fd!=-1)
    {
        memset(buf, 0, dataLen);
        read(sock, &fileSize, sizeof(long));
        while(fileSize > dataLen)
        {
            read(sock, buf, dataLen);
            write(fd, buf, dataLen);
            fileSize = fileSize - dataLen;
        }

        read(sock, buf, fileSize);
        write(fd, buf, fileSize);
        close(fd);
        printf("download completed ");
    }
    else
    {
        printf("open file %s failed ", localFilePath);
    }
}

//command put
void cmd_put(int sock, int sockmsg, char *fileName)
{
    write(sockmsg, user_cmd, sizeof(user_cmd));
    write(sockmsg, cmd_arg, sizeof(cmd_arg));

    int fd;
    long fileSize;
    int numRead;
    char filePath[200];

    struct stat fileSta;
    
    memset(filePath, 0, sizeof(filePath));
    getcwd(filePath, sizeof(filePath));

    strcat(filePath, "/");
    strcat(filePath, fileName);

    fd = open(filePath, O_RDONLY, S_IREAD);
    if(fd != -1)
    {
        fstat(fd, &fileSta);
        fileSize = (long)fileSta.st_size;

        write(sock, &fileSize, sizeof(long));
        memset(buf, 0, dataLen);
        while(fileSize > dataLen)
        {
            read(fd, buf, dataLen);
            write(sock, buf, dataLen);
            fileSize = fileSize -dataLen;
        }

        read(fd, buf, fileSize);
        write(sock, buf, fileSize);
        close(fd);
        printf("upload completed ");
    }
    else
    {
        printf("open file %s failed ", filePath);
    }
}