[关闭]
@a5635268 2015-10-10T17:44:02.000000Z 字数 16638 阅读 1077

【PHPsocket编程专题(实战篇②)】兼容 Curl/Socket/Stream 的 HTTP 操作类

PHP

  1. <?php
  2. /************************************************************
  3.  *  描述：HTTP操作类
  4.  *  作者：heiyeluren
  5.  *  创建：2009/12/13 04:43
  6.  *  修改：2009/12/16 10:30  实现基本HTTP各种接口操作支持
  7.  ************************************************************/
  9. /**
  10.  * HTTP功能工厂方法类
  11.  * 调用示例代码：
  12.  * try {
  13.  * $http = Http::factory('http://www.baidu.com', Http::TYPE_SOCK );
  14.  * echo $http->get();
  15.  * $http = Http::factory('http://127.0.0.1/test/i.php', Http::TYPE_SOCK );
  16.  * echo $http->post('', array('user'=>'我们', 'nick'=>'ASSADF@#!32812989+-239%ASDF'), '', array('aa'=>'bb', 'cc'=>'dd'));
  17.  * } catch (Exception $e) {
  18.  * echo $e->getMessage();
  19.  * }
  20.  */
  21. class Http{
  22.   /**
  23.    * @var 使用 CURL
  24.    */
  25.   const TYPE_CURL = 1;
  26.   /**
  27.    * @var 使用 Socket
  28.    */
  29.   const TYPE_SOCK = 2;
  30.   /**
  31.    * @var 使用 Stream
  32.    */
  33.   const TYPE_STREAM = 3;
  35.   /**
  36.    * 保证对象不被clone
  37.    */
  38.   private function __clone(){
  39.   }
  41.   /**
  42.    * 构造函数
  43.    */
  44.   private function __construct(){
  45.   }
  47.   /**
  48.    * HTTP工厂操作方法
  49.    * @param string $url 需要访问的URL
  50.    * @param int $type 需要使用的HTTP类
  51.    * @return object
  52.    */
  53.   public static function factory($url = '' , $type = self::TYPE_SOCK){
  54.     if ($type == '') {
  55.       $type = self::TYPE_SOCK;
  56.     }
  57.     switch ($type) {
  58.       case self::TYPE_CURL :
  59.         if (!function_exists('curl_init')) {
  60.           throw new Exception(__CLASS__ . " PHP CURL extension not install");
  61.         }
  62.         $obj = Http_Curl::getInstance($url);
  63.         break;
  64.       case self::TYPE_SOCK :
  65.         if (!function_exists('fsockopen')) {
  66.           throw new Exception(__CLASS__ . " PHP function fsockopen() not support");
  67.         }
  68.         $obj = Http_Sock::getInstance($url);
  69.         break;
  70.       case self::TYPE_STREAM :
  71.         if (!function_exists('stream_context_create')) {
  72.           throw new Exception(__CLASS__ . " PHP Stream extension not install");
  73.         }
  74.         $obj = Http_Stream::getInstance($url);
  75.         break;
  76.       default:
  77.         throw new Exception("http access type $type not support");
  78.     }
  79.     return $obj;
  80.   }
  82.   /**
  83.    * 生成一个供Cookie或HTTP GET Query的字符串
  84.    * @param array $data 需要生产的数据数组，必须是 Name => Value 结构
  85.    * @param string $sep 两个变量值之间分割的字符，缺省是 &
  86.    * @return string 返回生成好的Cookie查询字符串
  87.    */
  88.   public static function makeQuery($data , $sep = '&'){
  89.     $encoded = '';
  90.     while (list($k , $v) = each($data)) {
  91.       $encoded .= ($encoded ? "$sep" : "");
  92.       $encoded .= rawurlencode($k) . "=" . rawurlencode($v);
  93.     }
  94.     return $encoded;
  95.   }
  96. }
  98. /**
  99.  * 使用CURL 作为核心操作的HTTP访问类
  100.  * @desc CURL 以稳定、高效、移植性强作为很重要的HTTP协议访问客户端，必须在PHP中安装 CURL 扩展才能使用本功能
  101.  */
  102. class Http_Curl{
  103.   /**
  104.    * @var object 对象单例
  105.    */
  106.   static $_instance = NULL;
  107.   /**
  108.    * @var string 需要发送的cookie信息
  109.    */
  110.   private $cookies = '';
  111.   /**
  112.    * @var array 需要发送的头信息
  113.    */
  114.   private $header = array();
  115.   /**
  116.    * @var string 需要访问的URL地址
  117.    */
  118.   private $uri = '';
  119.   /**
  120.    * @var array 需要发送的数据
  121.    */
  122.   private $vars = array();
  124.   /**
  125.    * 构造函数
  126.    * @param string $configFile 配置文件路径
  127.    */
  128.   private function __construct($url){
  129.     $this->uri = $url;
  130.   }
  132.   /**
  133.    * 保证对象不被clone
  134.    */
  135.   private function __clone(){
  136.   }
  138.   /**
  139.    * 获取对象唯一实例
  140.    * @param string $configFile 配置文件路径
  141.    * @return object 返回本对象实例
  142.    */
  143.   public static function getInstance($url = ''){
  144.     if (!(self::$_instance instanceof self)) {
  145.       self::$_instance = new self($url);
  146.     }
  147.     return self::$_instance;
  148.   }
  150.   /**
  151.    * 设置需要发送的HTTP头信息
  152.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  153.    *       或单一的一条类似于 'Host: example.com' 头信息字符串
  154.    * @return void
  155.    */
  156.   public function setHeader($header){
  157.     if (emptyempty($header)) {
  158.       return;
  159.     }
  160.     if (is_array($header)) {
  161.       foreach ($header as $k => $v) {
  162.         $this->header[] = is_numeric($k) ? trim($v) : (trim($k) . ": " . trim($v));
  163.       }
  164.     } elseif (is_string($header)) {
  165.       $this->header[] = $header;
  166.     }
  167.   }
  169.   /**
  170.    * 设置Cookie头信息
  171.    * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
  172.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  173.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  174.    * @return void
  175.    */
  176.   public function setCookie($cookie){
  177.     if (emptyempty($cookie)) {
  178.       return;
  179.     }
  180.     if (is_array($cookie)) {
  181.       $this->cookies = Http::makeQuery($cookie , ';');
  182.     } elseif (is_string($cookie)) {
  183.       $this->cookies = $cookie;
  184.     }
  185.   }
  187.   /**
  188.    * 设置要发送的数据信息
  189.    * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
  190.    * @param array 设置需要发送的数据信息，一个类似于 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  191.    * @return void
  192.    */
  193.   public function setVar($vars){
  194.     if (emptyempty($vars)) {
  195.       return;
  196.     }
  197.     if (is_array($vars)) {
  198.       $this->vars = $vars;
  199.     }
  200.   }
  202.   /**
  203.    * 设置要请求的URL地址
  204.    * @param string $url 需要设置的URL地址
  205.    * @return void
  206.    */
  207.   public function setUrl($url){
  208.     if ($url != '') {
  209.       $this->uri = $url;
  210.     }
  211.   }
  213.   /**
  214.    * 发送HTTP GET请求
  215.    * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
  216.    * @param array $vars 需要单独返送的GET变量
  217.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  218.    *         或单一的一条类似于 'Host: example.com' 头信息字符串
  219.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  220.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  221.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  222.    * @param array $options 当前操作类一些特殊的属性设置
  223.    * @return unknown
  224.    */
  225.   public function get($url = '' , $vars = array() , $header = array() , $cookie = '' , $timeout = 5 , $options = array()){
  226.     $this->setUrl($url);
  227.     $this->setHeader($header);
  228.     $this->setCookie($cookie);
  229.     $this->setVar($vars);
  230.     return $this->send('GET' , $timeout);
  231.   }
  233.   /**
  234.    * 发送HTTP POST请求
  235.    * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
  236.    * @param array $vars 需要单独返送的GET变量
  237.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  238.    *         或单一的一条类似于 'Host: example.com' 头信息字符串
  239.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  240.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  241.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  242.    * @param array $options 当前操作类一些特殊的属性设置
  243.    * @return unknown
  244.    */
  245.   public function post($url = '' , $vars = array() , $header = array() , $cookie = '' , $timeout = 5 , $options = array()){
  246.     $this->setUrl($url);
  247.     $this->setHeader($header);
  248.     $this->setCookie($cookie);
  249.     $this->setVar($vars);
  250.     return $this->send('POST' , $timeout);
  251.   }
  253.   /**
  254.    * 发送HTTP请求核心函数
  255.    * @param string $method 使用GET还是POST方式访问
  256.    * @param array $vars 需要另外附加发送的GET/POST数据
  257.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  258.    * @param array $options 当前操作类一些特殊的属性设置
  259.    * @return string 返回服务器端读取的返回数据
  260.    */
  261.   public function send($method = 'GET' , $timeout = 5 , $options = array()){
  262.     //处理参数是否为空   
  263.     if ($this->uri == '') {
  264.       throw new Exception(__CLASS__ . ": Access url is empty");
  265.     }
  266.     //初始化CURL   
  267.     $ch = curl_init();
  268.     curl_setopt($ch , CURLOPT_HEADER , 0);
  269.     curl_setopt($ch , CURLOPT_FOLLOWLOCATION , 1);
  270.     curl_setopt($ch , CURLOPT_RETURNTRANSFER , 1);
  271.     curl_setopt($ch , CURLOPT_TIMEOUT , $timeout);
  272.     //设置特殊属性   
  273.     if (!emptyempty($options)) {
  274.       curl_setopt_array($ch , $options);
  275.     }
  276.     //处理GET请求参数   
  277.     if ($method == 'GET' && !emptyempty($this->vars)) {
  278.       $query = Http::makeQuery($this->vars);
  279.       $parse = parse_url($this->uri);
  280.       $sep = isset($parse['query']) ? '&' : '?';
  281.       $this->uri .= $sep . $query;
  282.     }
  283.     //处理POST请求数据   
  284.     if ($method == 'POST') {
  285.       curl_setopt($ch , CURLOPT_POST , 1);
  286.       curl_setopt($ch , CURLOPT_POSTFIELDS , $this->vars);
  287.     }
  288.     //设置cookie信息   
  289.     if (!emptyempty($this->cookies)) {
  290.       curl_setopt($ch , CURLOPT_COOKIE , $this->cookies);
  291.     }
  292.     //设置HTTP缺省头   
  293.     if (emptyempty($this->header)) {
  294.       $this->header = array('User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; InfoPath.1)' , //'Accept-Language: zh-cn',             
  295.         //'Cache-Control: no-cache',   
  296.       );
  297.     }
  298.     curl_setopt($ch , CURLOPT_HTTPHEADER , $this->header);
  299.     //发送请求读取输数据   
  300.     curl_setopt($ch , CURLOPT_URL , $this->uri);
  301.     $data = curl_exec($ch);
  302.     if (($err = curl_error($ch))) {
  303.       curl_close($ch);
  304.       throw new  Exception(__CLASS__ . " error: " . $err);
  305.     }
  306.     curl_close($ch);
  307.     return $data;
  308.   }
  309. }
  311. /**
  312.  * 使用 Socket操作(fsockopen) 作为核心操作的HTTP访问接口
  313.  * @desc Network/fsockopen 是PHP内置的一个Sokcet网络访问接口，必须安装/打开 fsockopen 函数本类才能工作，
  314.  *    同时确保其他相关网络环境和配置是正确的
  315.  */
  316. class Http_Sock{
  317.   /**
  318.    * @var object 对象单例
  319.    */
  320.   static $_instance = NULL;
  321.   /**
  322.    * @var string 需要发送的cookie信息
  323.    */
  324.   private $cookies = '';
  325.   /**
  326.    * @var array 需要发送的头信息
  327.    */
  328.   private $header = array();
  329.   /**
  330.    * @var string 需要访问的URL地址
  331.    */
  332.   private $uri = '';
  333.   /**
  334.    * @var array 需要发送的数据
  335.    */
  336.   private $vars = array();
  338.   /**
  339.    * 构造函数
  340.    * @param string $configFile 配置文件路径
  341.    */
  342.   private function __construct($url){
  343.     $this->uri = $url;
  344.   }
  346.   /**
  347.    * 保证对象不被clone
  348.    */
  349.   private function __clone(){
  350.   }
  352.   /**
  353.    * 获取对象唯一实例
  354.    * @param string $configFile 配置文件路径
  355.    * @return object 返回本对象实例
  356.    */
  357.   public static function getInstance($url = ''){
  358.     if (!(self::$_instance instanceof self)) {
  359.       self::$_instance = new self($url);
  360.     }
  361.     return self::$_instance;
  362.   }
  364.   /**
  365.    * 设置需要发送的HTTP头信息
  366.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  367.    *       或单一的一条类似于 'Host: example.com' 头信息字符串
  368.    * @return void
  369.    */
  370.   public function setHeader($header){
  371.     if (emptyempty($header)) {
  372.       return;
  373.     }
  374.     if (is_array($header)) {
  375.       foreach ($header as $k => $v) {
  376.         $this->header[] = is_numeric($k) ? trim($v) : (trim($k) . ": " . trim($v));
  377.       }
  378.     } elseif (is_string($header)) {
  379.       $this->header[] = $header;
  380.     }
  381.   }
  383.   /**
  384.    * 设置Cookie头信息
  385.    * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
  386.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  387.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  388.    * @return void
  389.    */
  390.   public function setCookie($cookie){
  391.     if (emptyempty($cookie)) {
  392.       return;
  393.     }
  394.     if (is_array($cookie)) {
  395.       $this->cookies = Http::makeQuery($cookie , ';');
  396.     } elseif (is_string($cookie)) {
  397.       $this->cookies = $cookie;
  398.     }
  399.   }
  401.   /**
  402.    * 设置要发送的数据信息
  403.    * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
  404.    * @param array 设置需要发送的数据信息，一个类似于 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  405.    * @return void
  406.    */
  407.   public function setVar($vars){
  408.     if (emptyempty($vars)) {
  409.       return;
  410.     }
  411.     if (is_array($vars)) {
  412.       $this->vars = $vars;
  413.     }
  414.   }
  416.   /**
  417.    * 设置要请求的URL地址
  418.    * @param string $url 需要设置的URL地址
  419.    * @return void
  420.    */
  421.   public function setUrl($url){
  422.     if ($url != '') {
  423.       $this->uri = $url;
  424.     }
  425.   }
  427.   /**
  428.    * 发送HTTP GET请求
  429.    * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
  430.    * @param array $vars 需要单独返送的GET变量
  431.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  432.    *         或单一的一条类似于 'Host: example.com' 头信息字符串
  433.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  434.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  435.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  436.    * @param array $options 当前操作类一些特殊的属性设置
  437.    * @return unknown
  438.    */
  439.   public function get($url = '' , $vars = array() , $header = array() , $cookie = '' , $timeout = 5 , $options = array()){
  440.     $this->setUrl($url);
  441.     $this->setHeader($header);
  442.     $this->setCookie($cookie);
  443.     $this->setVar($vars);
  444.     return $this->send('GET' , $timeout);
  445.   }
  447.   /**
  448.    * 发送HTTP POST请求
  449.    * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
  450.    * @param array $vars 需要单独返送的GET变量
  451.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  452.    *         或单一的一条类似于 'Host: example.com' 头信息字符串
  453.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  454.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  455.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  456.    * @param array $options 当前操作类一些特殊的属性设置
  457.    * @return unknown
  458.    */
  459.   public function post($url = '' , $vars = array() , $header = array() , $cookie = '' , $timeout = 5 , $options = array()){
  460.     $this->setUrl($url);
  461.     $this->setHeader($header);
  462.     $this->setCookie($cookie);
  463.     $this->setVar($vars);
  464.     return $this->send('POST' , $timeout);
  465.   }
  467.   /**
  468.    * 发送HTTP请求核心函数
  469.    * @param string $method 使用GET还是POST方式访问
  470.    * @param array $vars 需要另外附加发送的GET/POST数据
  471.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  472.    * @param array $options 当前操作类一些特殊的属性设置
  473.    * @return string 返回服务器端读取的返回数据
  474.    */
  475.   public function send($method = 'GET' , $timeout = 5 , $options = array()){
  476.     //处理参数是否为空   
  477.     if ($this->uri == '') {
  478.       throw new Exception(__CLASS__ . ": Access url is empty");
  479.     }
  480.     //处理GET请求参数   
  481.     if ($method == 'GET' && !emptyempty($this->vars)) {
  482.       $query = Http::makeQuery($this->vars);
  483.       $parse = parse_url($this->uri);
  484.       $sep = isset($parse['query']) && ($parse['query'] != '') ? '&' : '?';
  485.       $this->uri .= $sep . $query;
  486.     }
  487.     //处理POST请求数据   
  488.     $data = '';
  489.     if ($method == 'POST' && !emptyempty($this->vars)) {
  490.       $data = Http::makeQuery($this->vars);
  491.       $this->setHeader('Content-Type: application/x-www-form-urlencoded');
  492.       $this->setHeader('Content-Length: ' . strlen($data));
  493.     }
  494.     //解析URL地址   
  495.     $url = parse_url($this->uri);
  496.     $host = $url['host'];
  497.     $port = isset($url['port']) && ($url['port'] != '') ? $url['port'] : 80;
  498.     $path = isset($url['path']) && ($url['path'] != '') ? $url['path'] : '/';
  499.     $path .= isset($url['query']) ? "?" . $url['query'] : '';
  500.     //组织HTTP请求头信息   
  501.     array_unshift(&$this->header , $method . " " . $path . " HTTP/1.1");
  502.     $this->setHeader('User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; InfoPath.1)');
  503.     if (!preg_match("/^[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}$/" , $host)) {
  504.       $this->setHeader("Host: " . $host);
  505.     }
  506.     if ($this->cookies != '') {
  507.       $this->setHeader("Cookie: " . $this->cookies);
  508.     }
  509.     $this->setHeader("Connection: Close");
  510.     //'Accept-Language: zh-cn',   
  511.     //'Cache-Control: no-cache',   
  512.     //构造请求信息   
  513.     $header = '';
  514.     foreach ($this->header as $h) {
  515.       $header .= $h . "\r\n";
  516.     }
  517.     $header .= "\r\n";
  518.     if ($method == 'POST' && $data != '') {
  519.       $header .= $data . "\r\n";
  520.     }
  521.     //连接服务器发送请求数据   
  522.     $ip = gethostbyname($host);
  523.     if (!($fp = fsockopen($ip , $port , &$errno , &$errstr , $timeout))) {
  524.       throw new Exception(__CLASS__ . ": Can't connect $host:$port, errno:$errno,message:$errstr");
  525.     }
  526.     fputs($fp , $header);
  527.     $lineSize = 1024;
  528.     //处理301,302跳转页面访问   
  529.     $line = fgets($fp , $lineSize);
  530.     $first = preg_split("/\s/" , trim($line));
  531.     if (isset($first[1]) && in_array($first[1] , array('301' , '302'))) {
  532.       while (!feof($fp)) {
  533.         $line = fgets($fp , $lineSize);
  534.         $second = preg_split("/\s/" , trim($line));
  535.         if (ucfirst(trim($second[0])) == 'Location:' && $second[1] != '') {
  536.           $this->header = array();
  537.           return $this->get(trim($second[1]));
  538.         }
  539.       }
  540.     }
  541.     //正常读取返回数据     
  542.     $buf = '';
  543.     $inheader = 1;
  544.     while (!feof($fp)) {
  545.       if ($inheader && ($line == "\n" || $line == "\r\n")) {
  546.         $inheader = 0;
  547.       }
  548.       $line = fgets($fp , $lineSize);
  549.       if ($inheader == 0) {
  550.         $buf .= $line;
  551.       }
  552.     }
  553.     fclose($fp);
  554.     return $buf;
  555.   }
  556. }
  558. /**
  559.  * 使用文件流操作函数为核心操作的HTTP访问接口
  560.  * @desc stream_* 和 fopen/file_get_contents 是PHP内置的一个流和文件操作接口，必须打开 fsockopen 函数本类才能工作，
  561.  *    同时确保其他相关网络环境和配置是正确的，包括 allow_url_fopen 等设置
  562.  */
  563. class Http_Stream{
  564.   /**
  565.    * @var object 对象单例
  566.    */
  567.   static $_instance = NULL;
  568.   /**
  569.    * @var string 需要发送的cookie信息
  570.    */
  571.   private $cookies = '';
  572.   /**
  573.    * @var array 需要发送的头信息
  574.    */
  575.   private $header = array();
  576.   /**
  577.    * @var string 需要访问的URL地址
  578.    */
  579.   private $uri = '';
  580.   /**
  581.    * @var array 需要发送的数据
  582.    */
  583.   private $vars = array();
  585.   /**
  586.    * 构造函数
  587.    * @param string $configFile 配置文件路径
  588.    */
  589.   private function __construct($url){
  590.     $this->uri = $url;
  591.   }
  593.   /**
  594.    * 保证对象不被clone
  595.    */
  596.   private function __clone(){
  597.   }
  599.   /**
  600.    * 获取对象唯一实例
  601.    * @param string $configFile 配置文件路径
  602.    * @return object 返回本对象实例
  603.    */
  604.   public static function getInstance($url = ''){
  605.     if (!(self::$_instance instanceof self)) {
  606.       self::$_instance = new self($url);
  607.     }
  608.     return self::$_instance;
  609.   }
  611.   /**
  612.    * 设置需要发送的HTTP头信息
  613.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  614.    *       或单一的一条类似于 'Host: example.com' 头信息字符串
  615.    * @return void
  616.    */
  617.   public function setHeader($header){
  618.     if (emptyempty($header)) {
  619.       return;
  620.     }
  621.     if (is_array($header)) {
  622.       foreach ($header as $k => $v) {
  623.         $this->header[] = is_numeric($k) ? trim($v) : (trim($k) . ": " . trim($v));
  624.       }
  625.     } elseif (is_string($header)) {
  626.       $this->header[] = $header;
  627.     }
  628.   }
  630.   /**
  631.    * 设置Cookie头信息
  632.    * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
  633.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  634.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  635.    * @return void
  636.    */
  637.   public function setCookie($cookie){
  638.     if (emptyempty($cookie)) {
  639.       return;
  640.     }
  641.     if (is_array($cookie)) {
  642.       $this->cookies = Http::makeQuery($cookie , ';');
  643.     } elseif (is_string($cookie)) {
  644.       $this->cookies = $cookie;
  645.     }
  646.   }
  648.   /**
  649.    * 设置要发送的数据信息
  650.    * 注意：本函数只能调用一次，下次调用会覆盖上一次的设置
  651.    * @param array 设置需要发送的数据信息，一个类似于 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  652.    * @return void
  653.    */
  654.   public function setVar($vars){
  655.     if (emptyempty($vars)) {
  656.       return;
  657.     }
  658.     if (is_array($vars)) {
  659.       $this->vars = $vars;
  660.     }
  661.   }
  663.   /**
  664.    * 设置要请求的URL地址
  665.    * @param string $url 需要设置的URL地址
  666.    * @return void
  667.    */
  668.   public function setUrl($url){
  669.     if ($url != '') {
  670.       $this->uri = $url;
  671.     }
  672.   }
  674.   /**
  675.    * 发送HTTP GET请求
  676.    * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
  677.    * @param array $vars 需要单独返送的GET变量
  678.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  679.    *         或单一的一条类似于 'Host: example.com' 头信息字符串
  680.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  681.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  682.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  683.    * @param array $options 当前操作类一些特殊的属性设置
  684.    * @return unknown
  685.    */
  686.   public function get($url = '' , $vars = array() , $header = array() , $cookie = '' , $timeout = 5 , $options = array()){
  687.     $this->setUrl($url);
  688.     $this->setHeader($header);
  689.     $this->setCookie($cookie);
  690.     $this->setVar($vars);
  691.     return $this->send('GET' , $timeout);
  692.   }
  694.   /**
  695.    * 发送HTTP POST请求
  696.    * @param string $url 如果初始化对象的时候没有设置或者要设置不同的访问URL，可以传本参数
  697.    * @param array $vars 需要单独返送的GET变量
  698.    * @param array /string 需要设置的头信息，可以是一个 类似 array('Host: example.com', 'Accept-Language: zh-cn') 的头信息数组
  699.    *         或单一的一条类似于 'Host: example.com' 头信息字符串
  700.    * @param string /array 需要设置的Cookie信息，一个类似于 'name1=value1&name2=value2' 的Cookie字符串信息，
  701.    *         或者是一个 array('name1'=>'value1', 'name2'=>'value2') 的一维数组
  702.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  703.    * @param array $options 当前操作类一些特殊的属性设置
  704.    * @return unknown
  705.    */
  706.   public function post($url = '' , $vars = array() , $header = array() , $cookie = '' , $timeout = 5 , $options = array()){
  707.     $this->setUrl($url);
  708.     $this->setHeader($header);
  709.     $this->setCookie($cookie);
  710.     $this->setVar($vars);
  711.     return $this->send('POST' , $timeout);
  712.   }
  714.   /**
  715.    * 发送HTTP请求核心函数
  716.    * @param string $method 使用GET还是POST方式访问
  717.    * @param array $vars 需要另外附加发送的GET/POST数据
  718.    * @param int $timeout 连接对方服务器访问超时时间，单位为秒
  719.    * @param array $options 当前操作类一些特殊的属性设置
  720.    * @return string 返回服务器端读取的返回数据
  721.    */
  722.   public function send($method = 'GET' , $timeout = 5 , $options = array()){
  723.     //处理参数是否为空   
  724.     if ($this->uri == '') {
  725.       throw new Exception(__CLASS__ . ": Access url is empty");
  726.     }
  727.     $parse = parse_url($this->uri);
  728.     $host = $parse['host'];
  729.     //处理GET请求参数   
  730.     if ($method == 'GET' && !emptyempty($this->vars)) {
  731.       $query = Http::makeQuery($this->vars);
  732.       $sep = isset($parse['query']) && ($parse['query'] != '') ? '&' : '?';
  733.       $this->uri .= $sep . $query;
  734.     }
  735.     //处理POST请求数据   
  736.     $data = '';
  737.     if ($method == 'POST' && !emptyempty($this->vars)) {
  738.       $data = Http::makeQuery($this->vars);
  739.     }
  740.     //设置缺省头   
  741.     $this->setHeader('User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; InfoPath.1)');
  742.     if (!preg_match("/^[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}\.[\d]{1,3}$/" , $host)) {
  743.       $this->setHeader("Host: " . $host);
  744.     }
  745.     if ($this->cookies != '') {
  746.       $this->setHeader("Cookie: " . $this->cookies);
  747.     }
  748.     $this->setHeader("Connection: Close");
  749.     //'Accept-Language: zh-cn',   
  750.     //'Cache-Control: no-cache',           
  751.     //构造头信息   
  752.     $opts = array('http' => array('method' => $method , 'timeout' => $timeout ,));
  753.     if ($data != '') {
  754.       $opts['http']['content'] = $data;
  755.     }
  756.     $opts['http']['header'] = '';
  757.     foreach ($this->header as $h) {
  758.       $opts['http']['header'] .= $h . "\r\n";
  759.     }
  760.     //print_r($opts);exit;   
  761.     //读取扩展设置选项   
  762.     if (!emptyempty($options)) {
  763.       isset($options['proxy']) ? $opts['http']['proxy'] = $options['proxy'] : '';
  764.       isset($options['max_redirects']) ? $opts['http']['max_redirects'] = $options['max_redirects'] : '';
  765.       isset($options['request_fulluri']) ? $opts['http']['request_fulluri'] = $options['request_fulluri'] : '';
  766.     }
  767.     //发送数据返回   
  768.     $context = stream_context_create($opts);
  769.     if (($buf = file_get_contents($this->uri , null , $context)) === false) {
  770.       throw new Exception(__CLASS__ . ": file_get_contents(" . $this->uri . ") fail");
  771.     }
  772.     return $buf;
  773.   }
  774. }
添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注