php curl_multi 多线程查询的例子

PHP自身没有多线程的，可以借助扩展实现。但是curl_multi* 函数实现了多线程访问网站数据的功能。

步骤总结如下：

第一步：调用curl_multi_init

第二步：循环调用curl_multi_add_handle

这一步需要注意的是，curl_multi_add_handle的第二个参数是由curl_init而来的子handle。

第三步：持续调用curl_multi_exec

第四步：根据需要循环调用curl_multi_getcontent获取结果

第五步：调用curl_multi_remove_handle，并为每个字handle调用curl_close

第六步：调用curl_multi_close

1. <?php 
2.  
3. $t=getTime(); 
4.  
5. $total=10; 
6.  
7. for($i=0;$i<$total;$i++){ 
8.  
9.  $url_arr[] = "http://www.Vevb.com /test"; 
10.  
11. } 
12.  
13. $mh = curl_multi_init(); 
14.  
15. foreach ($url_arr as $i => $url) { 
16.  
17.  $conn[$i] = curl_init($url); 
18.  
19.  curl_setopt($conn[$i],CURLOPT_RETURNTRANSFER,1); // 设置返回页面输出内容 
20.  
21.  curl_multi_add_handle ($mh,$conn[$i]); // 添加线程 
22.  
23. } 
24.  
25. #----------------执行线程---------------- 
26.  
27. do { 
28.  
29.  $mrc = curl_multi_exec($mh,$active); 
30.  
31. }while ($mrc == CURLM_CALL_MULTI_PERFORM); 
32. 2 
33. while ($active and $mrc == CURLM_OK) { 
34.  
35.  if (curl_multi_select($mh) != -1) { 
36.  
37.   do { 
38.  
39.    $mrc = curl_multi_exec($mh, $active); 
40.  
41.   } while ($mrc == CURLM_CALL_MULTI_PERFORM); 
42.  
43.  } 
44.  
45. } 
46. 3 
47. foreach ($url_arr as $i => $url) { 
48.  
49.  $res[$i]=curl_multi_getcontent($conn[$i]);//得到页面输入内容 
50.  
51.  curl_multi_remove_handle($mh, $conn[$i]); 
52.  
53.  curl_close($conn[$i]); 
54.  
55. } 
56.  
57. curl_multi_close($mh); 
58. 4 
59. foreach($res as $k=>$v){ 
60.  
61.  $k=str_pad($k,2,0); 
62.  
63.  echo "$k => $v <br>"; 
64.  
65. } 
66. 5 
67. runTime($t); 
68.  
69. #----------- calculate time function------------- 
70.  
71. function getTime(){ 
72.  
73.  $TIME=explode(" ",microtime()); 
74.  
75.  $TIME=$TIME[1].substr($TIME[0],1); 
76.  
77.  return $TIME; 
78.  
79. } 
80.  
81. function runTime($t,$l=3){ 
82.  
83.  $dif=getTime()-$t; 
84.  
85.  echo ' '.number_format($dif,$l); 
86.  
87. } 
88.  
89. ?>