本文章詳細的介紹了關于PHP中實現異步調用多線程方法,下面我們以給1000個用戶發送一封推薦郵件,用戶輸入或者導入郵件賬號了提交服務器執行發送來講述.

比如現在有一個場景,給1000個用戶發送一封推薦郵件,用戶輸入或者導入郵件賬號了提交服務器執行發送,代碼如下:

1. <?php 
2.  
3. $sqlservercount=count($emailarr); 
4.  
5. for($i=0;$i<$count;$i ) 
6.  
7. { 
8.  
9. 　　sendmail(.....);//發送郵件 
10.  
11. } 
12.  
13. ?> 

這段代碼用戶體驗極差,也無法實際運用,首先發送這么多郵件會產生服務器運行超時,其實漫長的用戶等待時間會讓用戶對系統產品懷疑和失去信心,但是用戶不需要等待到1000封郵件都發送完畢了才提交發送成功,我們完全可以提交后臺后直接給用戶提示發送成功,然后讓后臺程序靜默依次發送.

這個時候我們就需要“異步執行”技術來執行代碼,異步執行的特點是后臺靜默執行，用戶無需等待代碼的執行結果,使用異步執行的好處.

1.擺脫了應用程序對單個任務的依賴性

2.提高了程序的執行效率

3.提高了程序的擴展性

4.在一定場景提高了用戶體驗

5.因為PHP不支持多線程,使用異步調用的請求多個HTTP的方式達到了程序并行執行效果,但是注意的是請求的HTTP過多的話,會大大加大了系統的開銷.

用戶體驗:用戶等待->發送完畢

朋友們就會問,怎么缺少發信環節？

OK，發信環節就在用戶提交請求的時候,把發信任務轉給了一個單獨處理發信的php程序處理了,當用戶看見“發送完畢”的時候其實信還沒發送完,這個時候,發信程序正在后臺努力的工作著,一封一封的向外發送.

sendmail.php代碼如下:

1. <?php 
2. $domain="www.***.com"; 
3. $url="/system_mail.php"; 
4. $par="email=".implode(',',$emailarr)."&........"; 
5. $header = "POST $url HTTP/1.0rn"; 
6. $header .= "Content-Type: application/x-www-form-urlencodedrn"; 
7. $header .= "Content-Length: " . strlen($par) . "rnrn"; 
8. $fp = @fsockopen ($domain, 80, $errno, $errstr, 30); 
9. fputs ($fp, $header . $par); 
10. fclose($fp); 
11.  
12. echo ''發送完畢'; 
13. ?> 

system_mail.php

1. <?php 
2. ini_set("ignore_user_abort",true); 
3. ignore_user_abort(true);//此處的代碼需要php.ini開啟相關的選項，保證php執行不超時的，不明白，參考我的另一篇文章 “關閉瀏覽器后,php腳本會不會繼續運行” 
4. //獲取email地址，發信，此處為發信代碼 
5. ?> 

好了,改成異步方式后,用戶提交信息,可以立即得到結果“發送完畢”,信呢,會在后臺一封一封的發送,直到發送完畢.

經過試驗,總結出來幾種方法,和大家share.

1. 最簡單的辦法,就是在返回給客戶端的HTML代碼中,嵌入AJAX調用,或者,嵌入一個img標簽,src指向要執行的耗時腳本.

這種方法最簡單,也最快,服務器端不用做任何的調用.

但是缺點是,一般來說Ajax都應該在onLoad以后觸發,也就是說,用戶點開頁面后,就關閉,那就不會觸發我們的后臺腳本了.

而使用img標簽的話,這種方式不能稱為嚴格意義上的異步執行,用戶瀏覽器會長時間等待php腳本的執行完成,也就是用戶瀏覽器的狀態欄一直顯示還在load.

當然,還可以使用其他的類似原理的方法,比如script標簽等等.

2. popen()

resource popen ( string command, string mode );

打開一個指向進程的管道,該進程由派生給定的 command 命令執行而產生,打開一個指向進程的管道,該進程由派生給定的 command 命令執行而產生.

所以可以通過調用它，但忽略它的輸出,代碼如下:

pclose(popen("/home/xinchen/backend.php &", 'r')); 

這個方法避免了第一個方法的缺點,并且也很快,但是問題是,這種方法不能通過HTTP協議請求另外的一個WebService,只能執行本地的腳本文件,并且只能單向打開,無法穿大量參數給被調用腳本。

并且如果,訪問量很高的時候,會產生大量的進程,如果使用到了外部資源,還要自己考慮競爭.

3. 使用CURL

這個方法，設置CUROPT_TIMEOUT為1（最小為1，郁悶）。也就是說，客戶端至少必須等待1秒鐘,代碼如下:

1. $ch = curl_init(); 
2.  $curl_opt = array(CURLOPT_URL, 'http://www.example.com/backend.php', 
3.  CURLOPT_RETURNTRANSFER, 1, 
4. CURLOPT_TIMEOUT, 1,);  
5. curl_setopt_array($ch, $curl_opt); 
6. curl_exec($ch); 
7. curl_close($ch); 

4. 使用fsockopen

這個方法應該是最完美的,但是缺點是,你需要自己拼出HTTP的header部分,代碼如下:

1. $fp = fsockopen("www.example.com", 80, $errno, $errstr, 30); 
2.  
3. if (!$fp) { 
4.  
5.     echo "$errstr ($errno)<br />n"; 
6.  
7. } else { 
8.  
9.     $out = "GET /backend.php / HTTP/1.1rn"; 
10.  
11.     $out .= "Host: www.example.comrn"; 
12.  
13.     $out .= "Connection: Closernrn"; 
14.  
15.  
16.  
17.     fwrite($fp, $out); 
18.  
19.     /*忽略執行結果 
20.  
21. while (!feof($fp)) { 
22.  
23. echo fgets($fp, 128); 
24. //開源代碼Vevb.com 
25. }*/ 
26.  
27.     fclose($fp); 
28.  
29. }