この記事では主にPHP CURLマルチスレッド操作コード例を紹介していますので、必要な方は参考にしてください。
使用方法:?
1 2 3
|
$urls = array("http://baidu.com", "http://21andy.com", "http://google.com"); $mp = 新しい MultiHttpRequest($urls); $mp->start();
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 |
/* * カール多線程类 * 使用方法: * ======================== $urls = array("http://baidu.com", "http://dzone.com", "http://google.com"); $mp = 新しい MultiHttpRequest($urls); $mp->start(); * ======================== */ クラスMultiHttpRequest { パブリック $urls = array(); パブリック $curlopt_header = 1; パブリック $method = "GET";
関数 __construct($urls = false) { $this->urls = $urls; }
関数 set_urls($urls) { $this->urls = $urls; $this を返す; }
関数 is_return_header($b) { $this->curlopt_header = $b; $this を返す; }
関数 set_method($m) { $this->medthod = strtoupper($m); $this を返す; }
関数 start() { if(!is_array($this->urls) または count($this->urls) == 0){ false を返す; } $curl = $text = array(); $handle =curl_multi_init(); foreach($this->URLs as $k=>$v){ $curl[$k] = $this->add_handle($handle, $v); }
$this->exec_handle($handle); foreach($this->URLs as $k=>$v){ curl_multi_getcontent($curl[$k]); echo $curl[$k]."n"; //$text[$k] =curl_multi_getcontent($curl[$k]); //echo $text[$k], "nn"; curl_multi_remove_handle($handle, $curl[$k]); } curl_multi_close($handle); }
プライベート関数 add_handle($handle, $url) { $curl =curl_init(); curl_setopt($curl, CURLOPT_URL, $url); curl_setopt($curl, CURLOPT_HEADER, $this->curlopt_header); curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); curl_multi_add_handle($handle, $curl); $curl を返す; }
プライベート関数 exec_handle($handle) { $flag = null; する{ curl_multi_exec($handle, $flag); } while ($flag > 0); } } |