我的HTTPClient模拟PHPClass

最近因为要通过php调用REST接口,简单的写了一个模拟HTTPClient的PHP Class.相当于模拟浏览器操作.这是一个初始版本.等以后有时间了在完善下.如果有什么意见或者好的想法,欢迎指教.

/*
===========================================================
　 HTTP.php　 Zhu Weiwei
　 Copyright © 2006-2008
　 http://www.cncmm.com China. All Rights Reserved.
===========================================================
*/

class HTTP{
　 PRivate $m_httpVersion = "HTTP/1.0";
　 private $m_method　　　 = "GET";
　 private $m_enctype　　 = "application/x-www-form-urlencoded";
　 private $m_scheme　　　 = "http";
　 private $m_host　　　　 = "127.0.0.1";
　 private $m_port　　　　 = 80;
　 private $m_path　　　　 = "/";
　 private $m_query　　　 = "";
　 private $m_fragment　　 = "";
　 private $m_user　　　　 = "";
　 private $m_pass　　　　 = "";
　 private $m_uri　　　　 = "/";

　 private $m_referer　　 = "";
　 private $m_mimeBoundary = "";
　 private $m_sockTimeout = 10;
　 private $m_readTimeout = 10;
　 private $m_timeout　　 = false;
　
　 private $m_sock　　　　 = "";
　 private $m_error　　　 = "";
　 private $CRLF　　　　　 = "\r\n";

　 private $m_arrParam　　 = Array();
　 private $m_arrFile　　 = Array();
　 private $m_arrCookie　 = Array();

　 private $m_request　　 = "";
　 private $m_requestHead = "";
　 private $m_requestBody = "";

　 private $m_response　　 = "";
　 private $m_responseHead = Array();
　 private $m_responseBody = "";

　 private $m_maxLineLength= 1024;

　 function __construct() {

　 }

　 function getResponseHead() {
　　　 return $this->m_responseHead;
　 }

　 function getResponseBody() {
　　　 return $this->m_responseBody;
　 }

　 function getResponse() {
　　　 return $this->m_response;
　 }

　 function getRequestHead() {
　　　 return $this->m_requestHead;
　 }

　 function getRequestBody() {
　　　 return $this->m_requestBody;
　 }

　 function getRequest() {
　　　 return $this->m_request;
　 }

　 function getError() {
　　　 return $this->m_error;
　 }

　 function setMethod($m) {
　　　 $this->m_method = (strtoupper($m=='POST'))?('POST'):('GET');
　 }

　 function setEnctype($e) {
　　　 $this->m_enctype = (strtolower($e)=='application/x-www-form-urlencoded')?
　　　　　　　　　　　　　 ('application/x-www-form-urlencoded'):('multipart/form-data');
　 }

　 function setURL($url) {
　　　 $rs = parse_url($url);
　　　 $this->m_scheme　 = empty($rs['scheme']) ?('http')　　 :($rs['scheme']);
　　　 $this->m_host　　 = empty($rs['host'])　 ?('localhost'):($rs['host']);
　　　 $this->m_port　　 = empty($rs['port'])　 ?('80')　　　 :($rs['port']);
　　　 $this->m_user　　 = empty($rs['user'])　 ?('')　　　　 :($rs['user']);
　　　 $this->m_pass　　 = empty($rs['pass'])　 ?('')　　　　 :($rs['pass']);
　　　 $this->m_path　　 = empty($rs['path'])　 ?('/')　　　 :($rs['path']);
　　　 $this->m_query　 = empty($rs['query'])　 ?('')　　　　 :($rs['query']);
　　　 $this->m_fragment = empty($rs['fragment'])?('')　　　　 :($rs['fragment']);
　　　
　　　 $this->m_uri = $this->m_path;
　　　 if(!empty($this->m_query)){
　　　　　 $this->m_uri .= '?'.$this->m_query;
　　　 }
　　　 if(!empty($this->m_fragment)){
　　　　　 $this->m_uri .= '#'.$this->m_fragment;
　　　 }
　 }

　 function addParameter($key,$val) {
　　　 if(!empty($key)){
　　　　　 $this->m_arrParam[$key] = $val;
　　　 }
　 }

　 function addFile($key,$file) {
　　　 if(!empty($key) && file_exists($file)){
　　　　　 $this->m_arrFile[$key] = $file;
　　　 }
　 }

　 function addCookie($key,$val) {
　　　 if(!empty($key)){
　　　　　 $this->m_arrCookie[$key] = $val;
　　　 }
　 }

　 function connect() {
　　　 $this->m_sock = fsockopen($this->m_host,
　　　　　　　　　　　　　　　　 $this->m_port,
　　　　　　　　　　　　　　　　 $errno,
　　　　　　　　　　　　　　　　 $errstr,
　　　　　　　　　　　　　　　　 $this->m_sockTimeout);

　 if($this->m_sock){
　　　　　 return true;
　　　 }else{
　　　　　 switch($errno){
　　　　　　　 case -3: $this->m_error="socket creation failed (-3)";　　　　 break;
　　　　　　　 case -4: $this->m_error="dns lookup failure (-4)";　　　　　　 break;
　　　　　　　 case -5: $this->m_error="connection refused or timed out (-5)"; break;
　　　　　　　 default: $this->m_error="connection failed (".$errno.")";　　　 break;
　　　　　 }
　　　　　 return false;
　　　 }
　 }

　 function disconnect(){
　　　 return(fclose($this->m_sock));
　 }

http://www.devdao.com/
　 function sendRequest() {
　　　 if($this->connect()){
　　　　　 $this->buildRequest();

　　　 socket_set_timeout($this->m_sock, $this->m_readTimeout);
　　　　　 fwrite($this->m_sock, $this->m_request, strlen($this->m_request));

　　　 /*
　　　　　　　 Get And Parse HTTP Header
　　　　　 */

　　　 while( !feof($this->m_sock) )
　　　　　 {
　　　　　　　 if( $this->m_readTimeout > 0 && $this->checkResponseTimeOut() ){
　　　　　　　　　 return false;
　　　　　　　 }
　　　　　　　 $line = fgets($this->m_sock, $this->m_maxLineLength);
　　　　　　　 if($line == $this->CRLF )
　　　　　　　　　 break;

　　　　　 $this->m_responseHead['Content'] .= $line;
　　　　　　　 if(preg_match("|^HTTP/[^\s]*\s(.*?)\s|",$line, $status)){
　　　　　　　　　 $this->m_responseHead['Status'] = $status[1];
　　　　　　　 }else{
　　　　　　　　　 list($key,$val) = explode(': ',$line,2);
　　　　　　　　　 $this->m_responseHead[$key] = $val;
　　　　　　　 }
　　　　　 }

　　　 /*
　　　　　　　 Get HTTP Body
　　　　　 */
　　　　　 while(!feof($this->m_sock) ) {
　　　　　　　 if( $this->m_readTimeout > 0 && $this->checkResponseTimeOut() ){
　　　　　　　　　 return false;
　　　　　　　 }
　　　　　　　 $this->m_responseBody .= fgets($this->m_sock, $this->m_maxLineLength);
　　　　　 }　　　

　　　 $this->m_response = $this->m_responseHead['Content'].$this->m_responseBody;
　　　　　 $this->disconnect();
　　　　　 return true;
　　　 }else{
　　　　　 return false;
　　　 }
　 }

　 function checkResponseTimeOut()
　 {
　　　 if ($this->m_readTimeout > 0) {
　　　　　 $fp_status = socket_get_status($this->m_sock);
　　　　　 if ($fp_status["timed_out"]) {
　　　　　　　 $this->m_error="read response timeout!";
　　　　　　　 return true;
　　　　　 }
　　　 }
　　　 return false;
　 }

　 function buildRequest() {
　　　 switch( $this->m_method ){
　　　　　 case "POST":
　　　　　　　 $body = $this->buildRequestBody();
　　　　　　　 $head = $this->buildRequestHead();

　　　　　 $this->m_request = $head.$this->CRLF.$this->CRLF.$body;
　　　　　　　 break;

　　　 case "GET":
　　　　　　　 $head = $this->buildRequestHead();

　　　　　 $this->m_request = $head.$this->CRLF.$this->CRLF;
　　　　　　　 break;
　　　 }
　　　 return $this->m_request;
　 }

　 function buildRequestHead() {
　　　 $header = Array();
　　　 switch( $this->m_method ){
　　　　　 case "POST":
　　　　　　　 $header[] ="POST $this->m_uri $this->m_httpVersion";
　　　　　　　 $header[] = "Content-Length: ".strlen($this->m_requestBody);
　　　　　　　 switch ($this->m_enctype) {
　　　　　　　　　 case "application/x-www-form-urlencoded":
　　　　　　　　　　　 $header[] ="Content-Type: application/x-www-form-urlencoded";
　　　　　　　　　　　 //$header[] ="Content-Type: application/xml; charset=UTF-8";
　　　　　　　　　　　 break;
　　　　　　　　　 case "multipart/form-data":
　　　　　　　　　　　 $header[] ="Content-Type: multipart/form-data; boundary=$this->m_mimeBoundary";　　
　　　　　　　　　　　 break;
　　　　　　　 }
　　　　　　　 break;
　　　　　 case "GET":
　　　　　　　 $header[] ="GET $this->m_uri $this->m_httpVersion";
　　　　　　　 break;
　　　 }

　 $header[] = "Cache-Control: no-cache";
　　　 $header[] = "Pragma: no-cache";
　　　 $header[] = "User-Agent: Mozilla/5.0 (Windows; U; Windows NT 5.1; zh-CN; rv:1.9.0.11) Gecko/2009060215 Firefox/3.0.11";
　　　 $header[] = "Accept: */*";
　　　 #$header[] = "Accept-Language: zh-cn";
　　　 #$header[] = "Accept-Encoding: gzip,deflate";
　　　 #$header[] = "Accept-Charset: utf-8";
　　　 $header[] = "Connection: Keep-Alive";
　　　 $header[] = "Keep-Alive: 300";

　 //$header[] = "Connection: Close";
　　　 //$header[] = "Referer: $this->m_referer";
　　　 //$header[] = "Cookie: ".join(';',$this->m_arrCookie);

　 if( intval($this->m_port) == 80 ){
　　　　　 $header[] = "Host: $this->m_host";
　　　 }else{
　　　　　 $header[] = "Host: $this->m_host:$this->m_port";
　　　 }

　 if(!empty($this->m_user) || !empty($this->m_pass)){　
　　　　　 $header[] = "Authorization: Basic ".base64_encode($this->m_user.":".$this->m_pass);
　　　 }

　 $this->m_requestHead = join($this->CRLF, $header);
　　　 return $this->m_requestHead;
　 }

　 function buildRequestBody() {
　　　 $body = Array();
　　　 switch ($this->m_enctype) {
　　　　　 case "application/x-www-form-urlencoded":
　　　　　　　 foreach( $this->m_arrParam as $key=>$val) {
　　　　　　　　　 $body[] = urlencode($key)."=".urlencode($val);
　　　　　　　 }
　　　　　　　 $this->m_requestBody = join("&",$body);
　　　　　　　 //$this->m_requestBody = json_encode($this->m_arrParam); //For Rest
　　　　　　　 break;

　　　 case "multipart/form-data":
　　　　　　　 $this->m_mimeBoundary = '<'.base64_encode(uniqid(microtime(),true)).'=>';

　　　　　 foreach( $this->m_arrParam as $key=>$val) {
　　　　　　　　　 $body[] = "--".$this->m_mimeBoundary;
　　　　　　　　　 $body[] = "Content-Disposition: form-data; name=\"$key\"".$this->CRLF;
　　　　　　　　　 $body[] = $val;
　　　　　　　 }

　　　　　 foreach( $this->m_arrFile as $key=>$filename) {
　　　　　　　　　 $body[] = "--".$this->m_mimeBoundary;
　　　　　　　　　 $body[] = "Content-Disposition: form-data; name=\"$key\"; filename=\"$filename\"";
　　　　　　　　　 $body[] = "Content-Type: application/octet-stream";
　　　　　　　　　 $body[] = "Content-Transfer-Encoding: Binary".$this->CRLF;
　　　　　　　　　 $body[] = file_get_contents($filename);
　　　　　　　 }
　　　　　　　 $body[] = "--".$this->m_mimeBoundary."--".$this->CRLF;
　　　　　　　 $this->m_requestBody = join($this->CRLF,$body);
　　　　　　　 break;
　　　 }
　　　 return $this->m_requestBody;
　 }
};
example.php

require_once("http.php");
$oHTTP = new HTTP();
$oHTTP->setURL("http://www.cncmm.com/");
$oHTTP->setMethod("POST");
$oHTTP->addParameter("param","value");
$oHTTP->addFile("filedata","/tmp/tmpFile");
if( !$oHTTP->sendRequest() ){
　 print($oHTTP->getError());
　 exit();
}
$request = $oHTTP->getRequest();
$response = $oHTTP->getResponse();
print($response);