每個PHP文件的執行是單線程的,但是php本身也可以用一些別的技術實現多線程并發比如用php-fpm進程,這里用curl模擬多線程發送請求。php的curl多線程是通過不斷調用curl_multi_exec來獲取內容,這里舉一個demo來模擬一次curl多線程并發操作。
01 | //設置緩沖為0(也可以去php.ini設置) |
02 | ini_set ( 'output_buffering' , 0); |
03 | //打開輸出緩沖區 |
04 | ob_start(); |
05 | //設置一個空數組 |
06 | $curl_Arr =[]; |
07 | //這里模擬20次請求 |
08 | for ( $i =0; $i <20; $i ++){ |
09 | //開啟curl連接 |
10 | $curl_Arr [ $i ]=curl_init( "http://XXXX/test.php" ); |
11 | //CURLOPT_RETURNTRANSFER 設置為1表示稍后執行的curl_exec函數的返回是URL的返回字符串,而不是把返回字符串定向到標準輸出并返回TRUE; |
12 | curl_setopt( $curl_Arr [ $i ],CURLOPT_RETURNTRANSFER,1); |
13 | } |
14 |
15 | //創建批處理cURL句柄 |
16 | $mh = curl_multi_init(); |
17 |
18 | foreach ( $curl_Arr as $k => $ch ){ |
19 | //curl句柄入棧增加 |
20 | curl_multi_add_handle( $mh , $ch ); |
21 | } |
22 | $active = null; |
23 | while ( count ( $curl_Arr )>0){ |
24 | //發起curl_multi請求 |
25 | @curl_multi_exec( $mh , $active ); |
26 | foreach ( $curl_Arr as $k => $ch ){ |
27 | //獲取句柄的返回值 |
28 | if ( $result [ $k ]= curl_multi_getcontent( $ch )){ |
29 | //輸出結果 |
30 | echo "$result[$k]\n" ; |
31 | ob_flush(); |
32 | //把被釋放的數據發送到瀏覽器 |
33 | flush (); |
34 | //關閉該句柄 |
35 | curl_multi_remove_handle( $mh , $ch ); |
36 | unset( $curl_Arr [ $k ]); |
37 | } |
38 | } |
39 | } |
40 | //關閉ouput_buffering機制 |
41 | ob_end_flush(); |
42 | //關閉"curl_mulit"句柄 |
43 | curl_multi_close( $mh ); |
我再服務器上建立一起請求的php頁面命名為test.php,內容如下
1 | 1 sleep(10); |
2 | 2 echo 'seccess' ; exit ; |
表示等待十秒后數據下面語句。
然后我在命令行執行該程序結果如下:
上面代碼中通過循環$curl_Arr數組來調用curl_multi_getcontent來查詢是否有數據。有數據就輸出并刪除元素,直到$curl_Arr數組元素個數為0。
該模擬多線程實現是通過使用curl的curl_multi系列函數能實現此功能的。至于該系列函數使用介紹,百度一搜一大把。這里就不做說明了。
以上所述是小編給大家介紹的php使用curl模擬多線程發送請求詳解整合,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對服務器之家網站的支持!