PHP封装的HttpClient类用法实例

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

本文实例讲述了PHP封装的HttpClient类。分享给大家供大家参考。具体分析如下：

这是一段php封装的HttpClient类，可实现GET POST Cookie Session等简单的功能。原来做过，这两天重新修改了一下。

name = trim(substr($s, 0, $i1));       $this->value = trim(substr($s, $i1 +1, $i2 - $i1 -1));     }   }   // 获取Cookie键值对   function getKeyValue() {     return "$this->name=$this->value";   } } // 会话上下文 class SinHttpContext {   public $cookies; // 会话Cookies   public $referer; // 前一个页面地址   function __construct() {     $this->cookies = array ();     $this->refrer = "";   }   // 设置Cookie   function cookie($key, $val) {     $ck = new SinCookie();     $ck->name = $key;     $ck->value = $val;     $this->addCookie($ck);   }   // 添加Cookie   function addCookie($ck) {     $this->cookies[$ck->name] = $ck;   }   // 获取Cookies字串，请求时用到   function cookiesString() {     $res = '';     foreach ($this->cookies as $ck) {       $res .= $ck->getKeyValue() . ';';     }     return $res;   } } // Http请求对象 class SinHttpRequest {   public $url; // 请求地址   public $method = 'GET'; // 请求方法   public $host; // 主机   public $path; // 路径   public $scheme; // 协议，http   public $port; // 端口   public $header; // 请求头   public $body; // 请求正文   // 设置头   function setHeader($k, $v) {     if (!isset ($this->header)) {       $this->header = array ();     }     $this->header[$k] = $v;   }   // 获取请求字符串   // 包含头和请求正文   // 获取之后直接写socket就行   function reqString() {     $matches = parse_url($this->url);     !isset ($matches['host']) && $matches['host'] = '';     !isset ($matches['path']) && $matches['path'] = '';     !isset ($matches['query']) && $matches['query'] = '';     !isset ($matches['port']) && $matches['port'] = '';     $host = $matches['host'];     $path = $matches['path'] ? $matches['path'] . ($matches['query'] ? '?' . $matches['query'] : '') : '/';     $port = !empty ($matches['port']) ? $matches['port'] : 80;     $scheme = $matches['scheme'] ? $matches['scheme'] : 'http';     $this->host = $host;     $this->path = $path;     $this->scheme = $scheme;     $this->port = $port;     $method = strtoupper($this->method);     $res = "$method $path HTTP/1.1\r\n";     $res .= "Host: $host\r\n";     if ($this->header) {       reset($this->header);       while (list ($k, $v) = each($this->header)) {         if (isset ($v) && strlen($v) > 0)           $res .= "$k: $v\r\n";       }     }     $res .= "\r\n";     if ($this->body) {       $res .= $this->body;       $res .= "\r\n\r\n";     }     return $res;   } } // Http响应 class SinHttpResponse {   public $scheme; // 协议   public $stasus; // 状态，成功的时候是ok   public $code; // 状态码，成功的时候是200   public $header; // 响应头   public $body; // 响应正文   function __construct() {     $this->header = array ();     $this->body = null;   }   function setHeader($key, $val) {     $this->header[$key] = $val;   } } // HttpClient class SinHttpClient {   public $keepcontext = true; // 是否维持会话   public $context; // 上下文   public $request; // 请求   public $response; // 响应   public $debug = false;  // 是否在Debug模式，  //为true的时候会打印出请求内容和相同的头部   function __construct() {     $this->request = new SinHttpRequest();     $this->response = new SinHttpResponse();     $this->context = new SinHttpContext();     $this->timeout = 15; // 默认的超时为15s   }   // 清除上一次的请求内容   function clearRequest() {     $this->request->body = '';     $this->request->setHeader('Content-Length', false);     $this->request->setHeader('Content-Type', false);   }   // post方法   // data为请求的数据   // 为键值对的时候模拟表单提交   // 其他时候为数据提交，提交的形式为xml   // 如有其他需求，请自行扩展   function post($url, $data = false) {     $this->clearRequest();     if ($data) {       if (is_array($data)) {         $con = http_build_query($data);         $this->request->setHeader('Content-Type', 'application/x-www-form-urlencoded');       } else {         $con = $data;         $this->request->setHeader('Content-Type', 'text/xml; ');       }       $this->request->body = $con;       $this->request->method = "POST";       $this->request->setHeader('Content-Length', strlen($con));     }     $this->startRequest($url);   }   // get方法   function get($url) {     $this->clearRequest();     $this->request->method = "GET";     $this->startRequest($url);   }   // 该方法为内部调用方法，不用直接调用   function startRequest($url) {     $this->request->url = $url;     if ($this->keepcontext) {       // 如果保存上下文的话设置相关信息       $this->request->setHeader('Referer', $this->context->refrer);       $cks = $this->context->cookiesString();       if (strlen($cks) > 0)         $this->request->setHeader('Cookie', $cks);     }     // 获取请求内容     $reqstring = $this->request->reqString();     if ($this->debug)       echo "Request:\n$reqstring\n";     try {       $fp = fsockopen($this->request->host, $this->request->port, $errno, $errstr, $this->timeout);     } catch (Exception $ex) {       echo $ex->getMessage();       exit (0);     }     if ($fp) {       stream_set_blocking($fp, true);       stream_set_timeout($fp, $this->timeout);       // 写数据       fwrite($fp, $reqstring);       $status = stream_get_meta_data($fp);       if (!$status['timed_out']) { //未超时         // 下面的循环用来读取响应头部         while (!feof($fp)) {           $h = fgets($fp);           if ($this->debug) echo $h;           if ($h && ($h == "\r\n" || $h == "\n")) break;           $pos = strpos($h, ':');           if ($pos) { $k = strtolower(trim(substr($h, 0, $pos))); $v = trim(substr($h, $pos +1)); if ($k == 'set-cookie') {   // 更新Cookie   if ($this->keepcontext) {     $this->context->addCookie(new SinCookie($v));   } } else {   // 添加到头里面去   $this->response->setHeader($k, $v); }           } else { // 第一行数据 // 解析响应状态 $preg = '/^(\S*) (\S*) (.*)$/'; preg_match_all($preg, $h, $arr); isset ($arr[1][0]) & $this->response->scheme = trim($arr[1][0]); isset ($arr[2][0]) & $this->response->stasus = trim($arr[2][0]); isset ($arr[3][0]) & $this->response->code = trim($arr[3][0]);           }         }         // 获取响应正文长度         $len = (int) $this->response->header['content-length'];         $res = '';         // 下面的循环读取正文         while (!feof($fp) && $len > 0) {           $c = fread($fp, $len);           $res .= $c;           $len -= strlen($c);         }         $this->response->body = $res;       }       // 关闭Socket       fclose($fp);       // 把返回保存到上下文维持中       $this->context->refrer = $url;     }   } } // demo // now let begin test it $client = new SinHttpClient(); // create a client $client->get('http://www.baidu.com/');  // get echo $client->response->body; // echo ?>

希望本文所述对大家的php程序设计有所帮助。

您可能感兴趣的文章:

• httpclient模拟post请求json封装表单数据的实现方法
• Android中HttpURLConnection与HttpClient的使用与封装
• 完成OSS.Http底层HttpClient重构封装 支持标准库