HTTP操作类－－工厂模式－不经典不传－求加精

注解，该类来源于网络。经本人加工，可以支持自定义连接端口号。喜欢的朋友直接拿去。
全面封装,PHP里使用CURL,SOCKET，STREAM，进行连接操作时的不便，完全使用同一调用方式，优化了代码。提高了效率
<?php
/************************************************************
 * 描述：HTTP操作类
 * 作者：heiyeluren
 * 创建：2009/12/13 04:43
 * 修改：2009/12/16 10:30  实现基本HTTP各种接口操作支持
 *
 ************************************************************/

/**
 * HTTP功能工厂方法类
 *
 * 调用示例代码：
     try {
         $http = Http::factory('http://www.baidu.com', Http::TYPE_SOCK );
         echo $http->get();  
         $http = Http::factory('http://127.0.0.1/test/i.php', Http::TYPE_SOCK );
         echo $http->post('', array('user'=>'我们', 'nick'=>'ASSADF@#!32812989+-239%ASDF'), '', array('aa'=> 'bb', 'cc'=>'dd'));
     } catch (Exception $e) {
        echo $e->getMessage();
     }
 */
class Http {
    /**
     * @var 使用 CURL
     */
    const TYPE_CURL = 1;
    /**
     * @var 使用 Socket
     */
    const TYPE_SOCK = 2;
    /**
     * @var 使用 Stream
     */
    const TYPE_STREAM = 3;
   
    /**
     * 保证对象不被clone
     */
    private function __clone() {
    }
   
    /**
     * 构造函数
     */
    private function __construct() {
    }
   
    /**
     * HTTP工厂操作方法
     *
     * @param string $url 需要访问的URL
     * @param int $type 需要使用的HTTP类
     * @return object
     */
    public static function factory($url = '', $type = self::TYPE_SOCK) {
        if ($type == '') {
            $type = self::TYPE_SOCK;
        }
        switch ($type) {
            case self::TYPE_CURL :
                if (! function_exists ( 'curl_init' )) {
                    throw new Exception ( __CLASS__ . " PHP CURL extension not install" );
                }
                $obj = Http_Curl::getInstance ( $url );
                break;
            case self::TYPE_SOCK :
                if (! function_exists ( 'fsockopen' )) {
                    throw new Exception ( __CLASS__ . " PHP function fsockopen() not support" );
                }
                $obj = Http_Sock::getInstance ( $url );
                break;
            case self::TYPE_STREAM :
                if (! function_exists ( 'stream_context_create' )) {
                    throw new Exception ( __CLASS__ . " PHP Stream extension not install" );
                }
                $obj = Http_Stream::getInstance ( $url );
                break;
            default :
                throw new Exception ( "http access type $type not support" );
        }
        return $obj;
    }
    /**
     * 生成一个供Cookie或HTTP GET Query的字符串
     *
     * @param array $data 需要生产的数据数组，必须是 Name => Value 结构
     * @param string $sep 两个变量值之间分割的字符，缺省是 & 
     * @return string 返回生成好的Cookie 查询字符串
     */
    public static function makeQuery($data, $sep = '&') {
        $encoded = '';
        while (list($k,$v)=each($data)) {
            $encoded .= ($encoded ? "$sep" : "");
            $encoded .= rawurlencode ( $k ) . "=" . rawurlencode ( $v );
        }
        return $encoded;
    }

}

/**
 * 使用CURL 作为核心操作的HTTP访问类
 *
 * @desc CURL 以稳定、高效、移植性强作为很重要的HTTP 协议访问客户端，必须在PHP中安装 CURL 扩展才能使用本功能
 */
class Http_Curl {
    /**
     * @var object 对象单例
     */
    static $_instance = NULL;
   
    /**
     * @var string 需要发送的cookie信息
     */
    private $cookies = '';
    /**
     * @var array 需要发送的头信息
     */
    private $header = array ();
    /**
     * @var string 需要访问的URL地址
     */
    private $uri = '';
    /**
     * @var array 需要发送的数据
     */
    private $vars = array ();
    /**
     * @var int port 端口号
     *
     */
    private $port = '';
    /**
     * 构造函数
     *
     * @param string $configFile 配置文件路径
     */
    private function __construct($url,$port=0) {
        $this->uri = $url;
        $this->port = $port;
    }
   
