linuxbird
3.ok，在初步了解完这些系统调用后，我们就可以开始干活了。
A.开始定义头文件了。
#ifndef __ANT_H
#define __ANT_H
//定义包含库
#include
#include
#include
#include
#include
#include
#include
#include
#include
//定义蚂蚁的最大数目
#define MAXANTNUM 6
//定义缓存大小
#define BUFSIZE 1500
//从传进来的长字符串分别拣开文件名、域名、路径、端口等
#define FILENAME 1
#define SITENAME 2
#define PATHNAME 3
#define PORTNAME 4
typedef char URL[256];
//定义蚂蚁的数据结构
struct Ant{
int s;
// URL mission;
int position;
int amount;
char haversack[BUFSIZE];
int ready;
};
//定义任务的数据结构
struct Mission{
char host[100];
u_short port;
URL url;
};
//是否用代理 0表示不用，1表示用
extern int use_proxy;
//代理地址
extern char proxy_server[100];
//代理端口
extern u_short proxy_port;
//蚂蚁数目
extern int ant_num;
extern int bulk;
//下载进度
extern int progress;
//配置文件
extern char cfgfile[256];
//日志文件
extern char logfile[256];
extern struct Ant* ants[10];
extern struct Mission ms;
//此函数是读取配置文件的
extern void read_cfg(char* file);
//此函数是初始化环境的，给变量赋值
extern void init_env();
//分配下载任务
extern int assign_mission(FILE* log, struct Ant* ant);
//此函数是去掉字符串的空格
extern void eat_whitespace(char* str);
//
extern char* extract_from_url(URL url,int what);
//从日志文件中取得地址
extern char* get_url_from_log(FILE* log);
//返回下载文件的大小
extern int get_size_of_url(struct Mission* pms);
//go......下载文件
extern int go(struct Ant* ant, struct Mission* pms);
extern void enroll(struct Ant* ant, fd_set* rset);
extern void unenroll(struct Ant* ant,fd_set* rset);
extern int receive(struct Ant* ant, FILE* save);
//如果意外退出，保存当前状态
extern int save_status(struct Ant* ant, FILE* log);
#endif
B.在定义完头文件后，下面就可以写辅助函数了，主要是围绕着读取配置、创建连接、下载文件、保存文件、保存当前蚂蚁状态等。
下面就是funcs.c源码内容
#include ""ant.h""
//读取配置文件,并赋予相关变量的值
void
read_cfg(char* cfgfile)
{
FILE* f;
int i;
char line[256];
char* p=(char*)NULL;
//判断是否能打开该文件
if((f = fopen(cfgfile, ""r"")) == (FILE*)NULL){
printf(""can not open cfg file
"");
exit(1);
}
while(fgets(line, 256, f)!=(char*)NULL){
eat_whitespace(line);//去掉空行(此喂自定义函数)
if(line[0]==''#'')
continue;
for(i = 0; line[i]; i++)
line[i]=tolower(line[i]); //将所有字母转换成小写的
if((p = strstr(line,""use_proxy""))){ //查找代理(proxy)开关设置信息，有则给use_proxy=1,否则为0
if(strstr(line,""yes""))
use_proxy=1;
else
use_proxy=0;
}
else if((p = strstr(line,""proxy_server""))){ //查找代理服务器地址设置信息，将值赋给(proxy_server)
p=strstr(line,""="");
eat_whitespace(++p);
strcpy(proxy_server, p);
}
else if((p = strstr(line, ""proxy_port""))){ //查找代理端口设置信息，将值赋给(proxy_port)
p=strstr(line, ""="");
eat_whitespace(++p);
proxy_port=atoi(p);
}
}
}
void
//初始化环境参数，将值赋给各个变量
init_env( )
{
strcpy(cfgfile, ""./ant.conf"");
//取得配置文件名
read_cfg(cfgfile);
//取得配置文件中的变量
logfile[0] = cfgfile[0] = 0;
ant_num = MAXANTNUM;
bulk = 0; progress=0;
}
char*
//从记录文件里取得URL地址，断点续传的时候用，函数返回url
get_url_from_log(FILE* log)
{
static URL url;
URL line;
fseek(log, 0, SEEK_SET);
//从文件中读取字符串，从起始字符为""#""的行取url
while(fgets(line, sizeof(line)-1, log)!=(char*)NULL){
eat_whitespace(line);
if(line[0]==''#'')
continue;
strcpy(url, line);
return url;
}
memset(url,0,sizeof(url));
//内存中为之分配地址
return url;
}
int
//分配下载任务，失败返回0，从上面函数返回的字符中分析出将相关的值赋给数据结构ant
assign_mission(FILE* log, struct Ant* ant)
{
char line[256];
char* p;
while(fgets(line, 256, log)!=(char*)NULL){
eat_whitespace(line);
if((line[0]==''#'')||toupper(line[0]==''H'')||toupper(line[0]==''F''))
continue;
if(isdigit(line[0])){
ant->position=atoi(line);
p=index(line,'':'');
ant->amount=atoi(++p);
return 1;
}else
continue;
}
return 0;
}
void
//去掉字符流中的空行
eat_whitespace(char* str)
{
char* p;
int i;
p=str;
for(i=0; isspace(p[i]); i++ );
for( ;*p ;p++)
*p=p[i];
p=str;
for(i=strlen(str)-1;isspace(p[i]);i--)
p[i]=0;
}
char*
//从传进来的url字符串中，分析出文件名、域名、端口名、路径，根据不同的what返回不同的字串。
extract_from_url(URL url,int what)
{
static char res[100];
char* p;
char* pn;
res[0]=0;
memset(res,0,100);
switch (what){
case FILENAME://分析文件名、若没有用index.html替代（网络默认的首页，呵呵）
p=rindex(url,''/'');
if((*(p-1)==''/'')||(*(p+1)==0))
strcpy(res,""index.html"");
else
strcpy(res,++p);
break;
case PATHNAME:
break;
case SITENAME: //分析出域名，其中，对ftp,和http做出分类
if((p=index(url, ''@'')))
p++;
else{
if((p=strstr(url,""http://"")))
p+=7;
else if((p=strstr(url,""ftp://"")))
p+=6;
else
p=url;
}
if((pn=index(p,'':''))||(pn=index(p,''/''))){
strncpy(res,p,pn-p);
res[pn-p] = 0;
}
else
strcpy(res,p);
break;
case PORTNAME: //在字符""www.XXXX.com:8080/""之间取得端口号
if((p=rindex(url,'':''))&&(*(++p)!=''/'')){
if((pn=index(p,''/''))){
strncpy(res,p,pn-p);
res[pn-p]=0;
}
else
strcpy(res,p);
}
else{
strcpy(res,""80"");
}
break;
}
return res;
}
//
int
//根据传进来的Mission数据结构，建立socket链接，取得文件的大小。
get_size_of_url(struct Mission* pms)
{
int s;
struct sockaddr_in sin;
struct hostent* phe;
char cmd[256];
char msg_hdr[1000];
char* p;
//准备http中GET 方法的请求。
sprintf(cmd,""GET %s HTTP/1.0
"", pms->url);
//创建socket
if((s=socket(PF_INET,SOCK_STREAM,0))<0)
return -1;
//取得远程主机的IP地址，失败函数返回－1
if((phe = gethostbyname(pms->host)) == NULL)
return -1;
memset(&sin,0,sizeof(sin));
memcpy(&sin.sin_addr,phe->h_addr,sizeof(struct in_addr));
sin.sin_family=AF_INET;
sin.sin_port=htons(pms->port);
//跟远程机器建立连接，失败函数返回－1
if(connect(s,(struct sockaddr*)&sin,sizeof(sin))==-1)
return -1;
//发送GET请求
if(write(s,cmd,strlen(cmd))<0)
return 0;
//从链接描述符（连接管道）中读取传送过来的数据
if(read(s, msg_hdr, 300)<0)
return 0;
close(s);
printf(""%s"",msg_hdr);
//读到该文件的大小
if((p=strstr(msg_hdr,""Content-Length""))||(p=strstr(msg_hdr,""Content-length:"")))
p+=16;
else
return 0;
//返回大小
return atoi(p);
}
//根据传进来的 ant、mission数据结构，开始下载数据。
int
go(struct Ant* ant, struct Mission* pms)
{
struct sockaddr_in sin;
struct hostent* phe;
char cmd[256];
//准备请求的GET字符
if(ant_num==1)
sprintf(cmd,""GET %s HTTP/1.0
"", pms->url);
sprintf(cmd,""GET %s HTTP/1.0
Range: bytes=%d-%d
Cache-Control: no-cache
"", pms->url,ant->position, ant->position+ant->amount-1);
//为ant数据结构创建套接口
if((ant->s=socket(PF_INET,SOCK_STREAM,0))<0)
return 0;
//取得远程主机的IP地址，失败返回0
if((phe = gethostbyname(pms->host)) == NULL)
return 0;
memset(&sin,0,sizeof(sin));
memcpy(&sin.sin_addr,phe->h_addr,sizeof(struct in_addr));
sin.sin_family=AF_INET;
sin.sin_port=htons(pms->port);
//建立连接
if(connect(ant->s,(struct sockaddr*)&sin,sizeof(sin))==-1)
return 0;
//发送读取请求
if(write(ant->s,cmd,strlen(cmd))<0)
return 0;
printf(""Connect Host:%s , port:%d
"",pms->host,pms->port);
printf(""%s"",cmd);
return 1;
}
void
enroll(struct Ant* ant, fd_set* rset)
{
FD_SET(ant->s,rset);
}
void
unenroll(struct Ant* ant, fd_set* rset)
{
FD_CLR(ant->s,rset);
}
int
//把传进来的数据结构ant的数据存储起来
receive(struct Ant* ant, FILE* save)
{
int as;
int length;
char* p;
if((length = read(ant->s, ant->haversack, BUFSIZE)) >= 0){
p=ant->haversack;
if(!ant->ready){
ant->ready=1;
p=strstr(ant->haversack, ""
"");
p+=4;
length-=(p-ant->haversack);
}
}
else{
return 0;
}
if(0 == fseek(save, ant->position, SEEK_SET)){
if(0 <= fwrite(p, sizeof(char), length, save)){
ant->amount-=length;
ant->position+=length;
return length;
}
}
return 0;
}
int
//保存当前的蚂蚁数目，以及状态
save_status(struct Ant* ant, FILE* log)
{
return fprintf(log,""%d:%d
"",ant->position,ant->amount);
}