PHP反向代理类代码

php  /  管理员 发布于 7年前   192

改自PHP Reverse Proxy PRP，修改了原版中的一些错误，支持了文件上传以及上传文件类型识别，支持指定IP，自适应SAE环境。

使用方法

port="8080";$proxy->host="";//$proxy->ip="1.1.1.1";$proxy->forward_path="";$proxy->connect();$proxy->output();?>

源代码

version="PHP Reverse Proxy (PRP) 1.0";  $this->port="8080";  $this->host="127.0.0.1";  $this->ip="";  $this->content="";  $this->forward_path="";  $this->path="";  $this->content_type="";  $this->user_agent="";  $this->http_code="";  $this->XFF="";  $this->request_method="GET";  $this->IMS=false;  $this->cacheTime=72000;  $this->lastModified=gmdate("D, d M Y H:i:s",time()-72000)." GMT";  $this->cookie="";  $this->XRequestedWith = "";  $this->authorization = ""; } function translateURL($serverName) {  $this->path=$this->forward_path.$_SERVER['REQUEST_URI'];  if(IS_SAE)   return $this->translateServer($serverName).$this->path;  if($_SERVER['QUERY_STRING']=="")   return $this->translateServer($serverName).$this->path;  else  return $this->translateServer($serverName).$this->path."?".$_SERVER['QUERY_STRING']; } function translateServer($serverName) {  $s = empty($_SERVER["HTTPS"]) ? ''   : ($_SERVER["HTTPS"] == "on") ? "s"   : "";  $protocol = $this->left(strtolower($_SERVER["SERVER_PROTOCOL"]), "/").$s;  if($this->port=="")    return $protocol."://".$serverName;  else   return $protocol."://".$serverName.":".$this->port; } function left($s1, $s2) {  return substr($s1, 0, strpos($s1, $s2)); } function preConnect(){  $this->user_agent=$_SERVER['HTTP_USER_AGENT'];  $this->request_method=$_SERVER['REQUEST_METHOD'];  $tempCookie="";  foreach ($_COOKIE as $i => $value) {   $tempCookie=$tempCookie." $i=$_COOKIE[$i];";  }  $this->cookie=$tempCookie;  if(empty($_SERVER['HTTP_X_FORWARDED_FOR'])){   $this->XFF=$_SERVER['REMOTE_ADDR'];  } else {   $this->XFF=$_SERVER['HTTP_X_FORWARDED_FOR'].", ".$_SERVER['REMOTE_ADDR'];  }  } function connect(){  if(empty($_SERVER['HTTP_IF_MODIFIED_SINCE'])){   $this->preConnect();   $ch=curl_init();   if($this->request_method=="POST"){    curl_setopt($ch, CURLOPT_POST,1);     $postData = array();    $filePost = false;    $uploadPath = 'uploads/';    if (IS_SAE)      $uploadPath = SAE_TMP_PATH;     if(count($_FILES)>0){      if(!is_writable($uploadPath)){        die('You cannot upload to the specified directory, please CHMOD it to 777.');      }      foreach($_FILES as $key => $fileArray){         copy($fileArray["tmp_name"], $uploadPath . $fileArray["name"]);        $proxyLocation = "@" . $uploadPath . $fileArray["name"] . ";type=" . $fileArray["type"];        $postData = array($key => $proxyLocation);        $filePost = true;      }    }     foreach($_POST as $key => $value){      if(!is_array($value)){     $postData[$key] = $value;      }      else{     $postData[$key] = serialize($value);      }    }     if(!$filePost){      //$postData = http_build_query($postData);      $postString = "";      $firstLoop = true;      foreach($postData as $key => $value){      $parameterItem = urlencode($key)."=".urlencode($value);      if($firstLoop){     $postString .= $parameterItem;      }      else{     $postString .= "&".$parameterItem;      }      $firstLoop = false;       }      $postData = $postString;    }     //echo print_r($postData);     //curl_setopt($ch, CURLOPT_VERBOSE, 0);    //curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);    //curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/4.0 (compatible;)");    $this->sendPost = $postData;    //var_dump(file_exists(str_replace('@','',$postData['imgfile'])));exit;    curl_setopt($ch, CURLOPT_POSTFIELDS,$postData);    //curl_setopt($ch, CURLOPT_POSTFIELDS,file_get_contents($proxyLocation));    //curl_setopt($ch, CURLOPT_POSTFIELDS,file_get_contents("php://input"));   }    //gets rid of mulitple ? in URL   $translateURL = $this->translateURL(($this->ip)?$this->ip:$this->host);   if(substr_count($translateURL, "?")>1){     $firstPos = strpos($translateURL, "?", 0);     $secondPos = strpos($translateURL, "?", $firstPos + 1);     $translateURL = substr($translateURL, 0, $secondPos);   }    curl_setopt($ch,CURLOPT_URL,$translateURL);    $proxyHeaders = array(     "X-Forwarded-For: ".$this->XFF,     "User-Agent: ".$this->user_agent,     "Host: ".$this->host   );    if(strlen($this->XRequestedWith)>1){     $proxyHeaders[] = "X-Requested-With: ".$this->XRequestedWith;     //echo print_r($proxyHeaders);   }    curl_setopt($ch,CURLOPT_HTTPHEADER, $proxyHeaders);    if($this->cookie!=""){    curl_setopt($ch,CURLOPT_COOKIE,$this->cookie);   }   curl_setopt($ch,CURLOPT_FOLLOWLOCATION,false);    curl_setopt($ch,CURLOPT_AUTOREFERER,true);    curl_setopt($ch,CURLOPT_HEADER,true);   curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);    $output=curl_exec($ch);   $info = curl_getinfo( $ch );   curl_close($ch);   $this->postConnect($info,$output);  }else {   $this->lastModified=$_SERVER['HTTP_IF_MODIFIED_SINCE'];   $this->IMS=true;  } } function postConnect($info,$output){  $this->content_type=$info["content_type"];  $this->http_code=$info['http_code'];  //var_dump($info);exit;  if(!empty($info['last_modified'])){   $this->lastModified=$info['last_modified'];  }  $this->resultHeader=substr($output,0,$info['header_size']);  $content = substr($output,$info['header_size']);   if($this->http_code=='200'){   $this->content=$content;  }elseif( ($this->http_code=='302' || $this->http_code=='301') && isset($info['redirect_url'])){   $redirect_url = str_replace($this->host,$_SERVER['HTTP_HOST'],$info['redirect_url']);   if (IS_SAE)     $redirect_url = str_replace('http://fetchurl.sae.sina.com.cn/','',$info['redirect_url']);   header("Location: $redirect_url");   exit;  }elseif($this->http_code=='404'){   header("HTTP/1.1 404 Not Found");   exit("HTTP/1.1 404 Not Found");  }elseif($this->http_code=='500'){   header('HTTP/1.1 500 Internal Server Error');   exit("HTTP/1.1 500 Internal Server Error");  }else{   exit("HTTP/1.1 ".$this->http_code." Internal Server Error");  } }  function output(){  $currentTimeString=gmdate("D, d M Y H:i:s",time());  $expiredTime=gmdate("D, d M Y H:i:s",(time()+$this->cacheTime));   $doOriginalHeaders = true;  if($doOriginalHeaders){    if($this->IMS){     header("HTTP/1.1 304 Not Modified");     header("Date: Wed, $currentTimeString GMT");     header("Last-Modified: $this->lastModified");     header("Server: $this->version");    }else{      header("HTTP/1.1 200 OK");     header("Date: Wed, $currentTimeString GMT");     header("Content-Type: ".$this->content_type);     header("Last-Modified: $this->lastModified");     header("Cache-Control: max-age=$this->cacheTime");     header("Expires: $expiredTime GMT");     header("Server: $this->version");     preg_match("/Set-Cookie:[^\n]*/i",$this->resultHeader,$result);     foreach($result as $i=>$value){      header($result[$i]);     }     preg_match("/Content-Encoding:[^\n]*/i",$this->resultHeader,$result);     foreach($result as $i=>$value){      //header($result[$i]);     }     preg_match("/Transfer-Encoding:[^\n]*/i",$this->resultHeader,$result);     foreach($result as $i=>$value){      //header($result[$i]);     }     echo($this->content);     /*     if(stristr($this->content, "error")){    echo print_r($this->sendPost);     }     */    }  }  else{    $headerString = $this->resultHeader; //string     $headerArray = explode("\n", $headerString);    foreach($headerArray as $privHeader){   header($privHeader);    }     if(stristr($headerString, "Transfer-encoding: chunked")){   flush();   ob_flush();   $i = 0;   $maxLen = strlen($this->content);    while($i < $maxLen){     $endChar = $i + self::chunkSize;     if($endChar >= $maxLen){    $endChar = $maxLen - 1;     }     $chunk = substr($this->content, $i, $endChar);     $this->dump_chunk($chunk);     flush();     ob_flush();     $i = $i + $endChar;   }    }    else{    echo($this->content);    }     //echo "header: ".print_r($headerArray);    //header($this->resultHeader);  }  }   function dump_chunk($chunk) {   echo sprintf("%x\r\n", strlen($chunk));   echo $chunk;   echo "\r\n"; }   function getOutsideHeaders(){   $headers = array();   foreach ($_SERVER as $name => $value){   if (substr($name, 0, 5) == 'HTTP_') {     $name = str_replace(' ', '-', ucwords(strtolower(str_replace('_', ' ', substr($name, 5)))));     $headers[$name] = $value;   }elseif ($name == "CONTENT_TYPE") {     $headers["Content-Type"] = $value;   }elseif ($name == "CONTENT_LENGTH") {     $headers["Content-Length"] = $value;   }elseif(stristr($name, "X-Requested-With")) {     $headers["X-Requested-With"] = $value;    $this->XRequestedWith = $value;  }   }     //echo print_r($headers);    $this->outsideHeaders = $headers;   return $headers; }  }?>

您可能感兴趣的文章:

• php采集中国代理服务器网的方法
• php在线代理转向代码
• php设计模式 Proxy (代理模式)
• php中通过虚代理实现延迟加载的实现代码
• PHP 反射机制实现动态代理的代码
• php使用curl并发减少后端访问时间的方法分析
• PHP使用curl模拟post上传及接收文件的方法
• PHP Curl模拟登录微信公众平台、新浪微博实例代码
• php curl抓取网页的介绍和推广及使用CURL抓取淘宝页面集成方法
• php使用curl通过代理获取数据的实现方法