    /**
     * 保证对象不被clone
     */
    private function __clone() {
    }
   
    /**
     * 获取对象唯一实例
     *
     * @param string $configFile 配置文件路径
     * @return object 返回本对象实例
     */
    public static function getInstance($url = '') {
        if (! (self::$_instance instanceof self)) {
            self::$_instance = new self ( $url );
        }
        return self::$_instance;
    }
   
    /**
     * 设置需要发送的HTTP头信息
     *
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @return void
     */
    private function setHeader($header) {
        if (empty ( $header )) {
            return;
        }
        if (is_array ( $header )) {
            foreach ( $header as $k => $v ) {
                $this->header [] = is_numeric ( $k ) ? trim ( $v ) : (trim ( $k ) . ": " . trim ( $v ));
            }
        } elseif (is_string ( $header )) {
            $this->header [] = $header;
        }
    }
    /**
     * 设置商品号
     * @param int $port
     */
    private function setPort($port){
        if($port>0){
            $this->port = $port;
        }
    }
    /**
     * 设置Cookie头信息
     *
     * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
     *
     * @param string/array 需要设置的 Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @return void
     */
    private function setCookie($cookie) {
        if (empty ( $cookie )) {
            return;
        }
        if (is_array ( $cookie )) {
            $this->cookies = Http::makeQuery ( $cookie, ';' );
        } elseif (is_string ( $cookie )) {
            $this->cookies = $cookie;
        }
    }
   
    /**
     * 设置要发送的数据信息
     *
     * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
     *
     * @param array 设置需要发送的数据信息，一个类似于 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @return void
     */
    private function setVar($vars) {
        if (empty ( $vars )) {
            return;
        }
        if (is_array ( $vars )) {
            $this->vars = $vars;
        }
    }
   
    /**
     * 设置要请求的URL地址
     *
     * @param string $url 需要设置的URL地址
     * @return void
     */
    private function setUrl($url) {
        if ($url != '') {
            $this->uri = $url;
        }
    }
   
    /**
     * 发送HTTP GET请求
     *
     * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
     * @param array $vars 需要单独返送的GET变量
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @param string/array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return unknown
     */
    public function get($url = '', $vars = array(), $header = array(), $cookie = '', $timeout = 5, $options = array(),$port=0) {
        $this->setUrl ( $url );
        $this->setHeader ( $header );
        $this->setCookie ( $cookie );
        $this->setVar ( $vars );
        $this->setPort($port);
        return $this->send ( 'GET', $timeout );
    }
   
    /**
     * 发送HTTP POST请求
     *
     * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
     * @param array $vars 需要单独返送的GET变量
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @param string/array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return unknown
     */
    public function post($url = '', $vars = array(), $header = array(), $cookie = '', $timeout = 5, $options = array(),$port=0) {
        $this->setUrl ( $url );
        $this->setHeader ( $header );
        $this->setCookie ( $cookie );
        $this->setVar ( $vars );
        $this->setPort($port);
        return $this->send ( 'POST', $timeout );
    }
   
    /**
     * 发送HTTP请求核心函数
     *
     * @param string $method 使用GET还是 POST方式访问
     * @param array $vars 需要另外附加发送的GET/POST数据
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return string 返回服务器端读取的返回数据
     */
    private function send($method = 'GET', $timeout = 5, $options = array()) {
        //处理参数是否为空 
        if ($this->uri == '') {
            throw new Exception ( __CLASS__ . ": Access url is empty" );
        }
       
        //初始化CURL 
        $ch = curl_init ();
        curl_setopt ( $ch, CURLOPT_HEADER, 0 );
        curl_setopt ( $ch, CURLOPT_FOLLOWLOCATION, 1 );
        curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 );
        curl_setopt ( $ch, CURLOPT_TIMEOUT, $timeout );
       
