\u5b66\u4e60linux\u6709\u4e9b\u65f6\u65e5\u4e86\uff0c\u8fd9\u4e2a\u5c31\u662f\u6211\u7684\u4e00\u7b2c\u4e00\u771f\u6b63\u7684\u4f5c\u54c1\uff0c\u53d1\u8868\u4e00\u4e0b\u4f5c\u54c1\uff0c
\u5e0c\u671b\u5176\u4e2d\u7684\u4e00\u4e9b\u6280\u5de7\u5bf9\u670b\u53cb\u4eec\u6709\u6240\u5e2e\u52a9\uff0c\u4e5f\u5e0c\u671b\u8fbe\u4eba\u6307\u6b63\u4e00\u4e0b\u5176\u4e2d\u7684\u4e0d\u8db3\u3002<\/p>\n
\u4e3b\u8981\u5e94\u7528\u77e5\u8bc6:
linux\u7684\u7f51\u7edc\u901a\u4fe1
\u6587\u4ef6\u7684\u5c5e\u6027\u53ca\u64cd\u4f5c
\u591a\u8fdb\u7a0b\u7684\u5e94\u7528
\u8fdb\u7a0b\u7684\u56de\u6536
\u4fe1\u53f7\u7684\u5e94\u7528<\/p>\n
\u4e0b\u9762\u662f\u5ba2\u6237\u7aef
\u6587\u4ef6\u7684\u610f\u4e49\uff1a
command.c \u547d\u4ee4\u6a21\u5757 ,common.h \u516c\u5171\u58f0\u660e, input.c \u5206\u5272\u547d\u4ee4, main.c \u4e3b\u7a0b\u5e8f ,
Makefile make\u5de5\u5177\u7528\u7684,ssjio.c ssjio.h \u662f\u6211\u81ea\u5df1\u7684\u6a21\u5757<\/p>\n
main.c<\/p>\n
#include "common.h"<\/p>\n
int main(void)
{
char cline[COMMAND_LINE]="123";
struct command_line command;
int sock_fd;
struct sockaddr_in sin;<\/p>\nprintf("ssj-soft$: ");
fflush(stdout);<\/p>\nwhile(fgets(cline,COMMAND_LINE,stdin)!=NULL)
{ \/\/printf("%x,%x,%x,%xn",cline[0],cline[1],cline[2],cline[3]);fflush(stdout);
if(cline[0]==0xa){cline[1]=0xa;cline[2]='\u0000';}
if(split(&command,cline)==-1)
exit(1);<\/p>\nif(strcasecmp(command.name,"get")==0){
if(do_get(command.argv[1],command.argv[2],sock_fd)==-1)
exit(1);
}else if(strcasecmp(command.name,"put")==0){
if(do_put(command.argv[1],command.argv[2],sock_fd)==-1)
exit(1);
}else if(strcasecmp(command.name,"cd")==0){
if(do_cd(command.argv[1])==-1)
exit(1);
}else if(strcasecmp(command.name,"!cd")==0){
if(do_serv_cd(command.argv[1],sock_fd)==-1)
exit(1);
}else if(strcasecmp(command.name,"ls")==0){
if(do_ls(command.argv[1])==-1)
exit(1);
}else if(strcasecmp(command.name,"!ls")==0){
if(do_serv_ls(command.argv[1],sock_fd)==-1)
exit(1);
}else if(strcasecmp(command.name,"connect")==0){
if(do_connect(command.argv[1],&sin,&sock_fd)==-1)
exit(1);
}else if(strcasecmp(command.name,"RUN")==0){
if(do_serv_command(command.argv[1],sock_fd)==-1)
exit(1);
}else if(strcasecmp(command.name,"bye")==0){
if(do_bye(sock_fd)==-1)
exit(1);
break;
}else{
printf("wrong commandn");
printf("usage:connect <ip>n");
printf(" run <command>n");
printf(" cd <path>n");
printf(" !cd <path>n");
printf(" get <srcpathfile> <dstpath>n");
printf(" put <srcpathfile> <dstpath>n");
printf(" ls <path>n");
printf(" !ls <path>n");
printf(" byen");
}
printf("ssj-soft$: ");
fflush(stdout);
}
if(close(sock_fd)==-1)
{perror("Fail to close");exit(1);}<\/p>\nreturn 0;
}<\/p><\/blockquote>\ncommand.c<\/p>\n
#include "common.h"<\/p>\n
\/\/================connect==================
int do_connect(char *ip,struct sockaddr_in *sin,int *sock_fd)
{
int sfd;<\/p>\nbzero(sin,sizeof(struct sockaddr_in));
sin->sin_family=AF_INET;
if(inet_pton(AF_INET,ip,&sin->sin_addr)==-1)
{perror("wrong format of ip address");return -1;}<\/p>\nsin->sin_port=htons(PORT);
if((sfd=socket(AF_INET,SOCK_STREAM,0))==-1)
{perror("fail to create socket");return -1;}<\/p>\nif(connect(sfd,(struct sockaddr *)sin,sizeof(struct sockaddr_in))==-1)
{perror("Fail to connetc");return -1;}<\/p>\n*sock_fd=sfd;
return 0;
}<\/p>\n\/\/=====================get_file=======================
int do_get(const char *src,const char *dst,int sock_fd)
{
char *dst_file,*p,buf[MAX_LINE];
struct stat statbuf;
int n,fd,len,res=-1;<\/p>\nif(src==NULL || dst==NULL)
{printf("wrong commandn");return -1;}<\/p>\nif (src[strlen(src)-1]=='\/')
{printf("source file should be a regular filen");return -1;}<\/p>\nif((dst_file=(char *)malloc(strlen(dst)+strlen(src)))==NULL)
{perror("Fail to malloc");return -1;}<\/p>\nstrcpy(dst_file,dst);<\/p>\n
if(dst_file[strlen(dst_file)-1]!='\/')
strcat(dst_file,"\/");
p=rindex(src,'\/');
strcat(dst_file,p+1);<\/p>\nif((fd=open(dst_file,O_WRONLY|O_CREAT|O_TRUNC,0664))==-1)
{perror("Fail to open dst_file");goto end2;}<\/p>\nif(fstat(fd,&statbuf)==-1)
{perror("Fail to stat dst_file");goto end1;}<\/p>\nif(!S_ISREG(statbuf.st_mode))
{printf("dst_file should be a regular file");goto end1;}<\/p>\nsprintf(buf,"GET %s",src);<\/p>\n
if(my_write(sock_fd,buf,strlen(buf)+1)==-1)
goto end1;<\/p>\nif((n=my_read(sock_fd,buf,MAX_LINE))<=0)
goto end1;<\/p>\nif(buf[0]=='E')
{write(STDOUT_FILENO,buf,n);res=0;goto end1;}<\/p>\nlen=atoi(&buf[3]);
printf("len atoi:%dn",len);\/\/no
if(my_write(sock_fd,"RDY",4)==-1)
{perror("Fail to write RDY");goto end1;}
printf("while……n");fflush(stdout);
while(1){
if(len!=0)
n=my_read(sock_fd,buf,MAX_LINE);
printf("read up len:%d,n:%d",len,n);fflush(stdout);
if(n>0)
{write(fd,buf,n);printf("len:%d,n:%d",len,n);fflush(stdout);len-=n;n=0;}
else if(len==0)
{printf("OKn");break;}
else
goto end1;
}
res=0;<\/p>\nend1:
close(fd);
end2:
free(dst_file);
return res;
}<\/p>\n\/\/=====================!cd=======================
int do_serv_cd(char *path,int sock_fd)
{
char buf[MAX_LINE];
int n;
sprintf(buf,"CD %s",path);<\/p>\nif(my_write(sock_fd,buf,strlen(buf)+1)==-1)
{return -1;}<\/p>\nif((n=my_read(sock_fd,buf,MAX_LINE))<=0)
{return -1;}<\/p>\nif(buf[0]=='E')
write(STDOUT_FILENO,buf,n);<\/p>\nreturn 0;
}<\/p>\n\/\/==================!ls=======================
int do_serv_ls(char *path,int sock_fd)
{
char buf[MAX_LINE];
int len,n;<\/p>\nsprintf(buf,"LS %s",path);<\/p>\n
if(my_write(sock_fd,buf,strlen(buf)+1)==-1)
return -1;<\/p>\nif((n=my_read(sock_fd,buf,MAX_LINE))<=0)
return -1;<\/p>\nif(buf[0]=='E')
{write(STDOUT_FILENO,buf,n);return 0;}<\/p>\nlen=atoi(&buf[3]);<\/p>\n
if(my_write(sock_fd,"RDY",4)==-1)
return -1;<\/p>\nwhile(1)
{
if(len!=0)
n=my_read(sock_fd,buf,MAX_LINE);
if(n>0)
{write(STDOUT_FILENO,buf,n);len-=n;n=0;}
else if(len==0)
{printf("OKn");break;}
else
return -1;
}
return 0;
}<\/p>\n\/\/================bye======================
int do_bye(int sock_fd)
{
if(my_write(sock_fd,"BYE",4)==-1)
return -1;<\/p>\nreturn 0;
}<\/p>\n\/\/===============put=====================
int do_put(const char *src,const char *dst,int sock_fd)
{
char *dst_file,buf[MAX_LINE],*p;
struct stat statbuf;
int n,fd,res=-1;<\/p>\nif(src==NULL || dst==NULL)
{printf("wrong commandn");return -1;}<\/p>\nif(src[strlen(src)-1]=='\/')
{printf("source file should be a regular filen");return -1;}<\/p>\nif((dst_file=malloc(strlen(src)+strlen(dst)+2))==NULL)
{perror("Fail to malloc");return -1;}<\/p>\nstrcpy(dst_file,dst);
if(dst_file[strlen(dst_file)-1]!='\/')
strcat(dst_file,"\/");
p=rindex(src,'\/');<\/p>\nstrcat(dst_file,p+1);<\/p>\n
if((fd=open(src,O_RDONLY))==-1)
{perror("Fail to open src_file");goto end1;}<\/p>\nif(fstat(fd,&statbuf)==-1)
{perror("Fail to stat src_file");goto end2;}
if(!S_ISREG(statbuf.st_mode))
{fputs("src_file should be a regular filen",stderr);goto end2;}<\/p>\nsprintf(buf,"PUT %d %s",statbuf.st_size,dst_file);
if(my_write(sock_fd,buf,strlen(buf)+1)==-1)
{goto end2;}
if((n=my_read(sock_fd,buf,MAX_LINE))<=0)
goto end2;
if(buf[0]=='E')
{write(STDOUT_FILENO,buf,n);goto end2;}<\/p>\nwhile(1)
{
n=read(fd,buf,MAX_LINE);<\/p>\nif(n>0)
{if(my_write(sock_fd,buf,n)==-1)
goto end2;}
else if(n==0)
{printf("OKn");break;}
else
{perror("Fail to readn");goto end2;}
}
res=0;
end2:
close(fd);
end1:
free(dst_file);
return res;
}<\/p>\n\/\/===================cd=================
int do_cd(char *path)
{
if(chdir(path)==-1)
{perror("Fail to change directoryn");return -1;}<\/p>\nreturn 0;
}<\/p>\n\/\/===================ls=================
int do_ls(char *path)
{
char cmd[128],buf[NAME_LEN];
FILE *fp;<\/p>\nsprintf(cmd,"ls %s > temp.txt",path);
system(cmd);<\/p>\nfp=fopen("temp.txt","r");
if(fp==NULL)
{perror("Fail to ls");return -1;}<\/p>\nwhile(fgets(buf,NAME_LEN,fp)!=NULL)
printf("%s",buf);<\/p>\nfclose(fp);
return 0;
}<\/p>\n\/\/================command======================
int do_serv_command(char *path,int sock_fd)
{
char buf[MAX_LINE];
int len,n;<\/p>\nsprintf(buf,"RUN %s",path);<\/p>\n
if(my_write(sock_fd,buf,strlen(buf)+1)==-1)
return -1;<\/p>\nif((n=my_read(sock_fd,buf,MAX_LINE))<=0)
return -1;<\/p>\nif(buf[0]=='E')
{write(STDOUT_FILENO,buf,n);return 0;}<\/p>\nlen=atoi(&buf[3]);<\/p>\n
if(my_write(sock_fd,"RDY",4)==-1)
return -1;<\/p>\nwhile(1)
{
if(len!=0)
n=my_read(sock_fd,buf,MAX_LINE);
if(n>0)
{write(STDOUT_FILENO,buf,n);len-=n;n=0;}
else if(len==0)
{printf("OKn");break;}
else
return -1;
}
return 0;
}<\/p><\/blockquote>\ninput.c<\/p>\n
#include "common.h"
\/\/\u53bb\u9664\u547d\u4ee4\u4e4b\u524d\u7684\u7a7a\u683c\u7b49
void del_blank(int *pos,char cline[])
{
while(*(cline+*pos)!='\u0000'&&(*(cline+*pos)==' '||*(cline+*pos)=='t'))
{(*pos)++;}
}<\/p>\n\/\/\u5f97\u5230\u53c2\u6570\u90e8\u5206,\u5199\u5165\u7ed3\u6784\u4f53
void get_arg(char arg[],int *pos,char cline[])
{
int i=0;
while(*(cline+*pos)!='\u0000' && *(cline+*pos)!=' ' && *(cline+*pos)!='t')
{*(arg+i)=*(cline+*pos);i++;(*pos)++;}
*(arg+i)='\u0000';
}<\/p>\nint split(struct command_line *command,char cline[])
{
int i=0,pos=0;
cline[strlen(cline)-1]='\u0000'; \/\/fgets\u5f97\u5230\u7684\u5b57\u7b26\u4e32\u4e2d\u6709\u4e00\u4e2an\uff0c\u628a\u5b83\u53d8\u6210\u0000<\/p>\ndel_blank(&pos,cline);
i=0;
while(cline[pos]!='\u0000')
{
if((command->argv[i]=(char *)malloc(MAX_LENGTH))==NULL)
{perror("Fail malloc");exit(-1);}
get_arg(command->argv[i],&pos,cline);
i++;
del_blank(&pos,cline);
}<\/p>\nif(strncasecmp(command->argv[0],"RUN",3)==0)
{strcpy(command->argv[1],cline+4);
i=2;}
command->argv[i]=NULL;
command->name=command->argv[0];
return i;
}<\/p><\/blockquote>\n\u670d\u52a1\u5668\u7aef:<\/p>\n
main.c<\/p>\n
#include "common.h"
static void handler(int signo)
{
pid_t pid;
pid = waitpid(-1,NULL, WNOHANG);
printf("process id:%d closedn",pid);
}<\/p>\nint main(void)
{
signal(SIGCHLD,handler); \/\/\u5b50\u7a0b\u5e8f\u9000\u51fa\u7684\u4fe1\u53f7
\/\/signal(SIGINT,handler); \/\/CTRL-C\u7684\u4fe1\u53f7
\/\/signal(SIGTERM,handler); <\/p>\nstruct sockaddr_in sin;
struct sockaddr_in cin;
int lfd, cfd;
socklen_t len = sizeof(struct sockaddr_in);
char buf[MAX_LINE];
char str[ADDR_LEN];
int sock_opt = 1;
int n;
pid_t pid; <\/p>\nif(init(&sin, &lfd, sock_opt) == -1)
exit(1);<\/p>\nprintf("waiting connections …n");<\/p>\n
while(1){
if((cfd = accept(lfd, (struct sockaddr *)&cin, &len)) == -1){
perror("fail to accept");
exit(1);
}<\/p>\nif( (pid = fork()) < 0){
perror("fail to fork");
exit(1);
}else if(pid == 0){
close(lfd); <\/p>\nwhile(1){
if(my_read(cfd, buf, MAX_LINE) == -1)
exit(1);<\/p>\nif(strstr(buf, "GET") == buf)
{if(do_put(cfd, &buf[4]) == -1)
printf("error occours while puttingn");
else
printf("GET successful!n");
}
else if(strstr(buf, "PUT") == buf)
{if(do_get(cfd, &buf[4]) == -1)
printf("error occours while gettingn");}
else if(strstr(buf, "CD") == buf)
{if(do_cd(cfd, &buf[3]) == -1)
printf("error occours while changing directoryn");}
else if(strstr(buf, "LS") == buf)
{if(do_ls(cfd, &buf[3]) == -1)
printf("error occours while listingn");else printf("LS OKn");}
else if(strstr(buf, "RUN") == buf)
{if(do_command(cfd, &buf[4]) == -1)
printf("error occours while listingn");else printf("RUN OKn");}
else if(strstr(buf, "BYE") == buf)
break;
else{
printf("wrong commandn");
exit(1);
}
}<\/p>\nclose(cfd);
exit(0);
}else
close(cfd);
}
return 0;
}<\/p><\/blockquote>\ncommand.c<\/p>\n
#include "common.h"<\/p>\n
\/\/================socket,bind,listen======================
int init(struct sockaddr_in *sin,int *lfd,int sock_opt)
{
int tfd;
bzero(sin,sizeof(struct sockaddr_in));
sin->sin_family=AF_INET;
sin->sin_addr.s_addr=INADDR_ANY;
sin->sin_port=htons(PORT);<\/p>\nif((tfd=socket(AF_INET,SOCK_STREAM,0))==-1)
{perror("Fail to creat socket");return -1;}<\/p>\nsetsockopt(tfd,SOL_SOCKET,SO_REUSEADDR,&sock_opt,sizeof(int));<\/p>\n
if(bind(tfd,(struct sockaddr *)sin,sizeof(struct sockaddr_in))==-1)
{perror("Fail to bind");return -1;}<\/p>\nif(listen(tfd,20)==-1)
{perror("Fail to listen");return -1;}<\/p>\n*lfd=tfd;
return 0;
}<\/p>\n\/\/=====================put==========================
int do_put(int cfd,char *file)
{
struct stat statbuf;
int n,fd,res=-1;
char buf[MAX_LINE];<\/p>\nif((fd=open(file,O_RDONLY))==-1)
{my_write(cfd,"ERR open server filen",22);return res;}<\/p>\nif(fstat(fd,&statbuf)==-1)
{my_write(cfd,"ERR stat server filen",22);goto end;}
if(!S_ISREG(statbuf.st_mode))
{if(my_write(cfd,"ERR server path should be a regular filen",42)==-1)
goto end;
res=0;
goto end;
}<\/p>\nsprintf(buf,"OK %d",statbuf.st_size);
if(my_write(cfd,buf,strlen(buf)+1)==1)
goto end;
if(my_read(cfd,buf,MAX_LINE)<=0)
goto end;<\/p>\nwhile(1)
{
n=read(fd,buf,MAX_LINE);
printf("n:%d – ",n);
if(n>0)
{if((my_write(cfd,buf,n))==-1)
goto end;}
else if(n==0){
printf("OKn");break;}
else{
perror("Fail to read");goto end;}
}
res=0;
end:
close(fd);
retur<\/p>\nn res;
}<\/p>\n\/\/===================get==============================
int do_get(int cfd,char *file)
{
struct stat statbuf;
int n,fd,len,res=-1;
char buf[MAX_LINE],c[MAX_LINE],*save=file;
char *lenc=c;
printf("%sn",file);
while(*file!=' ')
{*lenc++ = *file++;*lenc='\u0000';}
len=atoi(c);
printf("lenc:%s,file:%s,len:%dn",c,file,len);
if((fd=open(file+1,O_WRONLY|O_CREAT|O_TRUNC,0644))==-1)
{
if(errno==EISDIR)
{
if(my_write(cfd,"ERR server has a dir with the same namen",41)==-1)
goto end;
res=0;
goto end;
}else{
my_write(cfd,"ERR open server filen",22);
goto end;
}
}<\/p>\nif(fstat(fd,&statbuf)==-1)
{my_write(cfd,"ERR stat server filen",22);goto end;}<\/p>\nif(!S_ISREG(statbuf.st_mode))
{
if(my_write(cfd,"ERR server path should be a regular filen",42)==-1)
goto end;
res=0;
goto end;
}<\/p>\nif(my_write(cfd,"OK",3)==-1)
goto end;<\/p>\nwhile(1)
{
if(len!=0)
n=my_read(cfd,buf,MAX_LINE);<\/p>\nif(n>0)
{write(fd,buf,n);len-=n;n=0;}
else if(len==0)
{printf("OKn");break;}
else
goto end;
}
res=0;
end:
close(fd);
return res;
}<\/p>\n\/\/======================cd===========================
int do_cd(int cfd,char *path)
{
if(chdir(path)==-1)
{perror("Fail to change directoryn");
my_write(cfd,"ERR cat't change directoryn",28);return -1;
}
my_write(cfd,"OKn",4);
return 0;
}<\/p>\n\/\/=====================ls===========================
int do_ls(int cfd,char *path)
{
char cmd[128],buf[NAME_LEN];
struct stat statbuf;
int n,fd,res=-1;<\/p>\nsprintf(cmd,"ls %s > temp.txt",path);
system(cmd);<\/p>\nif((fd=open("temp.txt",O_RDONLY))==-1)
{my_write(cfd,"ERR ls server filen",20);return res;}<\/p>\nif(fstat(fd,&statbuf)==-1)
{my_write(cfd,"ERR stat server filen",22);goto end;}<\/p>\nif(!S_ISREG(statbuf.st_mode))
{
if(my_write(cfd,"ERR server path should be a regular filen",42)==-1)
goto end;
res=0;
goto end;
}<\/p>\nsprintf(buf,"OK %d",statbuf.st_size);
if(my_write(cfd,buf,strlen(buf)+1)==-1)
goto end;<\/p>\nif(my_read(cfd,buf,MAX_LINE)<=0)
goto end;<\/p>\nwhile(1)
{
n=read(fd,buf,MAX_LINE);
printf("%d,%sn",n,buf);
if(n>0)
{ if(my_write(cfd,buf,n)==-1)
goto end;}
else if(n==0)
{printf("OKn");break;}
else
{perror("Fail to read");goto end;}<\/p>\n}<\/p>\n
res=0;
end:
close(fd);
return res;
}<\/p>\n\/\/==================command=========================
int do_command(int cfd,char *path)
{
char cmd[128],buf[MAX_LINE];
struct stat statbuf;
int n,fd,res=-1;<\/p>\nsprintf(cmd,"%s > temp.txt",path);
system(cmd);<\/p>\nif((fd=open("temp.txt",O_RDONLY))==-1)
{my_write(cfd,"ERR ls server filen",20);return res;}<\/p>\nif(fstat(fd,&statbuf)==-1)
{my_write(cfd,"ERR stat server filen",22);goto end;}<\/p>\nif(!S_ISREG(statbuf.st_mode))
{
if(my_write(cfd,"ERR server path should be a regular filen",42)==-1)
goto end;
res=0;
goto end;
}<\/p>\nsprintf(buf,"OK %d",statbuf.st_size);
if(my_write(cfd,buf,strlen(buf)+1)==-1)
goto end;<\/p>\nif(my_read(cfd,buf,MAX_LINE)<=0)
goto end;<\/p>\nwhile(1)
{
n=read(fd,buf,MAX_LINE);
printf("n:%d,buf:%sn",n,buf);fflush(stdout);
if(n>0)
{ if(my_write(cfd,buf,n)==-1)
goto end;n=0;}
else if(n==0)
{printf("OKn");break;}
else
{perror("Fail to read");goto end;}<\/p>\n}<\/p>\n
res=0;
end:
close(fd);
return res;
}<\/p><\/blockquote>\n\u4ee5\u4e0a\u662f\u4e3b\u8981\u6587\u4ef6\u7684\u5185\u5bb9\uff0c\u5176\u5b83\u6587\u4ef6\u8bf7\u4e0b\u8f7d\u538b\u7f29\u5305\u3002<\/p>\n