PHP code example of busyphp / queue

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

busyphp / queue example snippets

return [
    // 默认驱动
    'default'     => 'sync',
    
    // 队列驱动配置
    'connections' => [
        // 同步驱动
        'sync'     => [
            'type' => 'sync',
        ],
        
        // 数据库驱动
        'database' => [
            'type'       => 'database',
            'queue'      => 'default',
        ],
        
        // redis驱动
        'redis'    => [
            'type'       => 'redis',
            'queue'      => 'default',
            'host'       => '127.0.0.1',
            'port'       => 6379,
            'password'   => '',
            'select'     => 0,
            'timeout'    => 0,
            'persistent' => false,
        ],
        
        // 更多驱动...
    ],
    
    // 任务失败
    'failed' => [
        'type'  => 'database',
    ],
];

use BusyPHP\queue\contract\JobFailedInterface;
use BusyPHP\queue\contract\JobInterface;
use BusyPHP\queue\Job;

class TestJob implements JobInterface, JobFailedInterface
{
    /**
     * 执行任务
     * @param Job   $job 任务对象
     * @param mixed $data 发布任务时自定义的数据
     */
    public function fire(Job $job, $data) : void
    {
        //....这里执行具体的任务 
        
        if ($job->attempts() > 3) {
             //通过这个方法可以检查这个任务已经重试了几次了
        }
        
        
        //如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
        $job->delete();
        
        // 也可以重新发布这个任务
        $job->release($delay); //$delay为延迟时间
    }
    
    
    /**
     * 执行任务达到最大重试次数后失败
     * @param mixed     $data 发布任务时自定义的数据
     * @param Throwable $e 异常
     */
    public function failed($data, Throwable $e) : void
    {
        // ...任务达到最大重试次数后，失败了
    }
}

// 发布一条任务到队列中
\BusyPHP\queue\facade\Queue::push($job, $data); 

// 发布一条延迟执行的任务到队列中
\BusyPHP\queue\facade\Queue::later(10, $job, $data); 

// 向 database 队列连接器中发布一条任务
\BusyPHP\queue\facade\Queue::connection('database')->push($job, $data);

// 向 redis 队列连接器中发布一条任务
\BusyPHP\queue\facade\Queue::connection('redis')->push($job, $data);

shell script
php think queue:work

shell script
php think queue:listen

shell script
php think queue:failed

shell script
php think queue:flush

shell script
php think queue:forget id 1(失败任务ID)

shell script
php think queue:forget id 1,2,3

shell script
php think queue:restart