Gearman 使用小知識(shí)

ideaa 發(fā)布于2019-06-27 11:30 / 1090人閱讀

摘要：目前項(xiàng)目采用的是來實(shí)現(xiàn)異步任務(wù)。關(guān)于介紹通俗的來說是一個(gè)分發(fā)任務(wù)的程序框架使用的應(yīng)用通常有三部分組成一個(gè)一個(gè)一個(gè)任務(wù)服務(wù)器。的作用是提出一個(gè)任務(wù)交給任務(wù)服務(wù)器。請(qǐng)求的調(diào)度者，用來負(fù)責(zé)協(xié)調(diào)把發(fā)出的請(qǐng)求轉(zhuǎn)發(fā)給合適的。

眾所周知，PHP要實(shí)現(xiàn)異步任務(wù)一般都是通過 Gearman Beanstalkd 等第三方來實(shí)現(xiàn)的。目前項(xiàng)目采用的是 Gearman 來實(shí)現(xiàn)異步任務(wù)。

關(guān)于Gearman介紹

通俗的來說

Gearman是一個(gè)分發(fā)任務(wù)的程序框架,使用Gearman的應(yīng)用通常有三部分組成：一個(gè)Client、一個(gè)Worker、一個(gè) 任務(wù)服務(wù)器。 Client的作用是提出一個(gè) Job 任務(wù) 交給 Job Server 任務(wù)服務(wù)器。Job Server 會(huì)去尋找一個(gè) 合適的 Worker 來完成這項(xiàng)任務(wù)。

Gearman官方網(wǎng)站地址 Gearman官網(wǎng)

關(guān)于Gearman 安裝和使用請(qǐng)參考 Gearman安裝和使用

PHP使用Gearman

Gearman 請(qǐng)求過程中涉及的三個(gè) Client -> Job -> Worker。

Client 請(qǐng)求的發(fā)起者，可以是C，PHP，Perl，MySQL UDF等等。

Job：請(qǐng)求的調(diào)度者，用來負(fù)責(zé)協(xié)調(diào)把Client發(fā)出的請(qǐng)求轉(zhuǎn)發(fā)給合適的Work。

Worker：請(qǐng)求的處理者，可以是C，PHP，Perl等等。

在這個(gè)過程中 work要長(zhǎng)駐后臺(tái)時(shí)刻準(zhǔn)備著被jobserver調(diào)用來處理job，所以worker不能死掉

PHP使用Gream實(shí)例（多帶帶函數(shù)實(shí)現(xiàn)）

client.php

addServer("127.0.0.1", 4730);
    $client->doBackground("say","hello world");

work.php

addServer("127.0.0.1", 4730);
     $worker->addFunction("say", "hello");
     while ($worker->work());
     function hello () {
         //DO SOMETHING...
     }

以上即是 PHP 調(diào)用 Gearman 簡(jiǎn)單的示例。

在我們實(shí)際的開發(fā)過程中，一般會(huì)采用框架進(jìn)行項(xiàng)目的開發(fā)，如果采用以上方式進(jìn)行調(diào)用，肯定會(huì)破壞項(xiàng)目原有的文件結(jié)構(gòu)。以下以ThinkPHP 3.2 版本進(jìn)行DEMO演示，調(diào)用方式跟單文件調(diào)用沒什么區(qū)別，區(qū)別在于 work的編寫。

因?yàn)?work需要長(zhǎng)駐后臺(tái)運(yùn)行，所以我們要聲明文件以 CLI 模式運(yùn)行。即：

方式一：

 "XXXX",
            "port" => "XXX"
        );
        public function __construct () {
            $sapi = php_sapi_name();
            if ($sapi != "cli") {
                exit();
            }
        }
        
        protected function add_work ($job,$func) {
            $worker= new GearmanWorker();
            $worker->addServer($this->$_config["host"], $this->$_config["port"]);
            $worker->addFunction($job, $func);
            while ($worker->work());
        }
        
        public function test () {
            $this->add_work("say","SysControllerDemoController ::say");
        }
        
        static public function say ($job) {
            $data = $job->workload();
            //DO SOMETHING...
        }
    }

方式二：

 "XXXX",
            "port" => "XXX"
        );
        public function __construct () {
            $sapi = php_sapi_name();
            if ($sapi != "cli") {
                exit();
            }
        }
        
        protected function add_work ($job,$func) {
            $worker= new GearmanWorker();
            $worker->addServer($this->$_config["host"], $this->$_config["port"]);
            $worker->addFunction($job, $func);
            while ($worker->work());
        }
        
        public function test () {
            $this->add_work("say","SysControllersay");
        }
    }
    
    function say ($job) {
        $data = $job->workload();
        //DO SOMETHING.....
    }

添加work到后臺(tái) 格式為 /var/www/index.php Sys/Demo/test