        //设置特殊属性
        if (! empty ( $options )) {
            curl_setopt_array ( $ch, $options );
        }
        //处理GET请求参数 
        if ($method == 'GET' && ! empty ( $this->vars )) {
            $query = Http::makeQuery ( $this->vars );
            $parse = parse_url ( $this->uri );
            $sep = isset ( $parse ['query'] ) ? '&' : '?';
            $this->uri .= $sep . $query;
        }
        //处理POST请求数据 
        if ($method == 'POST') {
            curl_setopt ( $ch, CURLOPT_POST, 1 );
            curl_setopt ( $ch, CURLOPT_POSTFIELDS, $this->vars );
        }
       
        //设置cookie信息 
        if (! empty ( $this->cookies )) {
            curl_setopt ( $ch, CURLOPT_COOKIE, $this->cookies );
        }
        //设置HTTP缺省头 
        if (empty ( $this->header )) {
            $this->header = array ('User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; InfoPath.1)' )//'Accept-Language: zh-cn',           
            //'Cache-Control: no-cache', 
            ;
        }
        curl_setopt ( $ch, CURLOPT_HTTPHEADER, $this->header );
        //设置端口号
        if($this->port){
            curl_setopt($ch,CURLOPT_PORT,$this->port);
        }
        //发送请求读取输数据 
        curl_setopt ( $ch, CURLOPT_URL, $this->uri );
        $data = curl_exec ( $ch );
        if (($err = curl_error ( $ch ))) {
            curl_close ( $ch );
            echo ( __CLASS__ . " error: " . $err );
        }else{
            curl_close ( $ch );           
        }
        return $data;
    }
}

/**
* 使用 Socket操作(fsockopen) 作为核心操作的HTTP访问接口
*
* @desc Network/fsockopen 是PHP 内置的一个Sokcet网络访问接口，必须安装/打开 fsockopen 函数本类才能工作，
* 同时确保其他相关网络环境和配置是正确的
*/
class Http_Sock {
    /**
     * @var object 对象单例
     */
    static $_instance = NULL;
  
    /**
     * @var string 需要发送的cookie信息
     */
    private $cookies = '';
    /**
     * @var array 需要发送的头信息
     */
    private $header = array ();
    /**
     * @var string 需要访问的URL地址
     */
    private $uri = '';
    /**
     * @var array 需要发送的数据
     */
    private $vars = array ();
    /**
     * @var int 端口号
     */
    private $port = '';
    /**
     * 构造函数
     *
     * @param string $configFile 配置文件路径
     */
    private function __construct($url,$port=0) {
        $this->uri = $url;      
        $this->port = $port;
    }
  
    /**
     * 保证对象不被clone
     */
    private function __clone() {
    }
  
    /**
     * 获取对象唯一实例
     *
     * @param string $configFile 配置文件路径
     * @return object 返回本对象实例
     */
    public static function getInstance($url = '') {
        if (! (self::$_instance instanceof self)) {
            self::$_instance = new self ( $url );
        }
        return self::$_instance;
    }
  
    /**
     * 设置端口号
     * @param int $port
     */
    private function setPort($port){
        if($port>0){
            $this->port = $port;
        }
    }
  
    /**
     * 设置需要发送的HTTP头信息
     *
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @return void
     */
    private function setHeader($header) {
        if (empty ( $header )) {
            return;
        }
        if (is_array ( $header )) {
            foreach ( $header as $k => $v ) {
                $this->header [] = is_numeric ( $k ) ? trim ( $v ) : (trim ( $k ) . ": " . trim ( $v ));
            }
        } elseif (is_string ( $header )) {
            $this->header [] = $header;
        }
    }
  
    /**
     * 设置Cookie头信息
     *
     * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
     *
     * @param string/array 需要设置的 Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @return void
     */
    private function setCookie($cookie) {
        if (empty ( $cookie )) {
            return;
        }
        if (is_array ( $cookie )) {
            $this->cookies = Http::makeQuery ( $cookie, ';' );
        } elseif (is_string ( $cookie )) {
            $this->cookies = $cookie;
        }
    }
  
