第PHP實現(xiàn)的CURL非阻塞調(diào)用類本文實例講述了PHP實現(xiàn)的CURL非阻塞調(diào)用類。分享給大家供大家參考，具體如下：

前面一篇《PHP實現(xiàn)非阻塞模式的方法》文章講述了PHP中實現(xiàn)非阻塞模式，其實如果只是HTTP的話，直接用CURL就能實現(xiàn)。

基于網(wǎng)上的一段代碼，修改完善后封裝了一個支持POST/GET的非阻塞調(diào)用類。

歡迎測試bug~~~~~

/*****************************************************

CURL非阻塞調(diào)用類

Auther:Linvo

Copyright(C)2010/10/21

*******************************************************/

//使用范例

//傳入?yún)?shù)說明

//url請求地址

//dataPOST方式數(shù)據(jù)

//并發(fā)調(diào)用

$param1=array(

array(

'url'="http://localhost/a.phps=1",

array(

'url'="http://localhost/a.phps=1",

'data'=array('aaa'=1,'bbb'=2),

//單個調(diào)用

$param2=array(

'url'="http://localhost/a.phps=0",

'data'=array('aaa'=1,'bbb'=2),

//單個調(diào)用（GET簡便方式）

$param3='http://localhost/a.phps=2';

$ac=newAsyncCURL();

$ac-set_param($param1);

$ret=$ac-send();

//返回值為請求參數(shù)順序的結(jié)果數(shù)組（元素值為False表示請求錯誤）

var_dump($ret);

classAsyncCURL

*是否需要返回HTTP頭信息

public$curlopt_header=0;

*單個CURL調(diào)用超時限制

public$curlopt_timeout=20;

private$param=array();

*構(gòu)造函數(shù)（可直接傳入請求參數(shù)）

*@paramarray可選

*@returnvoid

publicfunction__construct($param=False)

if($param!==False)

$this-param=$this-init_param($param);

*設(shè)置請求參數(shù)

*@paramarray

*@returnvoid

publicfunctionset_param($param)

$this-param=$this-init_param($param);

*發(fā)送請求

*@returnarray

publicfunctionsend()

if(!is_array($this-param)||!count($this-param))

returnFalse;

$curl=$ret=array();

$handle=curl_multi_init();

foreach($this-paramas$k=$v)

$param=$this-check_param($v);

if(!$param)$curl[$k]=False;

else$curl[$k]=$this-add_handle($handle,$param);

$this-exec_handle($handle);

foreach($this-paramas$k=$v)

if($curl[$k])

$ret[$k]=curl_multi_getcontent($curl[$k]);

curl_multi_remove_handle($handle,$curl[$k]);

}else{

$ret[$k]=False;

curl_multi_close($handle);

return$ret;

//以下為私有方法

privatefunctioninit_param($param)

$ret=False;

if(isset($param['url']))

$ret=array($param);

}else{

$ret=isset($param[0])$param:False;

return$ret;

privatefunctioncheck_param($param=array())

$ret=array();

if(is_string($param))

$url=$param;

}else{

extract($param);

if(isset($url))

$url=trim($url);

$url=stripos($url,'http://')===0$url:NULL;

if(isset($data)is_array($data)!empty($data))

$method='POST';

}else{

$method='GET';

unset($data);

if(isset($url))$ret['url']=$url;

if(isset($method))$ret['method']=$method;

if(isset($data))$ret['data']=$data;

$ret=isset($url)$ret:False;

return$ret;

privatefunctionadd_handle($handle,$param)

$curl=curl_init();

curl_setopt($curl,CURLOPT_URL,$param['url']);

curl_setopt($curl,CURLOPT_HEADER,$this-curlopt_header);

curl_setopt($curl,CURLOPT_RETURNTRANSFER,1);

curl_setopt($curl,CURLOPT_TIMEOUT,$this-curlopt_timeout);

if($param['method']=='POST')

curl_setopt($curl,CURLOPT_POST,1);

curl_setopt($curl,CURLOPT_POSTFIELDS,$param['data']);

curl_multi_add_handle($handle,$curl);

return$curl;

privatefunctionexec_handle($handle)

$flag=null;

do{

curl_multi_exec($handle,$flag);

}whi