foreach

(

$map

as

 

$url

=>

$ch

)

 

{

        

$responses

[

$url

]

 

= callback(curl_multi_getcontent(

$ch

),

$delay

);

        

curl_multi_remove_handle(

$queue

,

$ch

);

        

curl_close(

$ch

);

    

}

 

 

    

curl_multi_close(

$queue

);

    

return

$responses

;

}
 
首先将所有的

URL 压入并发队列, 然后执行并发过程, 等待所有请求接收完之后进行数据的

解析等后续处理

. 在实际的处理过程中, 受网络传输的影响, 部分 URL 的内容会优先于其他

URL 返回, 但是经典 cURL 并发必须等待最慢的那个 URL 返回之后才开始处理, 等待也就意
味着

CPU 的空闲和浪费. 如果 URL 队列很短, 这种空闲和浪费还处在可接受的范围, 但如果

队列很长

, 这种等待和浪费将变得不可接受.

2. 改进的 Rolling cURL 并发方式
仔细分析不难发现经典

cURL 并发还存在优化的空间, 优化的方式时当某个 URL 请求完毕

之后尽可能快的去处理它

, 边处理边等待其他的 URL 返回, 而不是等待那个最慢的接口返回

之后才开始处理等工作

, 从而避免 CPU 的空闲和浪费. 闲话不多说, 下面贴上具体的实现:

复制代码

 代码如下:

 

function

rolling_curl(

$urls

,

$delay

)

 

{

    

$queue

= curl_multi_init();

    

$map

= 

array

();

 

 

    

foreach

(

$urls

as

 

$url

)

 

{

        

$ch