    /**
     * 设置要发送的数据信息
     *
     * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
     *
     * @param array 设置需要发送的数据信息，一个类似于 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @return void
     */
    private function setVar($vars) {
        if (empty ( $vars )) {
            return;
        }
        if (is_array ( $vars )) {
            $this->vars = $vars;
        }
    }
  
    /**
     * 设置要请求的URL地址
     *
     * @param string $url 需要设置的URL地址
     * @return void
     */
    private function setUrl($url) {
        if ($url != '') {
            $this->uri = $url;
        }
    }
  
    /**
     * 发送HTTP GET请求
     *
     * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
     * @param array $vars 需要单独返送的GET变量
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @param string/array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return unknown
     */
    public function get($url = '', $vars = array(), $header = array(), $cookie = '', $timeout = 5, $options = array(),$port=0) {
        $this->setUrl ( $url );
        $this->setHeader ( $header );
        $this->setCookie ( $cookie );
        $this->setVar ( $vars );
        $this->setPort($port);
        return $this->send ( 'GET', $timeout );
    }
  
    /**
     * 发送HTTP POST请求
     *
     * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
     * @param array $vars 需要单独返送的GET变量
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @param string/array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return unknown
     */
    public function post($url = '', $vars = array(), $header = array(), $cookie = '', $timeout = 5, $options = array(),$port=0) {
        $this->setUrl ( $url );      
        $this->setHeader ( $header );
        $this->setCookie ( $cookie );
        $this->setVar ( $vars );
        $this->setPort($port);
        return $this->send ('POST', $timeout );
    }
  
    /**
     * 发送HTTP请求核心函数
     *
     * @param string $method 使用GET还是 POST方式访问
     * @param array $vars 需要另外附加发送的GET/POST数据
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return string 返回服务器端读取的返回数据
     */
    private function send($method = 'GET', $timeout = 5, $options = array()) {
        //处理参数是否为空
        if ($this->uri == '') {
            throw new Exception ( __CLASS__ . ": Access url is empty" );
        }
        //处理GET请求参数
        if ($method == 'GET' && ! empty( $this->vars )) {
            $query = Http::makeQuery ( $this->vars );          
            $parse = parse_url ( $this->uri );
            $sep = isset ( $parse ['query'] ) && ($parse ['query'] != '') ? '&' : '?';
            $this->uri .= $sep . $query;          
        }
      
        //处理POST请求数据
        $data = '';
        if ($method == 'POST' && ! empty ( $this->vars )) {
            $data = Http::makeQuery ( $this->vars );
            $this->setHeader ( 'Content-Type: application/x-www-form-urlencoded' );
            $this->setHeader ( 'Content-Length: ' . strlen ( $data ) );
        }
      
        //解析URL地址
        $url = parse_url ( $this->uri );
        $host = $url ['host'];
        $port = isset ( $url ['port'] ) && ($url ['port'] != '') ? $url['port'] : 80;
        $path = isset ( $url ['path'] ) && ($url ['path'] != '') ? $url ['path'] : '/';
        $path .= isset ( $url ['query'] ) ? "?" . $url ['query'] : '';
      
        //设定指它的POR端口号
        if($this->port){
            $port = $this->port;
        }
      
        //组织HTTP请求头信息
        array_unshift ( &$this->header, $method . " " . $path . " HTTP/1.1" );
        $this->setHeader ( 'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; InfoPath.1)' );
        if (! preg_match ( "/^[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}$/", $host )) {
            $this->setHeader ( "Host: " . $host );
        }
        if ($this->cookies != '') {
            $this->setHeader ( "Cookie: " . $this->cookies );
        }
        $this->setHeader ( "Connection: Close" );
        //'Accept-Language: zh-cn',
        //'Cache-Control: no-cache',
      

        //构造请求信息
        $header = '';
        foreach ( $this->header as $h ) {
            $header .= $h . "\r\n";
        }
        $header .= "\r\n";
        if ($method == 'POST' && $data != '') {
            $header .= $data . "\r\n";
        }
      
        //连接服务器发送请求数据
        $ip = gethostbyname ( $host );
        if (! ($fp = fsockopen ( $ip, $port, $errno, $errstr, $timeout ))) {
            throw new Exception ( __CLASS__ . ": Can't connect $host:$port, errno:$errno,message:$errstr" );
        }
        fputs ( $fp, $header );
        $lineSize = 1024;
      
        //处理301,302跳转页面访问
        $line = fgets ( $fp);
        $first = preg_split ( "/\s/", trim ( $line ) );
        if (isset ( $first [1] ) && in_array ( $first [1], array ('301', '302' ) )) {
            while ( ! feof ( $fp ) ) {
                $line = fgets ( $fp, $lineSize );
                $second = preg_split ( "/\s/", trim ( $line ) );
                if (ucfirst ( trim ( $second [0] ) ) == 'Location:' && $second [1] != '') {
                    $this->header = array ();
                    return $this->get ( trim ( $second [1] ) );
                }
            }
        }
      
        //正常读取返回数据  
        $buf = '';
        $inheader = 1;
        while ( ! feof ( $fp ) ) {
            if ($inheader && ($line == "\n" || $line == "\r\n")) {
                $inheader = 0;
            }
            $line = fgets ( $fp, $lineSize );
            if ($inheader == 0) {
                $buf .= $line;              
            }
        }
        fclose ( $fp );
        return $buf;
      
    }

}

