Laravel 8 队列系统的新功能和变化

Laravel 8 附带了很酷的新特性，并对队列系统的一些更改。在本文中，咱们将研究这些特性和更改。php

变化

Backoff (回退)

已将 retryAfter() 方法和 retryAfter 排队做业，邮件，通知和侦听器的属性重命名为backoff。web

php artisan queue：work 命令的 --delay 选项也已重命名为 --backoff。数据库

您还应该知道，如今能够将数组传递给 backoff 属性，以指示 worker 实现指数回退 (exponential backoff)：数组

public $backoff = [30, 60];

或者从 backoff() 方法返回一个数组：微信

public function backoff()
{
    return [30, 60]; 
}

在这里使用指数回退，咱们指示 worker 在第一次失败后延迟 30 秒重试做业，而后在每次失败后延迟 60 秒。闭包

您还能够在 queue:work 命令上使用指数回退：工具

php artisan queue:Work --backoff=30,60

做业过时

排队做业，通知和侦听器的 timeoutAt 属性已重命名为 retryUntil。编码

使用 $retryUntil 指示 worker 继续重试做业，直到未来的某个时间为止。spa

您能够将 retryUntil 做为做业类的公共属性或 retryUntil 方法添加：.net

public function retryUntil()
{
    return now()->addDay();
}

新特性

队列闭包

您如今能够在调度队列闭包时链式调用 catch() 方法：

dispatch(function () {
    // Job logic...
})->catch(function (Throwable $e) {
    // Handle Failure...
});

若是做业失败，将调用提供给 catch() 方法的闭包。

数据库驱动程序可靠性

当使用数据库队列驱动程序将做业释放回队列时，Laravel 如今将在事务内执行操做。这意味着除非添加了新的已发布实例，不然不会从队列中删除做业。这大大减小了做业失败的机会。

Redis 驱动程序效率

当使用 Redis 队列驱动程序批量分发一组做业时， Laravel 将经过向 Redis 发送单个命令来执行操做。之前， Laravel曾经向 Redis 发送多个 rpush 命令，每一个做业一个。

Worker 优雅终止

从 Laravel 8 开始， Workers 将优雅退出，并调用由 App：：Terminating() 注册的任何终止回调。

Worker 自我终止

为了不内存泄漏，一般的作法是不时终止您的工做程序，而后让您的过程监视工具启动新的工做程序。一般是经过添加一个运行 queue:restart 令的CRON做业来完成的。

在 Laravel 8中，您能够指示 Workers 在处理了必定数量的做业或运行了特定的秒数后退出：

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

命名 Workers

你如今添加 --name 选项到 queue:work 命令:

php artisan queue:work --name=notifications

添加此功能的主要目的是容许人们自定义 Workers 在运行时如何选择哪一个队列来处理任务：

Worker::popUsing('notifications', function ($pop) {
    $queues = time()->atNight() 
        ? ['mail', 'webhooks'] 
        : ['push-notifications', 'sms', 'mail', 'webhooks'];

    foreach ($queues as $queue) {
        if (! is_null($job = $pop($queue))) {
            return $job;
        }
    }
});

任务批处理

Laravel 的任务批处理使您能够分派许多任务，以供您的 Workers 并行处理。您能够在批处理中的全部任务都处理完毕或任何批处理任务失败后执行操做：

Bus::batch([
    new ProcessFile(1),
    new ProcessFile(2),
    new ProcessFile(3),
])->dispatch();

您能够在官方文档中找到有关“做业批处理”的更多信息。

做业链

您如今可使用 Bus 直接调度一系列做业：

Bus::chain([
    new ExtractReports,
    new GenerateReport,
    new SendResults,
])->dispatch();

您还能够添加一个 catch() 回调，若是链中的任何做业失败都会被调用：

Bus::chain([
    new ExtractReports,
    new GenerateReport,
    new SendResults,
])->catch(function(){
    // Handle the chain failure.
})
->dispatch();

Horizon 平衡率

Horizon 中添加了两个新的配置选项： balanceMaxShift and balanceCooldown。

'environments' => [
    'environment' => [
        'supervisor-1' => [
            'balanceMaxShift' => 5,
        ],
    ],
],

balanceMaxShift 设置每次 Horizon 扩展工做程序池时要添加或删除的最大工做进程数。在 Horizon 的早期版本中，仅添加或删除了一个工做进程，如今您能够控制该数目。

至于 balanceCooldown ，它设置每一个缩放操做之间等待的秒数。在 Horizon 的早期版本中，这被硬编码为3秒。

'environments' => [
    'environment' => [
        'supervisor-1' => [
            'balanceCooldown' => 1,
        ],
    ],
],

本文分享自微信公众号 - PHP开源Hub（php_open）。
若有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一块儿分享。