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的部分先上測試程式碼:
- require_once 'PHPAsyncClient.php';
- date_default_timezone_set('Asia/Shanghai');
- class AsyncTest {
- const
- LOG_FILE = '/debug.log';
- static public function run() {
- if (PHPAsyncClient::in_callback(__FILE__)) {
- self::log('php Async callback');
- PHPAsyncClient::parse();
- return;
- }
- if (PHPAsyncClient::is_main(__FILE__)) {
- self::log('main run');
- $async_call = PHPAsyncClient::getInstance();
- $async_call->AsyncCall('AsyncTest', 'callback', array(
- 'content' => 'Hello World!!!',
- ), array(
- 'class' => 'AsyncTest',
- 'method' => 'callback',
- 'params' => array(
- 'content' => 'Hello Callback!',
- ),
- ), __FILE__);
- return;
- }
- }
- static public function callback($args) {
- self::log('AsyncTest callback run');
- self::log('AsyncTest callback args:'.print_r($args, true));
- }
- static public function log($content) {
- $fullname = dirname(__FILE__).self::LOG_FILE;
- $content = date('[Y-m-d H:i:s]').$content."\n";
- file_put_contents($fullname, $content, FILE_APPEND);
- }
- }
- AsyncTest::run();