關於PHP實現異步操做的研究

1.爲啥PHP須要異步操做?
通常來講PHP適用的場合是web頁面展現等耗時比較短的任務,若是對於比較花時間的操做如resize圖片、大數據導入、批量發送EDM、SMS等,就很容易出現操做超時狀況。你能夠說我能夠設置無限超時時間,等等你也要知道PHP有一個工做模式是fastcgi,PHP無限不超時,不表明 fastcgi相應不超時……若是你還想說要fastcgi相應永不超時,我建議你應該跟大家的運維人員討論去……
這個時候異步的操做就發揮他的做用了,因爲是非阻塞操做,操做會即時返回,而後在後臺再慢慢幹活。管你超時不超時的,我就沒有在當前的進程/線程下幹活。看吧是否是很美好,不過其實這也是個坑……php


2.PHP能夠實現異步操做嗎?
答案是確定的,不過網上各類的純PHP實現得就有點彆扭了。socket模式、掛起進程模式、有的還直接fork進程。很好,各路神仙各顯神通。若是運維人員看到的話,必定會×××××大家的,不把web server跑死纔怪……
那還有其餘更好的方法去實現這個異步操做的可能麼?有,如今咱們只有想怎麼開外掛了。查一下PECL主流的外掛方案有一堆的××MQ(消息隊列),其中有個用於任務分配的外掛進入了咱們的視線Gearman(其實這傢伙纔是角,我就不詳細介紹了,點鏈接看介紹)。java


3.爲啥選擇Gearman?
別的不說,就說他的client多,支持不少語言的client,你能夠使用大部分你喜歡的語言去寫worker。我我的是很煩語言之爭,你喜歡用神碼語言寫worker都隨你喜歡。有數據持久化支持(就是把隊列保存到數據庫介質中,那故障恢復也好作),有羣集支持(其實不少××MQ都有這些功能)。 PECL上有擴展,也有純PHP實現擴展。反正這個Gearman也活了好久了,雜七雜八的問題都基本上解決了。node


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的部分先上測試代碼:python

 

  1. <?php 
  2. require_once'PHPAsyncClient.php'
  3. date_default_timezone_set('Asia/Shanghai'); 
  4. class AsyncTest { 
  5.     const
  6.         LOG_FILE = '/debug.log'
  7.     staticpublicfunction run() { 
  8.         if (PHPAsyncClient::in_callback(__FILE__)) { 
  9.             self::log('php Async callback'); 
  10.             PHPAsyncClient::parse(); 
  11.             return
  12.         } 
  13.         if (PHPAsyncClient::is_main(__FILE__)) { 
  14.             self::log('main run'); 
  15.             $async_call = PHPAsyncClient::getInstance(); 
  16.             $async_call->AsyncCall('AsyncTest', 'callback', array
  17.                 'content' => 'Hello World!!!'
  18.             ), array
  19.                 'class' => 'AsyncTest'
  20.                 'method' => 'callback'
  21.                 'params' => array
  22.                     'content' => 'Hello Callback!'
  23.                 ), 
  24.             ), __FILE__); 
  25.             return
  26.         } 
  27.     } 
  28.     staticpublicfunction callback($args) { 
  29.         self::log('AsyncTest callback run'); 
  30.         self::log('AsyncTest callback args:'.print_r($args, true)); 
  31.     } 
  32.     staticpublicfunction log($content) { 
  33.         $fullname = dirname(__FILE__).self::LOG_FILE; 
  34.         $content = date('[Y-m-d H:i:s]').$content."\n"
  35.         file_put_contents($fullname, $content, FILE_APPEND); 
  36.     } 
  37. AsyncTest::run();

就3個靜態方法,一個是用於調試的log方法,其餘都是字面意思。這個例子是對這種調用方式有個初步印象。而後直接上PHP的全部源碼:
php_async.zip
而後應該會有不少人會說,win下安裝不了gearman……因此我把java版的gearman server也放上去吧。
java-gearman-service-0.6.6.zip
linux


5.結論
通過以上配置犀牛同樣大的傢伙後(要裝一個Gearman,還要跑個Py腳本),咱們基本上就使PHP擁有了異步調用功能,固然其中還有一個狀態維護神馬的要本身去實現。因此發現,其實這個方案不咋樣,太複雜了。仍是使用一些web service的方式去作web callback會好點(問題是web callback同樣會超時……),這個請留意後續。
web

相關文章
相關標籤/搜索