总体需求：
编写tcp文件服务器和客户端。客户端可以上传和下载文件。
================================================
分解需求
客户端功能描述：
1)要求支持以下命令：
help: 显示客户端所有命令和说明, 在本地实现即可，help的内容不需要从服务器传回。
list: 显示服务器端可下载文件列表，列表内容需要从服务器端传回。
get : 根据下载指定文件，只包含文件名，如果出现"/"等字符任务是路径，不予支持；下载后的文件存放在当前工作路径下即可。
put : 上传文件 必须为客户端本机的合法路径，客户端搜索到文件后推送给服务器
quit: 退出客户端
2)客户端启动后可以反复输入命令，除非用户输入quit才会退出。
3) 每次命令(list/get/put)建立一个连接，命令执行完毕后关闭该连接。
服务器端功能：
1)文件服务器不要求支持并发，同时只支持一个连接，即一个客户端发起的一次命令。一次命令执行完毕后关闭连接并继续等待下一次连接请求。
2)文件服务器启动后一直执行，除非被人为强制关闭。
3)文件服务器端需要设定一个目录用于存放所有的文件，该目录路径不支持可配置，且该目录不要求再包含子目录。称其为"文件存放目录"。
4)对list服务，服务器端从"文件存放目录"下列举出所有的文件名称并发送给客户端。
5)对get服务，服务器根据用户指定的文件名缺省从"文件存放目录"搜索该文件并推送文件到客户端，推送不会删除原服务器上的文件。
6)对put服务，服务器将用户推送的文件存储到"文件存放目录"，如果存在同名的文件则拒绝。
7)若执行命令和传输过程中发生错误，关闭当前连接并进入等待下一个连接。
=================================================
提示：
请在编码前仔细设计一个简单的应用层协议规定客户端和服务器端之间命令传输的请求和应答流程和格式。
二。参考代码：
1.服务器端参考代码
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#defineN128
#definePORT_NUM8888
typedefstructsockaddrSA;
voidProcessList(intconnfd)
{
charbuf[N];
DIR*mydir;
structdirent*myitem;
mydir=opendir(".");
while((myitem=readdir(mydir))!=NULL){
if((strcmp(myitem->d_name,".")==0)||(strcmp(myitem->d_name,"..")==0))
continue;
strcpy(buf,myitem->d_name);
send(connfd,buf,N,0);
}
close(connfd);
return;
}
voidProcessGet(intconnfd,charbuf[])
{
intfd,nbyte;
if((fd=open(buf+1,O_RDONLY))
fprintf(stderr,"failtoopen%s:%s\n",buf+1,strerror(errno));
buf[0]='N';
send(connfd,buf,N,0);
return;
}
buf[0]='Y';
send(connfd,buf,N,0);
while((nbyte=read(fd,buf,N))>0){
send(connfd,buf,nbyte,0);
}
close(connfd);
return;
}
voidProcessPut(intconnfd,charbuf[])
{
intfd,nbyte;
if((fd=open(buf+1,O_WRONLY|O_CREAT|O_TRUNC,0666))
printf("failtocreate%sonserver\n",buf+1);
return;
}
while((nbyte=recv(connfd,buf,N,0))>0){
write(fd,buf,nbyte);
}
close(fd);
return;
}
intmain(intargc,char*argv[])
{
intlistenfd,connfd;
intoptval=1;
charbuf[N];
structsockaddr_inserver_addr;
if((listenfd=socket(AF_INET,SOCK_STREAM,0))
fprintf(stderr,"failtosocket:%s\n",strerror(errno));
exit(-1);
}
#ifdef_DEBUG_
printf("socketis%d\n",listenfd);
#endif
memset(&server_addr,0,sizeof(server_addr));
server_addr.sin_family=AF_INET;
server_addr.sin_port=htons(PORT_NUM);
server_addr.sin_addr.s_addr=htonl(INADDR_ANY);
setsockopt(listenfd,SOL_SOCKET,SO_REUSEADDR,&optval,sizeof(optval));
if(bind(listenfd,(SA*)(&server_addr),sizeof(server_addr))
perror("failtobind");
exit(-1);
}
listen(listenfd,5);
while(1){
if((connfd=accept(listenfd,NULL,NULL))
perror("failtoaccept");
break;
}
recv(connfd,buf,N,0);
switch(buf[0]){
case'L':ProcessList(connfd);
break;
case'G':ProcessGet(connfd,buf);
break;
case'P':ProcessPut(connfd,buf);
break;
default:printf("Input");
}
close(connfd);
}
return0;
}
2.客户端参考代码：
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#defineN128
#definePORT_NUM8888
typedefstructsockaddrSA;
voidPrintHelp()
{
printf("help:displayhelpinfo\n");
printf("list:getfilelistofserver\n");
printf("get:get\n");
printf("put:put\n");
printf("quit:quittheclient\n");
return;
}
voidProcessList(structsockaddr_inserver_addr)
{
intsockfd,nbyte;
charbuf[N];
if((sockfd=socket(AF_INET,SOCK_STREAM,0))
printf("failtolist\n");
return;
}
if(connect(sockfd,(SA*)(&server_addr),sizeof(server_addr))
printf("failtoconnectserver\n");
gotoERROR_1;
}
strcpy(buf,"L");
send(sockfd,buf,N,0);
while((nbyte=recv(sockfd,buf,N,0))!=0){
printf("%s\n",buf);
}
ERROR_1:
close(sockfd);
return;
}
voidProcessGet(structsockaddr_inserver_addr,charcommand[])
{
intsockfd,nbyte,fd;
charbuf[N];
if((sockfd=socket(AF_INET,SOCK_STREAM,0))
printf("failtoget\n");
return;
}
if(connect(sockfd,(SA*)(&server_addr),sizeof(server_addr))
printf("failtoconnectserver\n");
gotoERROR_2;
}
sprintf(buf,"G%s",command+4);
send(sockfd,buf,N,0);
recv(sockfd,buf,N,0);
if(buf[0]=='N'){
printf("Nosuchfileonserver\n");
gotoERROR_2;
}
if((fd=open(command+4,O_WRONLY|O_CREAT|O_TRUNC,0666))
printf("failtocreatelocalfile%s\n",command+4);
gotoERROR_2;
}
while((nbyte=recv(sockfd,buf,N,0))>0){
write(fd,buf,nbyte);
}
close(fd);
ERROR_2:
close(sockfd);
return;
}
voidProcessPut(structsockaddr_inserver_addr,charcommand[])
{
intsockfd,fd,nbyte;
charbuf[N];
if((sockfd=socket(AF_INET,SOCK_STREAM,0))
printf("failtoget\n");
return;
}
if(connect(sockfd,(SA*)(&server_addr),sizeof(server_addr))
printf("failtoconnectserver\n");
gotoERROR_3;
}
if((fd=open(command+4,O_RDONLY))
printf("failtoopen%s\n",command+4);
gotoERROR_3;
}
sprintf(buf,"P%s",command+4);
send(sockfd,buf,N,0);
while((nbyte=read(fd,buf,N))>0){
send(sockfd,buf,nbyte,0);
}
close(fd);
ERROR_3:
close(sockfd);
return;
}
intmain(intargc,char*argv[])
{
intsockfd,fd,nbyte;
charcommand[32];
structsockaddr_inserver_addr;
if(argc
printf("Usage:%s\n",argv[0]);
exit(-1);
}
if((sockfd=socket(AF_INET,SOCK_STREAM,0))
fprintf(stderr,"failtosocket:%s\n",strerror(errno));
exit(-1);
}
#ifdef_DEBUG_
printf("socketis%d\n",sockfd);
#endif
memset(&server_addr,0,sizeof(server_addr));
server_addr.sin_family=AF_INET;
server_addr.sin_port=htons(atoi(argv[2]));
server_addr.sin_addr.s_addr=inet_addr(argv[1]);
//server_addr.sin_addr.s_addr=htonl(INADDR_ANY);
while(1){
printf("");
fgets(command,32,stdin);
command[strlen(command)-1]='\0';
if(strcmp(command,"help")==0){
PrintHelp();
}
elseif(strcmp(command,"list")==0){
ProcessList(server_addr);
}
elseif(strncmp(command,"get",3)==0){
ProcessGet(server_addr,command);
}
elseif(strncmp(command,"put",3)==0){
ProcessPut(server_addr,command);
}
elseif(strcmp(command,"quit")==0){
printf("Bye\n");
break;
}
else{
printf("Wrongcommand,'help'forcommandlist.\n");
}
}
return0;
}
3.验证结果(ubuntu14.04)
