Laravel 队列

root@php-fpm:/var/www/laravel-demo# php artisan make:job PublishArticles
Job created successfully.

class PublishArticles implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public Article $article;
    public function __construct(Article $article)
    {
        $this->article=$article;
    }
    public function handle()
    {
        Log::info($this->article);
        //todo 发布文章
    }
}

$article=Article::query()->first();
\App\Jobs\PublishArticles::dispatch($article);

#效率高，代码更新时必须重启队列
php artisan queue:work

#效率低，代码更新时不必重启队列
php artisan queue:listen

php artisan queue:work redis

php artisan queue:work redis --queue=emails

php artisan queue:work --once

php artisan queue:work --max-jobs=1000

php artisan queue:work --stop-when-empty

# 处理进程一小时，然后退出...
php artisan queue:work --max-time=3600

php artisan queue:work --sleep=3

php artisan queue:restart

QUEUE_CONNECTION=null

QUEUE_CONNECTION=sync

composer require predis/predis

QUEUE_CONNECTION=redis

php artisan queue:table

php artisan migrate

QUEUE_CONNECTION=database

composer require pda/pheanstalk

QUEUE_CONNECTION=beanstalkd

php artisan queue:failed-table

php artisan migrate

#重试3次
#如果您没有为 --tries 选项指定值，则作业将仅尝试一次或与任务类的 $tries 属性指定的次数相同：
php artisan queue:work redis --tries=3

#重试3次，每次都3秒后重试
php artisan queue:work redis --tries=3 --backoff=3

#重试任务前等待的秒数。
public $backoff = 3;

#计算重试任务之前要等待的秒数。
public function backoff()
{
    return 3;
}

#计算重试任务之前要等待的秒数。
#第一次重试的重试延迟为 1 秒，第二次重试为 5 秒，第三次重试为 10 秒：
public function backoff()
{
    return [1, 5, 10];
}

class ProcessPodcast implements ShouldQueue
{
    use InteractsWithQueue, Queueable, SerializesModels;

    protected $podcast;
    public function __construct(Podcast $podcast)
    {
        $this->podcast = $podcast;
    }
    public function handle(AudioProcessor $processor)
    {
        // 处理上传的播客...
    }
    public function failed(Throwable $exception)
    {
        // 向用户发送失败通知等...
    }
}

#查看失败的任务（failed_jobs表）
php artisan queue:failed

#任务 ID 可用于重试失败的任务
php artisan queue:retry ce7bb17c-cdd8-41f0-a8ec-7b4fef4e5ece

#如有必要，可以向命令传递多个 ID:
php artisan queue:retry ce7bb17c-cdd8-41f0-a8ec-7b4fef4e5ece 91401d2c-0784-4f43-824c-34f94a33c24d

#还可以重试指定队列的所有失败任务:
php artisan queue:retry --queue=name

#重试所有失败任务，可以执行 queue:retry 命令，并将 all 作为 ID 传递:
php artisan queue:retry all

#如果要删除指定的失败任务，可以使用 queue:forget 命令:
php artisan queue:forget 91401d2c-0784-4f43-824c-34f94a33c24d

#删除 failed_jobs 表中所有失败任务，可以使用 queue:flush 命令:
php artisan queue:flush

#删除失败的任务2（和queue:flush有何不同？）
php artisan queue:prune-failed
php artisan queue:prune-failed --hours=48

/**
 * 如果任务的模型不存在，则删除该任务。
 *
 * @var bool
 */
public $deleteWhenMissingModels = true;

QUEUE_FAILED_DRIVER=null

php artisan queue:clear

php artisan queue:clear redis --queue=emails

php artisan queue:monitor redis:default,redis:deployments --max=100