首页 / 网页编程 / PHP / 摘自织梦CMS的HTTP文件下载类

<?php if（！defined（"DEDEINC"）） exit（"Request Error！"）;/** * 织梦HTTP下载类 * * @version$Id: dedehttpdown.class.php 1 11:42 2010年7月6日Z tianya $ * @packageDedeCMS.Libraries * @copyrightCopyright （c） 2007 - 2010, DesDev, Inc. * @licensehttp://help.dedecms.com/usersguide/license.html * @link http://www.dedecms.com */@set_time_limit（0）;class DedeHttpDown{ 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; /*** 初始化系统** @access public* @paramstring $url 需要下载的地址* @return string*/ function PrivateInit（$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）;} } /*** 重设各参数** @access public* @return void*/ function ResetAny（） {$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 = ""; } /*** 打开指定网址** @access public* @paramstring $url 地址* @paramstring $requestType 请求类型* @return string*/ function OpenUrl（$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重定向网址** @access public* @paramstring $url 地址* @return string*/ function JumpOpenUrl（$url） {$this->ResetAny（）;$this->JumpCount++;$this->m_httphead = Array（） ;$this->m_html = "";$this->Close（）;//初始化系统$this->PrivateInit（$url）;$this->PrivateStartSession（"GET"）; } /*** 获得某操作错误的原因** @access public* @return void*/ function printError（） {echo "错误信息：".$this->m_error;echo "<br/>具体返回头：<br/>";foreach（$this->m_httphead as $k=>$v）{ echo "$k => $v <br/>
"; } } /*** 判别用Get方法发送的头的应答结果是否正确** @access public* @return bool*/ function IsGetOK（） {if（ preg_match（"/^2/",$this->GetHead（"http-state"）） ）{ return TRUE;}else{ $this->m_error .= $this->GetHead（"http-state"）." - ".$this->GetHead（"http-describe"）."<br/>"; return FALSE;} } /*** 看看返回的网页是否是text类型** @access public* @return bool*/ function IsText（） {if（ preg_match（"/^2/",$this->GetHead（"http-state"）） && preg_match（"/text|xml/i",$this->GetHead（"content-type"）） ）{ return TRUE;}else{ $this->m_error .= "内容为非文本类型或网址重定向<br/>"; return FALSE;} } /*** 判断返回的网页是否是特定的类型** @access public* @paramstring $ctype 内容类型* @return string*/ function IsContentType（$ctype） {if（preg_match（"/^2/",$this->GetHead（"http-state"））&& $this->GetHead（"content-type"）==strtolower（$ctype））{ return TRUE; }else{ $this->m_error .= "类型不对 ".$this->GetHead（"content-type"）."<br/>"; return FALSE;} } /*** 用Http协议下载文件** @access public* @paramstring $savefilename 保存文件名称* @return string*/ function SaveToBin（$savefilename） {if（！$this->IsGetOK（））{ return FALSE;}if（@feof（$this->m_fp））{ $this->m_error = "连接已经关闭！"; return FALSE;}$fp = fopen（$savefilename,"w"）;while（！feof（$this->m_fp））{ fwrite（$fp, fread（$this->m_fp, 1024））;}fclose（$this->m_fp）;fclose（$fp）;return TRUE; } /*** 保存网页内容为Text文件** @access public* @paramstring $savefilename 保存文件名称* @return string*/ function SaveToText（$savefilename） {if（$this->IsText（））{ $this->SaveBinFile（$savefilename）;}else{ return "";} } /*** 用Http协议获得一个网页的内容** @access public* @return string*/ function GetHtml（） {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会话** @access public* @paramstring $requestType 请求类型* @return string*/ function PrivateStartSession（$requestType="GET"） {if（！$this->PrivateOpenHost（））{ $this->m_error .= "打开远程主机出错！"; return FALSE;}$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
";}else{ $headString .= "POST ".$ps[0]." $httpv
";}$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; MSIE 6.0; Windows NT 5.2）";}if（！isset（$this->m_puthead["Refer"]））{ $this->m_puthead["Refer"] = "http://".$this->m_puthead["Host"];}foreach（$this->m_puthead as $k=>$v）{ $k = trim（$k）; $v = trim（$v）; if（$k！=""&&$v！=""） {$headString .= "$k: $v
"; }}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
"）; fputs（$this->m_fp,"Content-Length: $plen
"）;}//发送固定的结束请求头//HTTP1.1协议必须指定文档结束后关闭链接,否则读取文档时无法使用feof判断结束if（$httpv=="HTTP/1.1"）{ fputs（$this->m_fp,"Connection: Close

"）;}else{ fputs（$this->m_fp,"
"）;}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） {return FALSE; } $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头的值** @access public* @paramstring $headname 头文件名称* @return string*/ function GetHead（$headname） {$headname = strtolower（$headname）;return isset（$this->m_httphead[$headname]） ? $this->m_httphead[$headname] : ""; } /*** 设置Http头的值** @access public* @paramstring $skey 键* @paramstring $svalue 值* @return string*/ function SetHead（$skey,$svalue） {$this->m_puthead[$skey] = $svalue; } /*** 打开连接** @access public* @return bool*/ function PrivateOpenHost（） {if（$this->m_host==""）{ return FALSE;}$errno = "";$errstr = "";$this->m_fp = @fsockopen（$this->m_host, $this->m_port, $errno, $errstr,10）;if（！$this->m_fp）{ $this->m_error = $errstr; return FALSE;}else{ return TRUE;} } /*** 关闭连接** @access public* @return void*/ function Close（） {@fclose（$this->m_fp）; } /*** 补全相对网址** @access public* @paramstring $surl 需要不全的地址* @return string*/ function FillUrl（$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;}else if（$surl[0]=="."）{ if（strlen（$surl）<=1） {return ""; } else if（$surl[1]=="/"） {$okurl = "http://".$this->BaseUrlPath."/".substr（$surl,2,strlen（$surl）-2）; } else {$urls = explode（"/",$surl）;foreach（$urls as $u）{ if（$u==".."） {$pathStep++; } else if（$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; } else if（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; }}//End Class