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

<?php
/*
===========================================================
    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

<?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);