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