PHP HttpClient封装

php封装的HttpClient，能实现些简单的功能。原来做过，这两天重新修改了一下。  

  <?php

 
                 /*
                  * Filename: httpclient.php Created on 2012-12-21 Created by RobinTang To change the template for this generated file go to Window - Preferences - PHPeclipse - PHP - Code Templates
                  */
                 class SinCookie {
                     public $name; // Cookie名称
                     public $value; // Cookie值
 
                     // 下面三个属性现在未实现
                     public $expires; // 过期时间
                     public $path; // 路径
                     public $domain; // 域
 
                     // 从Cookie字符串创建一个Cookie对象
                     function __construct($s = false) {
                         if ($s) {
                             $i1 = strpos ( $s, '=' );
                             $i2 = strpos ( $s, ';' );
                             $this->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; charset=utf-8' );
                             }
                             $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://qzone.qq.com/' ); // get
 
                 $body = $client->response->body;
                 echo $body; // echo
                 ?>