`
willko
  • 浏览: 386725 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

仅供参考, cURL 二次封装的类库 Curl_Manager

    博客分类:
  • php
阅读更多
cURL是一个可以在命令行下发起http请求的工具,phpl有调用ibcurl的适配器(adapter),所以在php里可以很方便的使用这个工具。

在使用cURL的过程中是否觉得难以使用,选项太多,没有封装,使用不够方便?

为了方便使用,我对php的cURL进行了二次封装,基于组合模式,使用灵活,能满足多数应用场景,经过我长期的实践。

  • 支持 ssl/proxy
  • 支持 cookie,会记录所有请求的cookie并带上(如需获得cookie的值,需要自己解析)
  • 支持常见请求方法get/post/put/delete 等等RESTFul所需要的方法
  • 支持文件上传
  • 支持返回http报文和报头
  • 支持带cookie的follow location(如果使用curl_setopt($this->_ch, CURLOPT_FOLLOWLOCATION, true);cookie并不会自动带上)
  • 解决cURL请求lighttpd会产生417 Expectation Failed错误的问题

实际上Curl_Manager并没有开发到心目中理想的样子,但并不妨碍使用,仅供各位参考:)

测试例子:
<?php
require_once("Curl_Manager.php");

$manager = new Curl_Manager();

$manager->set_action('gg', 'http://www.google.com/', 'http://willko.iteye.com/');//设置动作,(动作名称, 动作对应url,来源referer)

$manager->open()->get('gg'); //打开一个请求,进行get操作

echo $manager->body(); // 获得报文
echo $manager->header(); // 获得报头(需要自己解析)

//发起ssl请求
$manager->set_action('taobao', 'https://login.taobao.com/member/login.jhtml?f=top&redirectURL=http://www.taobao.com/', 'http://willko.iteye.com/');

$manager->ssl()->get('taobao'); //使用ssl方法,让当前这个请求支持ssl请求

echo $manager->body();
echo $manager->header();


支持cookie:
$manager->cookie();

带参数请求,get/post/put/delete等等使用方式一样
$manager->post('action', array('k' => 'v', 'a' => 'b'));
$manager->post('action', 'k=v&a=b');
$manager->post('action', array('k' => 'v', '@a' => '/home/www/avatar.gif')); //上传,需要使用绝对路径,参数名称加"@"。


Curl_Manager代码,也可以从附件下载:
<?php
// +----------------------------------------------------------------------+
// | Copyright (c) 2008-2010 Willko Cheng                                 |
// +----------------------------------------------------------------------+
// | Authors: Willko Cheng <willko@foxmail.com>                           |
// | Blog: http://willko.iteye.com/                                     |
// +----------------------------------------------------------------------+

class Curl_Manager {
	private $_is_temp_cookie = false;
	private $_header;
	private $_body;
	private $_ch;
	
	private $_proxy;
	private $_proxy_port;
	private $_proxy_type = 'HTTP'; // or SOCKS5
	private $_proxy_auth = 'BASIC'; // or NTLM
	private $_proxy_user;
	private $_proxy_pass;
	
	protected $_cookie;
	protected $_options;
	protected $_url = array ();
	protected $_referer = array ();
	
	public function __construct($options = array()) {
		$defaults = array ();
		
		$defaults ['timeout'] = 30;
		$defaults ['temp_root'] = sys_get_temp_dir ();
		$defaults ['user_agent'] = 'Mozilla/5.0 (Windows; U; Windows NT 6.0; zh-CN; rv:1.8.1.20) Gecko/20081217 Firefox/2.0.0.20';
		
		$this->_options = array_merge ( $defaults, $options );
	}
	
	public function open() {
		$this->_ch = curl_init ();
		
		//curl_setopt($this->_ch, CURLOPT_FOLLOWLOCATION, true);
		curl_setopt ( $this->_ch, CURLOPT_HEADER, true );
		curl_setopt ( $this->_ch, CURLOPT_RETURNTRANSFER, true );
		curl_setopt ( $this->_ch, CURLOPT_USERAGENT, $this->_options ['user_agent'] );
		curl_setopt ( $this->_ch, CURLOPT_CONNECTTIMEOUT, $this->_options ['timeout'] );
		curl_setopt ( $this->_ch, CURLOPT_HTTPHEADER, array('Expect:') ); // for lighttpd 417 Expectation Failed
		
		$this->_header = '';
		$this->_body = '';
		
		return $this;
	}
	
	public function close() {
		if (is_resource ( $this->_ch )) {
			curl_close ( $this->_ch );
		}
		
		if (isset ( $this->_cookie ) && $this->_is_temp_cookie && is_file ( $this->_cookie )) {
			unlink ( $this->_cookie );
		}
	}
	
	public function cookie() {
		if (! isset ( $this->_cookie )) {
			if (! empty ( $this->_cookie ) && $this->_is_temp_cookie && is_file ( $this->_cookie )) {
				unlink ( $this->_cookie );
			}
			
			$this->_cookie = tempnam ( $this->_options ['temp_root'], 'curl_manager_cookie_' );
			$this->_is_temp_cookie = true;
		}
		
		curl_setopt ( $this->_ch, CURLOPT_COOKIEJAR, $this->_cookie );
		curl_setopt ( $this->_ch, CURLOPT_COOKIEFILE, $this->_cookie );
		
		return $this;
	}
	
	public function ssl() {
		curl_setopt ( $this->_ch, CURLOPT_SSL_VERIFYPEER, false );
		
		return $this;
	}
	
	public function proxy($host = null, $port = null, $type = null, $user = null, $pass = null, $auth = null) {
		$this->_proxy = isset ( $host ) ? $host : $this->_proxy;
		$this->_proxy_port = isset ( $port ) ? $port : $this->_proxy_port;
		$this->_proxy_type = isset ( $type ) ? $type : $this->_proxy_type;
		
		$this->_proxy_auth = isset ( $auth ) ? $auth : $this->_proxy_auth;
		$this->_proxy_user = isset ( $user ) ? $user : $this->_proxy_user;
		$this->_proxy_pass = isset ( $pass ) ? $pass : $this->_proxy_pass;
		
		if (! empty ( $this->_proxy )) {
			curl_setopt ( $this->_ch, CURLOPT_PROXYTYPE, $this->_proxy_type == 'HTTP' ? CURLPROXY_HTTP : CURLPROXY_SOCKS5 );
			curl_setopt ( $this->_ch, CURLOPT_PROXY, $this->_proxy );
			curl_setopt ( $this->_ch, CURLOPT_PROXYPORT, $this->_proxy_port );
		}
		
		if (! empty ( $this->_proxy_user )) {
			curl_setopt ( $this->_ch, CURLOPT_PROXYAUTH, $this->_proxy_auth == 'BASIC' ? CURLAUTH_BASIC : CURLAUTH_NTLM );
			curl_setopt ( $this->_ch, CURLOPT_PROXYUSERPWD, "[{$this->_proxy_user}]:[{$this->_proxy_pass}]" );
		}
		
		return $this;
	}
	
	public function post($action, $query = array()) {
		if (is_array($query)) {
			foreach ($query as $key => $val) {
				if ($val{0} != '@') {
					$encode_key = urlencode($key);

					if ($encode_key != $key) {
						unset($query[$key]);
					}

					$query[$encode_key] = urlencode($val);
				}
			}
		}
		
		curl_setopt ( $this->_ch, CURLOPT_POST, true );
		curl_setopt ( $this->_ch, CURLOPT_URL, $this->_url [$action] );
		curl_setopt ( $this->_ch, CURLOPT_REFERER, $this->_referer [$action] );
		curl_setopt ( $this->_ch, CURLOPT_POSTFIELDS, $query );
		
		$this->_requrest ();
		
		return $this;
	}
	
	public function get($action, $query = array()) {
		$url = $this->_url [$action];
		
		if (! empty ( $query )) {
			$url .= strpos ( $url, '?' ) === false ? '?' : '&';
			$url .= is_array ( $query ) ? http_build_query ( $query ) : $query;
		}
		
		curl_setopt ( $this->_ch, CURLOPT_URL, $url );
		curl_setopt ( $this->_ch, CURLOPT_REFERER, $this->_referer [$action] );
		
		$this->_requrest ();
		
		return $this;
	}
	
	public function put($action, $query = array()) {
		curl_setopt ( $this->_ch, CURLOPT_CUSTOMREQUEST, 'PUT' );
		
		return $this->post ( $action, $query );
	}
	
	public function delete($action, $query = array()) {
		curl_setopt ( $this->_ch, CURLOPT_CUSTOMREQUEST, 'DELETE' );
		
		return $this->post ( $action, $query );
	}
	
	public function head($action, $query = array()) {
		curl_setopt ( $this->_ch, CURLOPT_CUSTOMREQUEST, 'HEAD' );
		
		return $this->post ( $action, $query );
	}
	
	public function options($action, $query = array()) {
		curl_setopt ( $this->_ch, CURLOPT_CUSTOMREQUEST, 'OPTIONS' );
		
		return $this->post ( $action, $query );
	}
	
	public function trace($action, $query = array()) {
		curl_setopt ( $this->_ch, CURLOPT_CUSTOMREQUEST, 'TRACE' );
		
		return $this->post ( $action, $query );
	}
	
	public function connect() {
	
	}
	
	public function follow_location() {
		preg_match ( '#Location:\s*(.+)#i', $this->header (), $match );
		
		if (isset ( $match [1] )) {
			$this->set_action ( 'auto_location_gateway', $match [1], $this->effective_url () );
			
			$this->get ( 'auto_location_gateway' )->follow_location ();
		}
		
		return $this;
	}
	
	public function set_action($action, $url, $referer = '') {
		$this->_url [$action] = $url;
		$this->_referer [$action] = $referer;
		
		return $this;
	}
	
	public function header() {
		return $this->_header;
	}
	
	public function body() {
		return $this->_body;
	}
	
	public function effective_url() {
		return curl_getinfo ( $this->_ch, CURLINFO_EFFECTIVE_URL );
	}

	public function http_code() {
		return curl_getinfo($this->_ch, CURLINFO_HTTP_CODE);
	}
	
	private function _requrest() {
		$response = curl_exec ( $this->_ch );
		
		$errno = curl_errno ( $this->_ch );
		
		if ($errno > 0) {
			throw new Curl_Manager_Exception ( curl_error ( $this->_ch ), $errno );
		}
		
		$header_size = curl_getinfo ( $this->_ch, CURLINFO_HEADER_SIZE );
		
		$this->_header = substr ( $response, 0, $header_size );
		$this->_body = substr ( $response, $header_size );
	}
	
	public function __destruct() {
		$this->close ();
	}
}

class Curl_Manager_Exception extends Exception {

}

分享到:
评论

相关推荐

    php的curl二次封装的类.zip

    8. **关闭连接**:为了释放系统资源,封装类会有一个关闭cURL会话的方法,对应cURL的`curl_close()`函数。 9. **重用连接**:如果需要进行多个相似的请求,封装类可能会实现连接池或重用机制,以减少建立新连接的...

    curl-7.53.1_spendrhy_curl_aix7.1安装curl_

    如果你需要编译自定义版本的`curl`或者进行二次开发,这些源代码会非常有用。 7. **packages**: 可能包含了针对不同操作系统的安装包,便于在AIX 7.1上安装`curl`。 8. **docs**: 文档目录,可能包含了更详细的...

    curl 封装的类库

    项目中自己使用的时候,自己封装的类库,请大家多多指教

    IOS cocos2dx编译的curl报错‘__curl_rule_01__'

    ios编译COCOS2DX时,有些版本会出现以下错误,'__curl_rule_01__' declared as an array with a negative size 只需把所有的.h文件替换掉引擎的,再把libcurl.a添加到工程中,即可解决这问题

    Curl获取网络时间.zip_Curl获取网络时间_curl 时间_curl 网络时间_网络时间 curl_网络时间获取

    std::cerr &lt;&lt; "curl_easy_perform() failed: " &lt;&lt; curl_easy_strerror(res) ; curl_easy_cleanup(curl); } curl_global_cleanup(); return 0; } ``` 在上面的代码中,我们向`worldtimeapi.org`发送了一个...

    curl-curl-7_47_1.zip

    curl-curl-7_47_1.zip

    curl_自定义进度条

    curl_global_init(CURL_GLOBAL_DEFAULT); curl = curl_easy_init(); if(curl) { curl_easy_setopt(curl, CURLOPT_URL, "http://example.com/large_file"); curl_easy_setopt(curl, CURLOPT_PROGRESSFUNCTION, ...

    curl_7_53_1_openssl_nghttp2_x64.7z for win10

    一个linux下的web后面测试工具,本机安装有vs2015, MingGW, cygWin,如果解压后不能正常使用可能与以上...如果在 path中加入exe的目录后,可以直接在 cmd中输入curl --hlep查看,否则需要在运行目录下有curl.exe程序。

    http类库:基于php curl库封装的http类库.zip

    这个压缩包包含了一个名为“基于php curl库封装的http类库”的PHP类库,它将PHP内置的cURL库进行了高级封装,以提供更加简洁和灵活的HTTP请求接口。 PHP的cURL库是一个功能丰富的库,用于在各种协议(包括HTTP、...

    WWW-Curl-4.17.tar_curl_www_www-curl_Perl_

    总结,`WWW-Curl-4.17.tar` 提供了一个方便的 Perl 模块,它封装了强大的 `curl` 功能,使 Perl 开发者能够轻松处理网络请求。无论是简单的数据获取还是复杂的网络交互,`WWW::Curl` 都能提供必要的支持。

    一个基于PHPcURL的开源HTTP类库

    5. **自定义请求选项**:尽管YurunHttp已经封装了很多常用功能,但仍然允许开发者自定义cURL的选项,以满足特殊需求。这使得类库具有很好的灵活性和可扩展性。 6. **重试机制**:为了应对网络不稳定的情况,...

    Curl.zip_C++ curl_DEMO_c++ curl_curl_curl c++

    - CURL库支持多线程,可以同时处理多个请求,使用`curl_multi_init()`和`curl_multi_add_handle()`等函数进行管理。 通过Curl.zip中的DEMO,我们可以看到这些概念如何在实际代码中体现,学习如何将CURL库有效地...

    curl-master.zip_curl_vendor

    在PHP项目中,`curl_vendor` 可能是一个已经预先配置好的类库,通过Composer安装。开发者只需引入相应的命名空间,然后创建对象,调用方法即可执行HTTP请求。例如,可能有如下的API: ```php use Vendor\Curl; $c ...

    ESP32_curl_example-master.zip_ESP32 CURL_curl esp32_esp32 cmake_

    在ESP32_curl_example-master.zip文件中,我们预计会找到以下内容: 1. `CMakeLists.txt`:这是CMake构建系统的配置文件,用于编译libcurl及其示例代码。CMake是一个跨平台的自动化构建系统,能帮助管理和构建不同...

    http类库:基于php curl库封装的http类库

    `php-httplib`的源码软件结构清晰,便于自定义扩展和二次开发。例如,你可以通过继承`HttpClient`,实现自己的特定逻辑,或者添加新的功能。 总的来说,`php-httplib`是PHP开发中的一款强大且实用的工具,它将cURL...

    WWW-Curl-4.15.tar_curl_www_www-curl_Perl_

    **WWW-Curl-4.15.tar - 关于curl、www-curl 和 Perl 的知识** 在互联网编程中,`curl` 是一个强大的命令行工具,用于传输数据到或从服务器,支持多种协议如HTTP、HTTPS、FTP、FTPS等。`curl` 的存在使得开发者可以...

    CURL多线程类库

    **CURL多线程类库详解** CURL(Client URL Library)是PHP中一个非常重要的库,用于处理HTTP和其他协议的请求。它提供了丰富的选项来定制各种网络交互,包括HTTP头、POST数据、代理设置等。当面临大量HTTP请求或者...

    curl-curl-7_53_1 (2).zip

    - **libcurl**: curl的核心库,提供了一整套接口供应用程序调用,处理各种网络协议。 - **多路复用**: curl-7_53_1支持HTTP/1.1的管道和HTTP/2的多路复用,能有效利用网络带宽,提高请求处理速度。 - **SSL/TLS...

    curl-master.zip_curl_curl-master_curlconfig-d

    `curl-master.zip_curl_curl-master_curlconfig-d`这个文件名表明这是一个关于curl源码仓库的压缩包,可能包含了curl的源代码、配置文件以及与`curlconfig-d`相关的文件。 `curl-master`通常指的是curl项目的主分支...

    freeswitch xml_curl模块使用

    XML_CURL模块是Freeswitch中的一部分,它允许通过CURL库从远程服务器获取或发送XML数据,从而实现动态配置和控制。这对于自动化管理和扩展Freeswitch系统非常有用。 1. **XML_CURL模块的原理** XML_CURL模块利用了...

Global site tag (gtag.js) - Google Analytics