|
|
1.為啥php需要異步操作？
一般來(lái)說(shuō)php適用的場(chǎng)合是web頁(yè)面展示等耗時(shí)比較短的任務(wù)，如果對(duì)于比較花時(shí)間的操作如resize圖片、大數(shù)據(jù)導(dǎo)入、批量發(fā)送EDM、SMS等，就很容易出現(xiàn)操作超時(shí)情況。你可以說(shuō)我可以設(shè)置無(wú)限超時(shí)時(shí)間，等等你也要知道php有一個(gè)工作模式是fastcgi，php無(wú)限不超時(shí)，不代表fastcgi相應(yīng)不超時(shí)……如果你還想說(shuō)要fastcgi相應(yīng)永不超時(shí)，我建議你應(yīng)該跟你們的運(yùn)維人員討論去……
這個(gè)時(shí)候異步的操作就發(fā)揮他的作用了，由于是非阻塞操作，操作會(huì)即時(shí)返回，然后在后臺(tái)再慢慢干活。管你超時(shí)不超時(shí)的，我就沒(méi)有在當(dāng)前的進(jìn)程/線程下干活。看吧是不是很美好，不過(guò)其實(shí)這也是個(gè)坑……
2.php可以實(shí)現(xiàn)異步操作嗎？
答案是肯定的，不過(guò)網(wǎng)上各種的純php實(shí)現(xiàn)得就有點(diǎn)別扭了。socket模式、掛起進(jìn)程模式、有的還直接fork進(jìn)程。很好，各路神仙各顯神通。如果運(yùn)維人員看到的話，一定會(huì)×××××你們的，不把web server跑死才怪……
那還有其他更好的方法去實(shí)現(xiàn)這個(gè)異步操作的可能么？有，現(xiàn)在我們只有想怎么開(kāi)外掛了。查一下PECL主流的外掛方案有一堆的××MQ（消息隊(duì)列），其中有個(gè)用于任務(wù)分配的外掛進(jìn)入了我們的視線Gearman(其實(shí)這家伙才是角，我就不詳細(xì)介紹了，點(diǎn)連接看介紹)。
3.為啥選擇Gearman?
別的不說(shuō)，就說(shuō)他的client多，支持很多語(yǔ)言的client，你可以使用大部分你喜歡的語(yǔ)言去寫(xiě)worker。我個(gè)人是很煩語(yǔ)言之爭(zhēng)，你喜歡用神碼語(yǔ)言寫(xiě)worker都隨你喜歡。有數(shù)據(jù)持久化支持（就是把隊(duì)列保存到數(shù)據(jù)庫(kù)介質(zhì)中，那故障恢復(fù)也好做），有群集支持（其實(shí)很多××MQ都有這些功能）。PECL上有擴(kuò)展，也有純php實(shí)現(xiàn)擴(kuò)展。反正這個(gè)Gearman也活了很久了，雜七雜八的問(wèn)題都基本上解決了。
4.基本思路
有了Gearman這外掛就簡(jiǎn)單多了。就是向gearman發(fā)送一個(gè)任務(wù)，把執(zhí)行的任務(wù)發(fā)出去，然后等待worker去調(diào)用php cli去運(yùn)行我們的php代碼。
我就寫(xiě)了一下一個(gè)Python的worker（別問(wèn)我為啥用Python，1.我會(huì)Python，2.linux下不用裝runtime），你可以自己根據(jù)思路寫(xiě)一個(gè)php的worker，不過(guò)嘛，本人是不太信得過(guò)php跑的worker。其他語(yǔ)言飯可以用Java、node.js 或者其他語(yǔ)言實(shí)現(xiàn)一個(gè)worker試試。對(duì)用Golang寫(xiě)worker有興趣的朋友可以找我。
phpasync_worker_py
不好意思，里面是沒(méi)有注釋的。一個(gè)配置文件，一個(gè)py腳本。基本的功能也就是分析一下調(diào)用的參數(shù)，然后調(diào)用php Cli，就是那樣子而已。要讓py腳本跑起來(lái)請(qǐng)自行安裝Python的gearman模塊。
然后到php的部分先上測(cè)試代碼：
復(fù)制代碼 代碼如下:
<?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();
就3個(gè)靜態(tài)方法，一個(gè)是用于調(diào)試的log方法，其他都是字面意思。這個(gè)例子是對(duì)這種調(diào)用方式有個(gè)初步印象。然后直接上php的所有源碼：
php_async.zip
然后應(yīng)該會(huì)有很多人會(huì)說(shuō)，win下安裝不了gearman……所以我把Java版的gearman server也放上去吧。
Java-gearman-service-0.6.6.zip
5.結(jié)論
經(jīng)過(guò)以上配置犀牛一樣大的家伙后（要裝一個(gè)Gearman，還要跑個(gè)Py腳本），我們基本上就使php擁有了異步調(diào)用功能，當(dāng)然其中還有一個(gè)狀態(tài)維護(hù)神馬的要自己去實(shí)現(xiàn)。所以發(fā)現(xiàn)，其實(shí)這個(gè)方案不咋樣，太復(fù)雜了。還是使用一些web service的方式去做web callback會(huì)好點(diǎn)（問(wèn)題是web callback一樣會(huì)超時(shí)……），這個(gè)請(qǐng)留意后續(xù)。
為防止上面的代碼無(wú)法下載，腳本之家特打包下載
原文鏈接：http://my.oschina.NET/wakanoc/blog/101789
php技術(shù)：關(guān)于PHP實(shí)現(xiàn)異步操作的研究，轉(zhuǎn)載需保留來(lái)源！
鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請(qǐng)第一時(shí)間聯(lián)系我們修改或刪除，多謝。
