摘自织梦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程序设计有所帮助。