/**
* 使用文件流操作函数为核心操作的HTTP访问接口
*
* @desc stream_* 和 fopen/file_get_contents 是 PHP内置的一个流和文件操作接口，必须打开 fsockopen 函数本类才能工作，
* 同时确保其他相关网络环境和配置是正确的，包括 allow_url_fopen 等设置
*/
class Http_Stream {
  
    /**
     * @var object 对象单例
     */
    static $_instance = NULL;
  
    /**
     * @var string 需要发送的cookie信息
     */
    private $cookies = '';
    /**
     * @var array 需要发送的头信息
     */
    private $header = array ();
    /**
     * @var string 需要访问的URL地址
     */
    private $uri = '';
    /**
     * @var array 需要发送的数据
     */
    private $vars = array ();
  
    /**
     * 构造函数
     *
     * @param string $configFile 配置文件路径
     */
    private function __construct($url) {
        $this->uri = $url;
    }
  
    /**
     * 保证对象不被clone
     */
    private function __clone() {
    }
  
    /**
     * 获取对象唯一实例
     *
     * @param string $configFile 配置文件路径
     * @return object 返回本对象实例
     */
    public static function getInstance($url = '') {
        if (! (self::$_instance instanceof self)) {
            self::$_instance = new self ( $url );
        }
        return self::$_instance;
    }
  
    /**
     * 设置需要发送的HTTP头信息
     *
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @return void
     */
    private function setHeader($header) {
        if (empty ( $header )) {
            return;
        }
        if (is_array ( $header )) {
            foreach ( $header as $k => $v ) {
                $this->header [] = is_numeric ( $k ) ? trim ( $v ) : (trim ( $k ) . ": " . trim ( $v ));
            }
        } elseif (is_string ( $header )) {
            $this->header [] = $header;
        }
    }
  
    /**
     * 设置Cookie头信息
     *
     * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
     *
     * @param string/array 需要设置的 Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @return void
     */
    private function setCookie($cookie) {
        if (empty( $cookie )) {
            return;
        }
        if (is_array ( $cookie )) {
            $this->cookies = Http::makeQuery ( $cookie, ';' );
        } elseif (is_string ( $cookie )) {
            $this->cookies = $cookie;
        }
    }
  
    /**
     * 设置要发送的数据信息
     *
     * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
     *
     * @param array 设置需要发送的数据信息，一个类似于 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @return void
     */
    private function setVar($vars) {
        if (empty ( $vars )) {
            return;
        }
        if (is_array ( $vars )) {
            $this->vars = $vars;
        }
    }
  
    /**
     * 设置要请求的URL地址
     *
     * @param string $url 需要设置的URL地址
     * @return void
     */
    private function setUrl($url) {
        if ($url != '') {
            $this->uri = $url;
        }
    }
  
