|
|
<?php
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Copyright (c) 2009 http://thinkphp.cn All rights reserved.
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Author: liu21st <liu21st@gmail.com>
|
|
|
// +----------------------------------------------------------------------
|
|
|
namespace Org\Net;
|
|
|
/**
|
|
|
* Http 工具类
|
|
|
* 提供一系列的Http方法
|
|
|
* @author liu21st <liu21st@gmail.com>
|
|
|
*/
|
|
|
class Http {
|
|
|
|
|
|
/**
|
|
|
* 采集远程文件
|
|
|
* @access public
|
|
|
* @param string $remote 远程文件名
|
|
|
* @param string $local 本地保存文件名
|
|
|
* @return mixed
|
|
|
*/
|
|
|
static public function curlDownload($remote,$local) {
|
|
|
$cp = curl_init($remote);
|
|
|
$fp = fopen($local,"w");
|
|
|
curl_setopt($cp, CURLOPT_FILE, $fp);
|
|
|
curl_setopt($cp, CURLOPT_HEADER, 0);
|
|
|
curl_exec($cp);
|
|
|
curl_close($cp);
|
|
|
fclose($fp);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 使用 fsockopen 通过 HTTP 协议直接访问(采集)远程文件
|
|
|
* 如果主机或服务器没有开启 CURL 扩展可考虑使用
|
|
|
* fsockopen 比 CURL 稍慢,但性能稳定
|
|
|
* @static
|
|
|
* @access public
|
|
|
* @param string $url 远程URL
|
|
|
* @param array $conf 其他配置信息
|
|
|
* int limit 分段读取字符个数
|
|
|
* string post post的内容,字符串或数组,key=value&形式
|
|
|
* string cookie 携带cookie访问,该参数是cookie内容
|
|
|
* string ip 如果该参数传入,$url将不被使用,ip访问优先
|
|
|
* int timeout 采集超时时间
|
|
|
* bool block 是否阻塞访问,默认为true
|
|
|
* @return mixed
|
|
|
*/
|
|
|
static public function fsockopenDownload($url, $conf = array()) {
|
|
|
$return = '';
|
|
|
if(!is_array($conf)) return $return;
|
|
|
|
|
|
$matches = parse_url($url);
|
|
|
!isset($matches['host']) && $matches['host'] = '';
|
|
|
!isset($matches['path']) && $matches['path'] = '';
|
|
|
!isset($matches['query']) && $matches['query'] = '';
|
|
|
!isset($matches['port']) && $matches['port'] = '';
|
|
|
$host = $matches['host'];
|
|
|
$path = $matches['path'] ? $matches['path'].($matches['query'] ? '?'.$matches['query'] : '') : '/';
|
|
|
$port = !empty($matches['port']) ? $matches['port'] : 80;
|
|
|
|
|
|
$conf_arr = array(
|
|
|
'limit' => 0,
|
|
|
'post' => '',
|
|
|
'cookie' => '',
|
|
|
'ip' => '',
|
|
|
'timeout' => 15,
|
|
|
'block' => TRUE,
|
|
|
);
|
|
|
|
|
|
foreach (array_merge($conf_arr, $conf) as $k=>$v) ${$k} = $v;
|
|
|
|
|
|
if($post) {
|
|
|
if(is_array($post))
|
|
|
{
|
|
|
$post = http_build_query($post);
|
|
|
}
|
|
|
$out = "POST $path HTTP/1.0\r\n";
|
|
|
$out .= "Accept: */*\r\n";
|
|
|
//$out .= "Referer: $boardurl\r\n";
|
|
|
$out .= "Accept-Language: zh-cn\r\n";
|
|
|
$out .= "Content-Type: application/x-www-form-urlencoded\r\n";
|
|
|
$out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
|
|
|
$out .= "Host: $host\r\n";
|
|
|
$out .= 'Content-Length: '.strlen($post)."\r\n";
|
|
|
$out .= "Connection: Close\r\n";
|
|
|
$out .= "Cache-Control: no-cache\r\n";
|
|
|
$out .= "Cookie: $cookie\r\n\r\n";
|
|
|
$out .= $post;
|
|
|
} else {
|
|
|
$out = "GET $path HTTP/1.0\r\n";
|
|
|
$out .= "Accept: */*\r\n";
|
|
|
//$out .= "Referer: $boardurl\r\n";
|
|
|
$out .= "Accept-Language: zh-cn\r\n";
|
|
|
$out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
|
|
|
$out .= "Host: $host\r\n";
|
|
|
$out .= "Connection: Close\r\n";
|
|
|
$out .= "Cookie: $cookie\r\n\r\n";
|
|
|
}
|
|
|
$fp = @fsockopen(($ip ? $ip : $host), $port, $errno, $errstr, $timeout);
|
|
|
if(!$fp) {
|
|
|
return '';
|
|
|
} else {
|
|
|
stream_set_blocking($fp, $block);
|
|
|
stream_set_timeout($fp, $timeout);
|
|
|
@fwrite($fp, $out);
|
|
|
$status = stream_get_meta_data($fp);
|
|
|
if(!$status['timed_out']) {
|
|
|
while (!feof($fp)) {
|
|
|
if(($header = @fgets($fp)) && ($header == "\r\n" || $header == "\n")) {
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$stop = false;
|
|
|
while(!feof($fp) && !$stop) {
|
|
|
$data = fread($fp, ($limit == 0 || $limit > 8192 ? 8192 : $limit));
|
|
|
$return .= $data;
|
|
|
if($limit) {
|
|
|
$limit -= strlen($data);
|
|
|
$stop = $limit <= 0;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@fclose($fp);
|
|
|
return $return;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 下载文件
|
|
|
* 可以指定下载显示的文件名，并自动发送相应的Header信息
|
|
|
* 如果指定了content参数，则下载该参数的内容
|
|
|
* @static
|
|
|
* @access public
|
|
|
* @param string $filename 下载文件名
|
|
|
* @param string $showname 下载显示的文件名
|
|
|
* @param string $content 下载的内容
|
|
|
* @param integer $expire 下载内容浏览器缓存时间
|
|
|
* @return void
|
|
|
*/
|
|
|
static public function download ($filename, $showname='',$content='',$expire=180) {
|
|
|
if(is_file($filename)) {
|
|
|
$length = filesize($filename);
|
|
|
}elseif(is_file(UPLOAD_PATH.$filename)) {
|
|
|
$filename = UPLOAD_PATH.$filename;
|
|
|
$length = filesize($filename);
|
|
|
}elseif($content != '') {
|
|
|
$length = strlen($content);
|
|
|
}else {
|
|
|
E($filename.L('下载文件不存在！'));
|
|
|
}
|
|
|
if(empty($showname)) {
|
|
|
$showname = $filename;
|
|
|
}
|
|
|
$showname = basename($showname);
|
|
|
if(!empty($filename)) {
|
|
|
$finfo = new \finfo(FILEINFO_MIME);
|
|
|
$type = $finfo->file($filename);
|
|
|
}else{
|
|
|
$type = "application/octet-stream";
|
|
|
}
|
|
|
//发送Http Header信息 开始下载
|
|
|
header("Pragma: public");
|
|
|
header("Cache-control: max-age=".$expire);
|
|
|
//header('Cache-Control: no-store, no-cache, must-revalidate');
|
|
|
header("Expires: " . gmdate("D, d M Y H:i:s",time()+$expire) . "GMT");
|
|
|
header("Last-Modified: " . gmdate("D, d M Y H:i:s",time()) . "GMT");
|
|
|
header("Content-Disposition: attachment; filename=".$showname);
|
|
|
header("Content-Length: ".$length);
|
|
|
header("Content-type: ".$type);
|
|
|
header('Content-Encoding: none');
|
|
|
header("Content-Transfer-Encoding: binary" );
|
|
|
if($content == '' ) {
|
|
|
readfile($filename);
|
|
|
}else {
|
|
|
echo($content);
|
|
|
}
|
|
|
exit();
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 显示HTTP Header 信息
|
|
|
* @return string
|
|
|
*/
|
|
|
static function getHeaderInfo($header='',$echo=true) {
|
|
|
ob_start();
|
|
|
$headers = getallheaders();
|
|
|
if(!empty($header)) {
|
|
|
$info = $headers[$header];
|
|
|
echo($header.':'.$info."\n"); ;
|
|
|
}else {
|
|
|
foreach($headers as $key=>$val) {
|
|
|
echo("$key:$val\n");
|
|
|
}
|
|
|
}
|
|
|
$output = ob_get_clean();
|
|
|
if ($echo) {
|
|
|
echo (nl2br($output));
|
|
|
}else {
|
|
|
return $output;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* HTTP Protocol defined status codes
|
|
|
* @param int $num
|
|
|
*/
|
|
|
static function sendHttpStatus($code) {
|
|
|
static $_status = array(
|
|
|
// Informational 1xx
|
|
|
100 => 'Continue',
|
|
|
101 => 'Switching Protocols',
|
|
|
|
|
|
// Success 2xx
|
|
|
200 => 'OK',
|
|
|
201 => 'Created',
|
|
|
202 => 'Accepted',
|
|
|
203 => 'Non-Authoritative Information',
|
|
|
204 => 'No Content',
|
|
|
205 => 'Reset Content',
|
|
|
206 => 'Partial Content',
|
|
|
|
|
|
// Redirection 3xx
|
|
|
300 => 'Multiple Choices',
|
|
|
301 => 'Moved Permanently',
|
|
|
302 => 'Found', // 1.1
|
|
|
303 => 'See Other',
|
|
|
304 => 'Not Modified',
|
|
|
305 => 'Use Proxy',
|
|
|
// 306 is deprecated but reserved
|
|
|
307 => 'Temporary Redirect',
|
|
|
|
|
|
// Client Error 4xx
|
|
|
400 => 'Bad Request',
|
|
|
401 => 'Unauthorized',
|
|
|
402 => 'Payment Required',
|
|
|
403 => 'Forbidden',
|
|
|
404 => 'Not Found',
|
|
|
405 => 'Method Not Allowed',
|
|
|
406 => 'Not Acceptable',
|
|
|
407 => 'Proxy Authentication Required',
|
|
|
408 => 'Request Timeout',
|
|
|
409 => 'Conflict',
|
|
|
410 => 'Gone',
|
|
|
411 => 'Length Required',
|
|
|
412 => 'Precondition Failed',
|
|
|
413 => 'Request Entity Too Large',
|
|
|
414 => 'Request-URI Too Long',
|
|
|
415 => 'Unsupported Media Type',
|
|
|
416 => 'Requested Range Not Satisfiable',
|
|
|
417 => 'Expectation Failed',
|
|
|
|
|
|
// Server Error 5xx
|
|
|
500 => 'Internal Server Error',
|
|
|
501 => 'Not Implemented',
|
|
|
502 => 'Bad Gateway',
|
|
|
503 => 'Service Unavailable',
|
|
|
504 => 'Gateway Timeout',
|
|
|
505 => 'HTTP Version Not Supported',
|
|
|
509 => 'Bandwidth Limit Exceeded'
|
|
|
);
|
|
|
if(isset($_status[$code])) {
|
|
|
header('HTTP/1.1 '.$code.' '.$_status[$code]);
|
|
|
}
|
|
|
}
|
|
|
}//类定义结束
|