PHP CURL 多线程 GET/POST 类

2. /****************************************************************
3. PHP CURL 多线程 GET/POST
4. curl(array('url?get=data','url'),array('','post_data'));
5. *****************************************************************/
6. function curl($urls,$post) {
7. $queue = curl_multi_init();
8. $map = array();
9. foreach ($urls as $key => $url) {
10. $ch = curl_init();
11. curl_setopt($ch, CURLOPT_URL, $url);
12. curl_setopt($ch, CURLOPT_TIMEOUT, 30);
13. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
14. curl_setopt($ch, CURLOPT_POSTFIELDS, $post[$key]);
15. curl_setopt($ch, CURLOPT_HEADER, 0);
16. curl_setopt($ch, CURLOPT_NOSIGNAL, true);
17. curl_multi_add_handle($queue, $ch);
18. $map[(string) $ch] = $url;
19. }
20. $responses = array();
21. do {
22. while (($code = curl_multi_exec($queue, $active)) == CURLM_CALL_MULTI_PERFORM) ;
23. if ($code != CURLM_OK) { break; }
24. while ($done = curl_multi_info_read($queue)) {
25. $error = curl_error($done['handle']);
26. $results = curl_multi_getcontent($done['handle']);
27. $responses[$map[(string) $done['handle']]] = compact('error', 'results');
28. curl_multi_remove_handle($queue, $done['handle']);
29. curl_close($done['handle']);
30. }
31. if ($active > 0) {
32. curl_multi_select($queue, 0.5);
33. }
34. } while ($active);
35. curl_multi_close($queue);
36. return $responses;
37. }

复制代码

多线程, PHP, CURL