溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

如何在PHP項(xiàng)目中實(shí)現(xiàn)一個(gè)異步操作功能

發(fā)布時(shí)間:2021-01-22 14:56:19 來(lái)源:億速云 閱讀:174 作者:Leah 欄目:開(kāi)發(fā)技術(shù)

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)如何在PHP項(xiàng)目中實(shí)現(xiàn)一個(gè)異步操作功能,文章內(nèi)容豐富且以專(zhuān)業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。

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

上述就是小編為大家分享的如何在PHP項(xiàng)目中實(shí)現(xiàn)一個(gè)異步操作功能了,如果剛好有類(lèi)似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道。

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

php
AI