關於PHP實現非同步操作的研究 關於春天的古詩 關於讀書的名言 關於讀書的手抄

1.為啥PHP需要非同步操作？

一般來說PHP適用的場合是web頁面展示等耗時比較短的任務，如果對於比較花時間的操作如resize圖片、大數據導入、批量發送EDM、SMS等，就很容易出現操作超時情況。你可以說我可以設定無限超時時間，等等你也要知道PHP有一個工作模式是fastcgi，PHP無限不超時，不代表fastcgi相應不超時……如果你還想說要fastcgi相應永不超時，我建議你應該跟你們的維運人員討論去…

這個時候異步的操作就發揮他的作用了，由於是非阻塞操作，操作會即時返回，然後在後台再慢慢幹活。管你超時不超時的，我就沒有在目前的進程/執行緒下工作。看吧是不是很美好，不過其實這也是個坑…

2.PHP可以實現非同步操作嗎？

答案是肯定的，不過網路上各種的純PHP實現得就有點彆扭了。 socket模式、掛起進程模式、有的還直接fork進程。很好，各路神仙各顯神通。如果維運人員看到的話，一定會×××××你們的，不把web server跑死才怪……

那還有其他更好的方法去實現這個非同步操作的可能麼？有，現在我們只有想怎麼開外掛了。查一下PECL主流的外掛方案有一堆的××MQ（訊息佇列），其中有個用於任務分配的外掛進入了我們的視線Gearman(其實這傢伙才是角，我就不詳細介紹了，點連接看介紹)。

別的不說，就說他的client多，支援很多語言的client，你可以使用大部分你喜歡的語言去寫worker。我個人很煩語言之爭，你喜歡用神碼語言寫worker都隨你喜歡。有資料持久化支援（就是把佇列保存到資料庫媒體中，那故障復原也好做），有群集支援（其實很多××MQ都有這些功能）。 PECL上有擴展，也有純PHP實作擴展。反正這個Gearman也活了很久了，雜七雜八的問題基本上都解決了。

4.基本思路

有了Gearman這外掛就簡單多了。就是向gearman發送一個任務，把執行的任務發出去，然後等待worker去呼叫PHP cli去執行我們的php程式碼。

我就寫了一下一個python的worker（別問我為啥用python，1.我會python，2.linux下不用裝runtime），你可以自己根據思路寫一個PHP的worker，不過嘛，本人是不太信得過PHP跑的worker。其他語言飯可以用java、node.js 或其他語言實作一個worker試試。對用Golang寫worker有興趣的朋友可以找我。

phpasync_worker_py

不好意思，裡面是沒有註解的。一個設定文件，一個py腳本。基本的功能也就是分析一下呼叫的參數，然後呼叫PHP Cli，就是那樣子而已。要讓py腳本跑起來請自行安裝python的gearman模組。

然後到PHP的部分先上測試程式碼：

