摘自织梦CMS的HTTP文件下载类
本文实例讲述了摘自织梦CMS的HTTP文件下载类。分享给大家供大家参考。具体如下：
<?phpif(!defined('DEDEINC'))exit("RequestError!");
/**
*织梦HTTP下载类
*
*@version$Id:dedehttpdown.class.php111:422010年7月6日Ztianya$
*@packageDedeCMS.Libraries
*@copyrightCopyright(c)2007-2010,DesDev,Inc.
*@licensehttp://help.dedecms.com/usersguide/license.html
*@linkhttp://www.dedecms.com
*/
@set_time_limit(0);
classDedeHttpDown
{
var$m_url='';
var$m_urlpath='';
var$m_scheme='http';
var$m_host='';
var$m_port='80';
var$m_user='';
var$m_pass='';
var$m_path='/';
var$m_query='';
var$m_fp='';
var$m_error='';
var$m_httphead='';
var$m_html='';
var$m_puthead='';
var$BaseUrlPath='';
var$HomeUrl='';
var$reTry=0;
var$JumpCount=0;
/**
*初始化系统
*
*@accesspublic
*@paramstring$url需要下载的地址
*@returnstring
*/
functionPrivateInit($url)
{
if($url==''){
return;
}
$urls='';
$urls=@parse_url($url);
$this->m_url=$url;
if(is_array($urls))
{
$this->m_host=$urls["host"];
if(!empty($urls["scheme"]))
{
$this->m_scheme=$urls["scheme"];
}
if(!empty($urls["user"]))
{
$this->m_user=$urls["user"];
}
if(!empty($urls["pass"]))
{
$this->m_pass=$urls["pass"];
}
if(!empty($urls["port"]))
{
$this->m_port=$urls["port"];
}
if(!empty($urls["path"]))
{
$this->m_path=$urls["path"];
}
$this->m_urlpath=$this->m_path;
if(!empty($urls["query"]))
{
$this->m_query=$urls["query"];
$this->m_urlpath.="?".$this->m_query;
}
$this->HomeUrl=$urls["host"];
$this->BaseUrlPath=$this->HomeUrl.$urls["path"];
$this->BaseUrlPath=preg_replace("/\/([^\/]*)\.(.*)$/","/",$this->BaseUrlPath);
$this->BaseUrlPath=preg_replace("/\/$/","",$this->BaseUrlPath);
}
}
/**
*重设各参数
*
*@accesspublic
*@returnvoid
*/
functionResetAny()
{
$this->m_url="";
$this->m_urlpath="";
$this->m_scheme="http";
$this->m_host="";
$this->m_port="80";
$this->m_user="";
$this->m_pass="";
$this->m_path="/";
$this->m_query="";
$this->m_error="";
}
/**
*打开指定网址
*
*@accesspublic
*@paramstring$url地址
*@paramstring$requestType请求类型
*@returnstring
*/
functionOpenUrl($url,$requestType="GET")
{
$this->ResetAny();
$this->JumpCount=0;
$this->m_httphead=Array();
$this->m_html='';
$this->reTry=0;
$this->Close();
//初始化系统
$this->PrivateInit($url);
$this->PrivateStartSession($requestType);
}
/**
*转到303重定向网址
*
*@accesspublic
*@paramstring$url地址
*@returnstring
*/
functionJumpOpenUrl($url)
{
$this->ResetAny();
$this->JumpCount++;
$this->m_httphead=Array();
$this->m_html="";
$this->Close();
//初始化系统
$this->PrivateInit($url);
$this->PrivateStartSession('GET');
}
/**
*获得某操作错误的原因
*
*@accesspublic
*@returnvoid
*/
functionprintError()
{
echo"错误信息：".$this->m_error;
echo"<br/>具体返回头：<br/>";
foreach($this->m_httpheadas$k=>$v){echo"$k=>$v<br/>\r\n";}
}
/**
*判别用Get方法发送的头的应答结果是否正确
*
*@accesspublic
*@returnbool
*/
functionIsGetOK()
{
if(preg_match("/^2/",$this->GetHead("http-state")))
{
returnTRUE;
}
else
{
$this->m_error.=$this->GetHead("http-state")."-".$this->GetHead("http-describe")."<br/>";
returnFALSE;
}
}
/**
*看看返回的网页是否是text类型
*
*@accesspublic
*@returnbool
*/
functionIsText()
{
if(preg_match("/^2/",$this->GetHead("http-state"))&&preg_match("/text|xml/i",$this->GetHead("content-type")))
{
returnTRUE;
}
else
{
$this->m_error.="内容为非文本类型或网址重定向<br/>";
returnFALSE;
}
}
/**
*判断返回的网页是否是特定的类型
*
*@accesspublic
*@paramstring$ctype内容类型
*@returnstring
*/
functionIsContentType($ctype)
{
if(preg_match("/^2/",$this->GetHead("http-state"))
&&$this->GetHead("content-type")==strtolower($ctype))
{returnTRUE;}
else
{
$this->m_error.="类型不对".$this->GetHead("content-type")."<br/>";
returnFALSE;
}
}
/**
*用Http协议下载文件
*
*@accesspublic
*@paramstring$savefilename保存文件名称
*@returnstring
*/
functionSaveToBin($savefilename)
{
if(!$this->IsGetOK())
{
returnFALSE;
}
if(@feof($this->m_fp))
{
$this->m_error="连接已经关闭！";returnFALSE;
}
$fp=fopen($savefilename,"w");
while(!feof($this->m_fp))
{
fwrite($fp,fread($this->m_fp,1024));
}
fclose($this->m_fp);
fclose($fp);
returnTRUE;
}
/**
*保存网页内容为Text文件
*
*@accesspublic
*@paramstring$savefilename保存文件名称
*@returnstring
*/
functionSaveToText($savefilename)
{
if($this->IsText())
{
$this->SaveBinFile($savefilename);
}
else
{
return"";
}
}
/**
*用Http协议获得一个网页的内容
*
*@accesspublic
*@returnstring
*/
functionGetHtml()
{
if(!$this->IsText())
{
return'';
}
if($this->m_html!='')
{
return$this->m_html;
}
if(!$this->m_fp||@feof($this->m_fp))
{
return'';
}
while(!feof($this->m_fp))
{
$this->m_html.=fgets($this->m_fp,256);
}
@fclose($this->m_fp);
return$this->m_html;
}
/**
*开始HTTP会话
*
*@accesspublic
*@paramstring$requestType请求类型
*@returnstring
*/
functionPrivateStartSession($requestType="GET")
{
if(!$this->PrivateOpenHost())
{
$this->m_error.="打开远程主机出错!";
returnFALSE;
}
$this->reTry++;
if($this->GetHead("http-edition")=="HTTP/1.1")
{
$httpv="HTTP/1.1";
}
else
{
$httpv="HTTP/1.0";
}
$ps=explode('?',$this->m_urlpath);
$headString='';
//发送固定的起始请求头GET、Host信息
if($requestType=="GET")
{
$headString.="GET".$this->m_urlpath."$httpv\r\n";
}
else
{
$headString.="POST".$ps[0]."$httpv\r\n";
}
$this->m_puthead["Host"]=$this->m_host;
//发送用户自定义的请求头
if(!isset($this->m_puthead["Accept"]))
{
$this->m_puthead["Accept"]="*/*";
}
if(!isset($this->m_puthead["User-Agent"]))
{
$this->m_puthead["User-Agent"]="Mozilla/4.0(compatible;MSIE6.0;WindowsNT5.2)";
}
if(!isset($this->m_puthead["Refer"]))
{
$this->m_puthead["Refer"]="http://".$this->m_puthead["Host"];
}
foreach($this->m_putheadas$k=>$v)
{
$k=trim($k);
$v=trim($v);
if($k!=""&&$v!="")
{
$headString.="$k:$v\r\n";
}
}
fputs($this->m_fp,$headString);
if($requestType=="POST")
{
$postdata="";
if(count($ps)>1)
{
for($i=1;$i<count($ps);$i++)
{
$postdata.=$ps[$i];
}
}
else
{
$postdata="OK";
}
$plen=strlen($postdata);
fputs($this->m_fp,"Content-Type:application/x-www-form-urlencoded\r\n");
fputs($this->m_fp,"Content-Length:$plen\r\n");
}
//发送固定的结束请求头
//HTTP1.1协议必须指定文档结束后关闭链接,否则读取文档时无法使用feof判断结束
if($httpv=="HTTP/1.1")
{
fputs($this->m_fp,"Connection:Close\r\n\r\n");
}
else
{
fputs($this->m_fp,"\r\n");
}
if($requestType=="POST")
{
fputs($this->m_fp,$postdata);
}
//获取应答头状态信息
$httpstas=explode("",fgets($this->m_fp,256));
$this->m_httphead["http-edition"]=trim($httpstas[0]);
$this->m_httphead["http-state"]=trim($httpstas[1]);
$this->m_httphead["http-describe"]="";
for($i=2;$i<count($httpstas);$i++)
{
$this->m_httphead["http-describe"].="".trim($httpstas[$i]);
}
//获取详细应答头
while(!feof($this->m_fp))
{
$line=trim(fgets($this->m_fp,256));
if($line=="")
{
break;
}
$hkey="";
$hvalue="";
$v=0;
for($i=0;$i<strlen($line);$i++)
{
if($v==1)
{
$hvalue.=$line[$i];
}
if($line[$i]==":")
{
$v=1;
}
if($v==0)
{
$hkey.=$line[$i];
}
}
$hkey=trim($hkey);
if($hkey!="")
{
$this->m_httphead[strtolower($hkey)]=trim($hvalue);
}
}
//如果连接被不正常关闭，重试
if(feof($this->m_fp))
{
if($this->reTry>10)
{
returnFALSE;
}
$this->PrivateStartSession($requestType);
}
//判断是否是3xx开头的应答
if(preg_match("/^3/",$this->m_httphead["http-state"]))
{
if($this->JumpCount>3)
{
return;
}
if(isset($this->m_httphead["location"]))
{
$newurl=$this->m_httphead["location"];
if(preg_match("/^http/i",$newurl))
{
$this->JumpOpenUrl($newurl);
}
else
{
$newurl=$this->FillUrl($newurl);
$this->JumpOpenUrl($newurl);
}
}
else
{
$this->m_error="无法识别的答复！";
}
}
}
/**
*获得一个Http头的值
*
*@accesspublic
*@paramstring$headname头文件名称
*@returnstring
*/
functionGetHead($headname)
{
$headname=strtolower($headname);
returnisset($this->m_httphead[$headname])?$this->m_httphead[$headname]:'';
}
/**
*设置Http头的值
*
*@accesspublic
*@paramstring$skey键
*@paramstring$svalue值
*@returnstring
*/
functionSetHead($skey,$svalue)
{
$this->m_puthead[$skey]=$svalue;
}
/**
*打开连接
*
*@accesspublic
*@returnbool
*/
functionPrivateOpenHost()
{
if($this->m_host=="")
{
returnFALSE;
}
$errno="";
$errstr="";
$this->m_fp=@fsockopen($this->m_host,$this->m_port,$errno,$errstr,10);
if(!$this->m_fp)
{
$this->m_error=$errstr;
returnFALSE;
}
else
{
returnTRUE;
}
}
/**
*关闭连接
*
*@accesspublic
*@returnvoid
*/
functionClose()
{
@fclose($this->m_fp);
}
/**
*补全相对网址
*
*@accesspublic
*@paramstring$surl需要不全的地址
*@returnstring
*/
functionFillUrl($surl)
{
$i=0;
$dstr="";
$pstr="";
$okurl="";
$pathStep=0;
$surl=trim($surl);
if($surl=="")
{
return"";
}
$pos=strpos($surl,"#");
if($pos>0)
{
$surl=substr($surl,0,$pos);
}
if($surl[0]=="/")
{
$okurl="http://".$this->HomeUrl.$surl;
}
elseif($surl[0]==".")
{
if(strlen($surl)<=1)
{
return"";
}
elseif($surl[1]=="/")
{
$okurl="http://".$this->BaseUrlPath."/".substr($surl,2,strlen($surl)-2);
}
else
{
$urls=explode("/",$surl);
foreach($urlsas$u)
{
if($u=="..")
{
$pathStep++;
}
elseif($i<count($urls)-1)
{
$dstr.=$urls[$i]."/";
}
else
{
$dstr.=$urls[$i];
}
$i++;
}
$urls=explode("/",$this->BaseUrlPath);
if(count($urls)<=$pathStep)
{
return"";
}
else
{
$pstr="http://";
for($i=0;$i<count($urls)-$pathStep;$i++)
{
$pstr.=$urls[$i]."/";
}
$okurl=$pstr.$dstr;
}
}
}
else
{
if(strlen($surl)<7)
{
$okurl="http://".$this->BaseUrlPath."/".$surl;
}
elseif(strtolower(substr($surl,0,7))=="http://")
{
$okurl=$surl;
}
else
{
$okurl="http://".$this->BaseUrlPath."/".$surl;
}
}
$okurl=preg_replace("/^(http:\/\/)/i","",$okurl);
$okurl=preg_replace("/\/{1,}/","/",$okurl);
return"http://".$okurl;
}
}//EndClass
希望本文所述对大家的php程序设计有所帮助。