PHP-Resque用法

2020-07-16 10:06:31

PHP-Resque用法

PHP-Resque是PHP對Resque的擴充套件庫,可以使PHP也能進行使用Resque,Resque是基於Redis開發的後台進程系統,相較其它的Queue系統, Resque的設計是非常簡潔,充分利用Redis的特性。

一、安裝 php-resque

進入專案根目錄,composer 安裝 php-resque

composer require chrisboulton/php-resque

二、常用方法

1、連線 redis

// setBackend($server, $database = 0)
Resque::setBackend('127.0.0.1:6379');

2、向佇列中新增工作

// enqueue($queue, $class, $args = null, $trackStatus = false)
$token = Resque::enqueue('default', 'My_Job', ['name'=>'test'], true);

3、檢視工作狀態

$status = (new Resque_Job_Status($token))->get();

4、停止(移除)工作

(new Resque_Job_Status($token))->stop();

三、常駐任務處理佇列(範例:worker.php)

// 處理 default 佇列;也可以填 *,代表所有佇列
$worker = new Resque_Worker('default');
// LOG_NONE 不寫紀錄檔, LOG_NORMAL 普通,LOG_VERBOSE 詳細
$worker->logLevel = Resque_Worker::LOG_VERBOSE;
// 佇列處理時間間隔,單位:秒
$worker->work(5);

註:worker.php 要以命令列的方法執行,並長駐後台,/usr/local/php/bin/php /xxx/xxx/worker.php

四、處理工作的類

class My_Job
{
    /**
     * 前置操作
     * @return void
     */
    public function setUp()
    {
        // ... Set up environment for this job
    }
    /**
     * 消費佇列
     * @return void
     */
    public function perform()
    {
        // execute a job
    }
    /**
     * 後置操作
     * @return void
     */
    public function tearDown()
    {
        // ... Remove environment for this job
    }
}

推薦教學:《PHP教學

以上就是PHP-Resque用法的詳細內容,更多請關注TW511.COM其它相關文章!