<ol>
<li><span><span><?php  </span></span></li><li><span>require_once</span><span> </span><span>'PHPAsyncClient.php'</span><span>;  </span></li><li><span>date_default_timezone_set(</span><span>'Asia/Shanghai'</span><span>);  </span></li><li><span> </span></li><li><span>class</span><span> AsyncTest {  </span></li><li><span> </span></li><li><span>    </span><span>const</span><span> </span></li><li><span>        LOG_FILE = </span><span>'/debug.log'</span><span>;  </span></li><li><span> </span></li><li><span>    </span><span>static</span><span> </span><span>public</span><span> </span><span>function</span><span> run() {  </span></li><li><span>        </span><span>if</span><span> (PHPAsyncClient::in_callback(</span><span>__FILE__</span><span>)) {  </span></li><li><span>            self::log(</span><span>'php Async callback'</span><span>);  </span></li><li><span>            PHPAsyncClient::parse();  </span></li><li><span>            </span><span>return</span><span>;  </span></li><li><span>        }  </span></li><li><span>        </span><span>if</span><span> (PHPAsyncClient::is_main(</span><span>__FILE__</span><span>)) {  </span></li><li><span>            self::log(</span><span>'main run'</span><span>);  </span></li><li><span>            </span><span>$async_call</span><span> = PHPAsyncClient::getInstance();  </span></li><li><span>            </span><span>$async_call</span><span>->AsyncCall(</span><span>'AsyncTest'</span><span>, </span><span>'callback'</span><span>, </span><span>array</span><span>(  </span></span></li>
<li>
<span>                </span><span>'content'</span><span> => </span><span>'Hello World!!!'</span><span>,  </span>
</li>
<li>
<span>            ), </span><span>array</span><span>(  </span>
</li>
<li>
<span>                </span><span>'class'</span><span> => </span><span>'AsyncTest'</span><span>,  </span>
</li>
<li>
<span>                </span><span>'method'</span><span> => </span><span>'callback'</span><span>,  </span>
</li>
<li>
<span>                </span><span>'params'</span><span> => </span><span>array</span><span>(  </span>
</li>
<li>
<span>                    </span><span>'content'</span><span> => </span><span>'Hello Callback!'</span><span>,  </span>
</li>
<li><span>                ),  </span></li>
<li>
<span>            ), </span><span>__FILE__</span><span>);  </span>
</li>
<li>
<span>            </span><span>return</span><span>;  </span>
</li>
<li><span>        }  </span></li>
<li><span>    }  </span></li>
<li><span> </span></li>
<li>
<span>    </span><span>static</span><span> </span><span>public</span><span> </span><span>function</span><span> callback(</span><span>$args</span><span>) {  </span>
</li>
<li>
<span>        self::log(</span><span>'AsyncTest callback run'</span><span>);  </span>
</li>
<li>
<span>        self::log(</span><span>'AsyncTest callback args:'</span><span>.print_r(</span><span>$args</span><span>, true));  </span>
</li>
<li><span>    }  </span></li>
<li><span> </span></li>
<li>
<span>    </span><span>static</span><span> </span><span>public</span><span> </span><span>function</span><span> log(</span><span>$content</span><span>) {  </span>
</li>
<li>
<span>        </span><span>$fullname</span><span> = dirname(</span><span>__FILE__</span><span>).self::LOG_FILE;  </span>
</li>
<li>
<span>        </span><span>$content</span><span> = </span><span>date</span><span>(</span><span>'[Y-m-d H:i:s]'</span><span>).</span><span>$content</span><span>.</span><span>"\n"</span><span>;  </span>
</li>
<li>
<span>        </span><span>file_put_contents</span><span>(</span><span>$fullname</span><span>, </span><span>$content</span><span>, FILE_APPEND);  </span>
</li>
<li><span>    }  </span></li>
<li><span>}  </span></li>
<li><span> </span></li>
<li><span>AsyncTest::run(); </span></li>
</ol>

就3個靜態方法，一個是用於調試的log方法，其他都是字面意思。這個例子是對這種呼叫方式有個初步印象。然後直接上PHP的所有原始碼：

php_async.zip

然後應該會有很多人會說，win下安裝不了gearman……所以我把java版的gearman server也放上去吧。

java-gearman-service-0.6.6.zip

5.結論

經過以上配置犀牛一樣大的傢伙後（要裝一個Gearman，還要跑個Py腳本），我們基本上就使PHP擁有了非同步呼叫功能，當然其中還有一個狀態維護神馬的要自己去實現。所以發現，其實這個方案不咋樣，太複雜了。還是使用一些web service的方式去做web callback會好點（問題是web callback一樣會超時…），這個請留意後續。

原文連結：http://my.oschina.net/wakanoc/blog/101789

以上就介紹了關於PHP實現非同步操作的研究，包括了php,關於方面的內容，希望對PHP教程有興趣的朋友有所幫助。