    /**
     * 发送HTTP GET请求
     *
     * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
     * @param array $vars 需要单独返送的GET变量
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @param string/array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return unknown
     */
    public function get($url = '', $vars = array(), $header = array(), $cookie = '', $timeout = 5, $options = array()) {
        $this->setUrl ( $url );
        $this->setHeader ( $header );
        $this->setCookie ( $cookie );
        $this->setVar ( $vars );
        return $this->send ( 'GET', $timeout );
    }
  
    /**
     * 发送HTTP POST请求
     *
     * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
     * @param array $vars 需要单独返送的GET变量
     * @param array/string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
     * 或单一的一条类似于 'Host: example.com' 头信息字符串
     * @param string/array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
     * 或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return unknown
     */
    public function post($url = '', $vars = array(), $header = array(), $cookie = '', $timeout = 5, $options = array()) {
        $this->setUrl ( $url );
        $this->setHeader ( $header );
        $this->setCookie ( $cookie );
        $this->setVar ( $vars );
        return $this->send ( 'POST', $timeout );
    }
  
    /**
     * 发送HTTP请求核心函数
     *
     * @param string $method 使用GET还是 POST方式访问
     * @param array $vars 需要另外附加发送的GET/POST数据
     * @param int $timeout 连接对方服务器访问超时时间，单位为秒
     * @param array $options 当前操作类一些特殊的属性设置
     * @return string 返回服务器端读取的返回数据
     */
    private function send($method = 'GET', $timeout = 5, $options = array()) {
        //处理参数是否为空
        if ($this->uri == '') {
            throw new Exception ( __CLASS__ . ": Access url is empty" );
        }
        $parse = parse_url ( $this->uri );
        $host = $parse ['host'];
      
        //处理GET请求参数
        if ($method == 'GET' && ! empty ( $this->vars )) {
            $query = Http::makeQuery ( $this->vars );
            $sep = isset ( $parse ['query'] ) && ($parse ['query'] != '') ? '&' : '?';
            $this->uri .= $sep . $query;
        }
      
        //处理POST请求数据
        $data = '';
        if ($method == 'POST' && ! empty ( $this->vars )) {
            $data = Http::makeQuery ( $this->vars );
        }
      
        //设置缺省头
        $this->setHeader ( 'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; InfoPath.1)' );
        if (! preg_match ( "/^[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}$/", $host )) {
            $this->setHeader ( "Host: " . $host );
        }
        if ($this->cookies != '') {
            $this->setHeader ( "Cookie: " . $this->cookies );
        }
        $this->setHeader ( "Connection: Close" );
        //'Accept-Language: zh-cn',
        //'Cache-Control: no-cache',        
      

        //构造头信息
        $opts = array ('http' => array ('method' => $method, 'timeout' => $timeout ) );
        if ($data != '') {
            $opts ['http'] ['content'] = $data;
        }
        $opts ['http'] ['header'] = '';
        foreach ( $this->header as $h ) {
            $opts ['http'] ['header'] .= $h . "\r\n";
        }
        //print_r($opts);exit;
      
        //读取扩展设置选项
        if (! empty( $options )) {
            isset ( $options ['proxy'] ) ? $opts ['http'] ['proxy'] = $options ['proxy'] : '';
            isset ( $options ['max_redirects'] ) ? $opts ['http'] ['max_redirects'] = $options ['max_redirects'] : '';
            isset ( $options ['request_fulluri'] ) ? $opts ['http'] ['request_fulluri'] = $options ['request_fulluri'] : '';
        }
      
        //发送数据返回
        $context = stream_context_create ( $opts );
        if (($buf = file_get_contents ( $this->uri, null, $context )) === false) {
            throw new Exception ( __CLASS__ . ": file_get_contents(" . $this->uri . ") fail" );
        }
      
        return $buf;
    }

}
?>

虽然看不懂，但是无比崇拜您

偶也看不懂，拷贝一份看看

    

kankan

复制了

怎么会看不懂呢，这段代码很好懂的啊，不懂的加直接加我。

顶啦！！！！！！！！！！

支持

路过,无比崇拜

我根本看不懂