PHP用curl_multi并行获取多个HTTP接口数据

接口1: php -S 127.0.0.1:8080 -t /home/eechen/www
接口2: php -S 127.0.0.2:8080 -t /home/eechen/www
/home/eechen/www/index.php:

1<?php
2header('Content-Type: application/json; charset=utf-8');
3echo json_encode(array('SERVER_NAME' => $_SERVER['SERVER_NAME']));
4//串行访问需要sum(2,1)秒,并行访问需要max(2,1)秒.
5($_SERVER['SERVER_NAME'] == '127.0.0.1') ? sleep(2) : sleep(1);

串行和并行对比:

1串行:
2<?php
3$ch1 = curl_init();
4$ch2 = curl_init();
5curl_setopt($ch1, CURLOPT_URL, 'http://127.0.0.1:8080/');
6curl_setopt($ch1, CURLOPT_HEADER, 0);
7curl_setopt($ch1, CURLOPT_RETURNTRANSFER, 1);
8curl_setopt($ch2, CURLOPT_URL, 'http://127.0.0.2:8080/');
9curl_setopt($ch2, CURLOPT_HEADER, 0);
10curl_setopt($ch2, CURLOPT_RETURNTRANSFER, 1);
11$starttime = microtime(true);
12$json[] = curl_exec($ch1);
13$json[] = curl_exec($ch2);
14echo microtime(true) - $starttime."\n"; //耗时约3秒
15curl_close($ch1);
16curl_close($ch2);
17var_export($json);
18//输出:
193.002946138382
20array (
21  0 => '{"SERVER_NAME":"127.0.0.1"}',
22  1 => '{"SERVER_NAME":"127.0.0.2"}',
23)
24
25并行:
26<?php
27$url[] = 'http://127.0.0.1:8080';
28$url[] = 'http://127.0.0.2:8080';
29$mh = curl_multi_init();
30foreach($url as $k => $v) {
31	$ch[$k] = curl_init($v);
32	curl_setopt($ch[$k], CURLOPT_HEADER, 0); //不输出头
33	curl_setopt($ch[$k], CURLOPT_RETURNTRANSFER, 1); //exec返回结果而不是输出,用于赋值
34	curl_multi_add_handle($mh, $ch[$k]); //决定exec输出顺序
35}
36$running = null;
37$starttime = microtime(true);
38//执行批处理句柄(类似pthreads多线程里的start开始和join同步)
39do {
40	//CURLOPT_RETURNTRANSFER如果为0,这里会直接输出获取到的内容.如果为1,后面可以用curl_multi_getcontent获取内容.
41	curl_multi_exec($mh, $running);
42	//阻塞直到cURL批处理连接中有活动连接,不加这个会导致CPU负载超过90%.
43	curl_multi_select($mh);
44} while ($running > 0);
45echo microtime(true) - $starttime."\n"; //耗时约2秒
46foreach($ch as $v) {
47	$info[] = curl_getinfo($v);
48	$json[] = curl_multi_getcontent($v);
49	curl_multi_remove_handle($mh, $v);
50}
51curl_multi_close($mh);
52var_export($json); 
53var_export($info);
54//输出:
552.0015449523926
56array (
57  0 => '{"SERVER_NAME":"127.0.0.1"}',
58  1 => '{"SERVER_NAME":"127.0.0.2"}',
59)
60array (
61  0 => 
62  array (
63    'url' => 'http://127.0.0.1:8080/',
64    'content_type' => 'application/json; charset=utf-8',
65    'http_code' => 200,
66    'header_size' => 107,
67    'request_size' => 53,
68    'filetime' => -1,
69    'ssl_verify_result' => 0,
70    'redirect_count' => 0,
71    'total_time' => 2.0013990000000002,
72    'namelookup_time' => 5.3999999999999998E-5,
73    'connect_time' => 0.00015799999999999999,
74    'pretransfer_time' => 0.000194,
75    'size_upload' => 0,
76    'size_download' => 27,
77    'speed_download' => 13,
78    'speed_upload' => 0,
79    'download_content_length' => -1,
80    'upload_content_length' => 0,
81    'starttransfer_time' => 0.00079699999999999997,
82    'redirect_time' => 0,
83    'certinfo' => 
84    array (
85    ),
86    'primary_ip' => '127.0.0.1',
87    'primary_port' => 8080,
88    'local_ip' => '127.0.0.1',
89    'local_port' => 57653,
90    'redirect_url' => '',
91  ),
92  1 => 
93  array (
94    'url' => 'http://127.0.0.2:8080/',
95    'content_type' => 'application/json; charset=utf-8',
96    'http_code' => 200,
97    'header_size' => 107,
98    'request_size' => 53,
99    'filetime' => -1,
100    'ssl_verify_result' => 0,
101    'redirect_count' => 0,
102    'total_time' => 1.0012369999999999,
103    'namelookup_time' => 1.1E-5,
104    'connect_time' => 4.6999999999999997E-5,
105    'pretransfer_time' => 6.3E-5,
106    'size_upload' => 0,
107    'size_download' => 27,
108    'speed_download' => 26,
109    'speed_upload' => 0,
110    'download_content_length' => -1,
111    'upload_content_length' => 0,
112    'starttransfer_time' => 0.00063699999999999998,
113    'redirect_time' => 0,
114    'certinfo' => 
115    array (
116    ),
117    'primary_ip' => '127.0.0.2',
118    'primary_port' => 8080,
119    'local_ip' => '127.0.0.1',
120    'local_port' => 43645,
121    'redirect_url' => '',
122  ),
123)